vrr/openclaw
2
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-10-03 09:39:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 30

test(heartbeat): await wake registration before advancing coalescing time

Browse source 
Vitest waitFor advances fake timers while real SQLite-backed cron admission is still pending. Observe the second synchronous wake registration through a deferred signal before advancing the existing 250ms coalescing window.

Preserve request counts, exact payloads, and both parent settlement assertions. The original failure is captured in CI; one local baseline passed. All 76 focused cases, targeted lint, and independent review pass after the fixture repair (41.32s wrapper).
This commit is contained in:
Peter Steinberger 2026-09-22 03:27:26 -07:00
parent 0ed077d468
commit 175c0b7d54
1 changed files with 11 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/cron/service.heartbeat-busy-poll.test.ts
View file

@ -415,8 +415,18 @@ describe("native heartbeat busy poll settlement", () => {
);
const task = "job" in added ? added.job : added;
const releaseMain = await holdLane(CommandLane.Main);
const bothRequested = createDeferred();
request.mockImplementation((opts, lifecycle) => {
const pending = requestHeartbeatAndWait({ ...opts, coalesceMs: 250 }, lifecycle);
if (request.mock.calls.length === 2) {
bothRequested.resolve();
}
return pending;
});
const parents = [cron.run(monitor.id, "force"), cron.run(task.id, "force")];
await vi.waitFor(() => expect(request).toHaveBeenCalledTimes(2));
// Polling with vi.waitFor advances the coalescer while SQLite admission is still pending.
await bothRequested.promise;
expect(request).toHaveBeenCalledTimes(2);
await vi.advanceTimersByTimeAsync(250);
expect(runOnce).toHaveBeenCalledOnce();
expect(runOnce.mock.calls[0]?.[0]).toMatchObject({