vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-16 05:40:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: tighten voice call restore assertions

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-09 20:10:00 +01:00
parent 51d84bcc2e
commit aa97e92b41
1 changed files with 20 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
extensions/voice-call/src/manager.restore.test.ts
View File

@@ -19,6 +19,18 @@ function requireSingleActiveCall(manager: CallManager) {
return activeCall;
}
function requireRecord(value: unknown, label: string): Record<string, unknown> {
if (value === null || typeof value !== "object" || Array.isArray(value)) {
throw new Error(`expected ${label} to be a record`);
}
return value as Record<string, unknown>;
}
function requireSingleHangupCall(provider: FakeProvider) {
expect(provider.hangupCalls).toHaveLength(1);
return requireRecord(provider.hangupCalls[0], "hangup call");
}
describe("CallManager verification on restore", () => {
afterEach(() => {
vi.useRealTimers();
@@ -90,11 +102,8 @@ describe("CallManager verification on restore", () => {
});
expect(manager.getActiveCalls()).toHaveLength(0);
expect(provider.hangupCalls).toEqual([
expect.objectContaining({
reason: "timeout",
}),
]);
const hangupCall = requireSingleHangupCall(provider);
expect(hangupCall.reason).toBe("timeout");
await flushPendingCallRecordWritesForTest();
expect(loadActiveCallsFromStore(storePath).activeCalls.size).toBe(0);
@@ -215,13 +224,10 @@ describe("CallManager verification on restore", () => {
.map((call) => call.callId)
.toSorted(),
).toEqual(["active-a", "failure-a", "unknown-a"]);
expect(provider.hangupCalls).toEqual([
expect.objectContaining({
callId: "expired-a",
providerCallId: "expired-provider-a",
reason: "timeout",
}),
]);
const hangupCall = requireSingleHangupCall(provider);
expect(hangupCall.callId).toBe("expired-a");
expect(hangupCall.providerCallId).toBe("expired-provider-a");
expect(hangupCall.reason).toBe("timeout");
expect(logSpy).toHaveBeenCalledWith(
"[voice-call] Skipped 2 restored call(s) with no providerCallId",
);
@@ -265,11 +271,8 @@ describe("CallManager verification on restore", () => {
await vi.advanceTimersByTimeAsync(1_100);
expect(manager.getActiveCalls()).toHaveLength(0);
expect(provider.hangupCalls).toEqual([
expect.objectContaining({
reason: "timeout",
}),
]);
const hangupCall = requireSingleHangupCall(provider);
expect(hangupCall.reason).toBe("timeout");
});
it("restores dedupe keys from terminal persisted calls so replayed webhooks stay ignored", async () => {