LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-16 18:34:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: pin realtime relay requests

Browse Source
This commit is contained in:
Shakker
2026-05-11 15:09:11 +01:00
parent 281a88d6df
commit 0343a2e689
1 changed files with 26 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
ui/src/ui/realtime-talk-gateway-relay.test.ts
View File

@@ -104,6 +104,13 @@ function pumpMicrophone(samples: Float32Array): void {
});
}
function requestCallsFor(
client: RealtimeTalkTransportContext["client"],
method: string,
): Array<Parameters<RealtimeTalkTransportContext["client"]["request"]>> {
return vi.mocked(client.request).mock.calls.filter((call) => call[0] === method);
}
describe("GatewayRelayRealtimeTalkTransport", () => {
beforeEach(() => {
listeners.clear();
@@ -209,7 +216,7 @@ describe("GatewayRelayRealtimeTalkTransport", () => {
});
pumpMicrophone(new Float32Array(4096));
expect(client.request).not.toHaveBeenCalledWith("talk.session.cancelOutput", expect.anything());
expect(requestCallsFor(client, "talk.session.cancelOutput")).toHaveLength(0);
const appendCall = vi
.mocked(client.request)
.mock.calls.find((call) => call[0] === "talk.session.appendAudio");
@@ -334,7 +341,7 @@ describe("GatewayRelayRealtimeTalkTransport", () => {
},
});
pumpMicrophone(speech);
expect(client.request).not.toHaveBeenCalledWith("talk.session.cancelOutput", expect.anything());
expect(requestCallsFor(client, "talk.session.cancelOutput")).toHaveLength(0);
pumpMicrophone(speech);
pumpMicrophone(speech);
@@ -435,9 +442,23 @@ describe("GatewayRelayRealtimeTalkTransport", () => {
args: { question: "status?" },
},
});
await vi.waitFor(() =>
expect(client.request).toHaveBeenCalledWith("talk.client.toolCall", expect.anything()),
);
await vi.waitFor(() => {
const toolCall = requestCallsFor(client, "talk.client.toolCall")[0];
const params = toolCall?.[1] as
| {
args?: unknown;
callId?: string;
name?: string;
relaySessionId?: string;
sessionKey?: string;
}
| undefined;
expect(params?.sessionKey).toBe("main");
expect(params?.callId).toBe("call-1");
expect(params?.name).toBe(REALTIME_VOICE_AGENT_CONSULT_TOOL_NAME);
expect(params?.args).toEqual({ question: "status?" });
expect(params?.relaySessionId).toBe("relay-1");
});
transport.stop();
await vi.waitFor(() =>