ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-28 05:16:23 -06:00
Code Issues Packages Projects Releases Wiki Activity

test(xai): cover playback mark overflow

Browse Source
This commit is contained in:
Vincent Koc
2026-08-04 09:06:53 +08:00
parent 73544a73af
commit d5d4a63733
1 changed files with 39 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
extensions/xai/realtime-voice-provider.test.ts
+39
View File
@@ -1,6 +1,7 @@
// Xai tests cover realtime voice provider plugin behavior.
import { REALTIME_VOICE_AUDIO_FORMAT_PCM16_24KHZ } from "openclaw/plugin-sdk/realtime-voice";
import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
import { XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS } from "./realtime-voice-config.js";
import { buildXaiRealtimeVoiceProvider } from "./realtime-voice-provider.js";
const { FakeWebSocket, isProviderAuthProfileConfiguredMock, resolveApiKeyForProviderMock } =
@@ -1256,6 +1257,44 @@ describe("buildXaiRealtimeVoiceProvider", () => {
expect(parseSent(socket).slice(-1)).toEqual([{ type: "response.create" }]);
});
it("fails the session when playback marks exceed their ownership bound", async () => {
vi.stubEnv("XAI_API_KEY", "xai-env"); // pragma: allowlist secret
const onAudio = vi.fn();
const onClose = vi.fn();
const onError = vi.fn();
const onMark = vi.fn();
const bridge = createTestBridge({ onAudio, onClose, onError, onMark });
const socket = await openRealtimeBridge(bridge);
const delta = Buffer.from("assistant audio").toString("base64");
socket.emitServer({ type: "response.created" });
for (let index = 0; index < XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS; index += 1) {
socket.emitServer({ type: "response.output_audio.delta", delta });
}
socket.emitServer({ type: "response.output_audio.delta", delta });
expect(onAudio).toHaveBeenCalledTimes(XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS);
expect(onMark).toHaveBeenCalledTimes(XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS);
expect(onError).toHaveBeenCalledTimes(1);
expect(onError).toHaveBeenCalledWith(
expect.objectContaining({
message: `xAI realtime voice playback mark limit exceeded (${XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS})`,
}),
);
expect(onClose).toHaveBeenCalledTimes(1);
expect(onClose).toHaveBeenCalledWith("error");
expect(socket.closed).toBe(true);
socket.emitServer({ type: "response.output_audio.delta", delta });
bridge.close();
expect(onAudio).toHaveBeenCalledTimes(XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS);
expect(onError).toHaveBeenCalledTimes(1);
expect(onClose).toHaveBeenCalledTimes(1);
await expect(bridge.connect()).rejects.toThrow(
`xAI realtime voice playback mark limit exceeded (${XAI_REALTIME_MAX_PENDING_PLAYBACK_MARKS})`,
);
});
it("preserves pending parallel tool calls across resumed reconnects", async () => {
vi.useFakeTimers();
vi.stubEnv("XAI_API_KEY", "xai-env"); // pragma: allowlist secret