vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-02 10:21:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(openai): settle roundtrip failures without rejection

Browse Source
This commit is contained in:
Vincent Koc
2026-07-30 23:50:00 +08:00
parent 5f0c49b65d
commit 17ef4a26f1
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
scripts/dev/realtime-talk-live-smoke.ts
View File

@@ -437,11 +437,9 @@ async function smokeOpenAIAudioRoundtrip(apiKey: string, cycleCount: number): Pr
let lateAudioBytes = 0;
let responseDone = false;
let closed = false;
let resolveRoundtrip: (() => void) | undefined;
let rejectRoundtrip: ((error: Error) => void) | undefined;
const roundtrip = new Promise<void>((resolve, reject) => {
let resolveRoundtrip: ((error?: Error) => void) | undefined;
const roundtrip = new Promise<Error | undefined>((resolve) => {
resolveRoundtrip = resolve;
rejectRoundtrip = reject;
});
const maybeResolveRoundtrip = () => {
if (
@@ -494,10 +492,10 @@ async function smokeOpenAIAudioRoundtrip(apiKey: string, cycleCount: number): Pr
maybeResolveRoundtrip();
}
},
onError: (error) => rejectRoundtrip?.(error),
onError: (error) => resolveRoundtrip?.(error),
onClose: (reason) => {
if (!closed && reason === "error") {
rejectRoundtrip?.(new Error("OpenAI audio roundtrip bridge closed with an error"));
resolveRoundtrip?.(new Error("OpenAI audio roundtrip bridge closed with an error"));
}
},
});
@@ -514,9 +512,12 @@ async function smokeOpenAIAudioRoundtrip(apiKey: string, cycleCount: number): Pr
// Observe failures immediately; the same promise is awaited after input streaming completes.
void boundedRoundtrip.catch(() => undefined);
chunksSent = await sendPcmAudioInChunks(bridge, inputAudio);
await boundedRoundtrip;
const roundtripError = await boundedRoundtrip;
if (roundtripError) {
throw roundtripError;
}
} catch (error) {
rejectRoundtrip?.(error instanceof Error ? error : new Error(String(error)));
resolveRoundtrip?.(error instanceof Error ? error : new Error(String(error)));
throw error;
} finally {
closed = true;