mirror of
https://github.com/openclaw/openclaw.git
synced 2026-08-02 07:17:14 +00:00
fix(talk): satisfy lifecycle test contracts
This commit is contained in:
@@ -807,7 +807,18 @@ describe("GatewayRelayRealtimeTalkTransport", () => {
|
||||
reason: "error",
|
||||
talkEvent:
|
||||
callbackKind === "talk event"
|
||||
? ({ type: "session.closed", final: true } satisfies RealtimeTalkEvent)
|
||||
? ({
|
||||
id: "relay-1:1",
|
||||
type: "session.closed",
|
||||
sessionId: "relay-1",
|
||||
seq: 1,
|
||||
timestamp: "2026-05-05T00:00:00.000Z",
|
||||
mode: "realtime",
|
||||
transport: "gateway-relay",
|
||||
brain: "agent-consult",
|
||||
payload: {},
|
||||
final: true,
|
||||
} satisfies RealtimeTalkEvent)
|
||||
: undefined,
|
||||
}),
|
||||
).toThrow("consumer failed");
|
||||
|
||||
@@ -181,7 +181,7 @@ async function awaitRealtimeTalkMediaRequest(
|
||||
);
|
||||
throw realtimeTalkAbortReason(signal);
|
||||
}
|
||||
let removeAbortListener = () => undefined;
|
||||
let removeAbortListener: () => void = () => undefined;
|
||||
const aborted = new Promise<never>((_resolve, reject) => {
|
||||
const onAbort = () => reject(realtimeTalkAbortReason(signal));
|
||||
signal.addEventListener("abort", onAbort, { once: true });
|
||||
|
||||
Reference in New Issue
Block a user