let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test(web): stabilize group heartbeat test

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-14 05:35:48 +00:00
parent 3f5dff35f8
commit c3528fb201
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/web/auto-reply.test.ts
View File

@@ -817,15 +817,24 @@ describe("web auto-reply", () => {
).toBe(false); ).toBe(false);
requestReplyHeartbeatNow({ coalesceMs: 0 }); requestReplyHeartbeatNow({ coalesceMs: 0 });
await new Promise((resolve) => setTimeout(resolve, 10)); let heartbeatCall = replyResolver.mock.calls.find(
controller.abort();
await run;
const heartbeatCall = replyResolver.mock.calls.find(
(call) => (call) =>
call[0]?.Body === HEARTBEAT_PROMPT && call[0]?.Body === HEARTBEAT_PROMPT &&
call[0]?.MessageSid === "sid-main", call[0]?.MessageSid === "sid-main",
); );
const deadline = Date.now() + 1000;
while (!heartbeatCall && Date.now() < deadline) {
await new Promise((resolve) => setTimeout(resolve, 10));
heartbeatCall = replyResolver.mock.calls.find(
(call) =>
call[0]?.Body === HEARTBEAT_PROMPT &&
call[0]?.MessageSid === "sid-main",
);
}
controller.abort();
await run;
expect(heartbeatCall).toBeDefined();
expect(heartbeatCall?.[0]?.From).toBe("+1555"); expect(heartbeatCall?.[0]?.From).toBe("+1555");
expect(heartbeatCall?.[0]?.To).toBe("+1555"); expect(heartbeatCall?.[0]?.To).toBe("+1555");
expect(heartbeatCall?.[0]?.MessageSid).toBe("sid-main"); expect(heartbeatCall?.[0]?.MessageSid).toBe("sid-main");