vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-06-03 22:04:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(voice-call): drive Twilio stream failure timers

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-31 13:59:40 +01:00
parent c797f02ff7
commit 657a668d94
1 changed files with 31 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
extensions/voice-call/src/providers/twilio.test.ts
View File

@@ -554,37 +554,43 @@ describe("TwilioProvider", () => {
});
it("fails stream playback when all audio sends and completion mark are dropped", async () => {
const provider = createProvider();
provider.registerCallStream("CA-dropped", "MZ-dropped");
vi.useFakeTimers();
try {
const provider = createProvider();
provider.registerCallStream("CA-dropped", "MZ-dropped");
const sendAudio = vi.fn(() => ({ sent: false }));
const sendMark = vi.fn(() => ({ sent: false }));
const mediaStreamHandler = {
queueTts: async (
_streamSid: string,
playFn: (signal: AbortSignal) => Promise<void>,
): Promise<void> => {
await playFn(new AbortController().signal);
},
sendAudio,
sendMark,
};
const sendAudio = vi.fn(() => ({ sent: false }));
const sendMark = vi.fn(() => ({ sent: false }));
const mediaStreamHandler = {
queueTts: async (
_streamSid: string,
playFn: (signal: AbortSignal) => Promise<void>,
): Promise<void> => {
await playFn(new AbortController().signal);
},
sendAudio,
sendMark,
};
provider.setMediaStreamHandler(mediaStreamHandler as never);
provider.setTTSProvider({
synthesisTimeoutMs: 5000,
synthesizeForTelephony: async () => Buffer.alloc(320),
});
provider.setMediaStreamHandler(mediaStreamHandler as never);
provider.setTTSProvider({
synthesisTimeoutMs: 5000,
synthesizeForTelephony: async () => Buffer.alloc(320),
});
await expect(
provider.playTts({
const playback = provider.playTts({
callId: "call-dropped",
providerCallId: "CA-dropped",
text: "Dropped audio",
}),
).rejects.toThrow("Telephony stream playback failed");
expect(sendAudio).toHaveBeenCalled();
expect(sendMark).toHaveBeenCalledTimes(1);
});
const playExpectation = expect(playback).rejects.toThrow("Telephony stream playback failed");
await vi.advanceTimersByTimeAsync(100);
await playExpectation;
expect(sendAudio).toHaveBeenCalled();
expect(sendMark).toHaveBeenCalledTimes(1);
} finally {
vi.useRealTimers();
}
});
it("fails stream playback when telephony synthesis returns empty audio", async () => {