root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test(FN-4890): cover board-stall verification and cooldown

Browse Source 
Fusion-Task-Id: FN-4890
Fusion-Task-Lineage: d1ae6585-7df0-481f-83c3-c7cdd45daf4f
This commit is contained in:
Fusion (runfusion.ai)
2026-05-17 10:17:00 -07:00
committed by gsxdsm
parent a6898c5ba4
commit 70169972ed
1 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
packages/engine/src/__tests__/reliability-interactions/board-stall-auto-recovery.test.ts
View File

@@ -158,4 +158,39 @@ describe("reliability interactions: board stall auto-recovery", () => {
expect(notify).toHaveBeenCalledTimes(1);
manager.stop();
});
it("skips unrecovered notification when progress resumes", async () => {
const holder = makeTask("FN-10", { column: "in-progress", paused: true, pausedReason: "waiting" });
const { store, byId } = makeStore([holder]);
const notify = vi.fn(async () => undefined);
const manager = new SelfHealingManager(store, { rootDir: process.cwd(), getExecutingTaskIds: () => new Set(), ntfyNotifier: { notifyBoardStallUnrecovered: notify } });
await manager.runBoardStallAutoRecoverySweep();
byId.set("FN-11", makeTask("FN-11", { column: "todo", blockedBy: "FN-10" }));
await manager.runBoardStallAutoRecoverySweep();
(manager as any).boardStallWindow.transitionsOutOfInProgressInWindow = 1;
(manager as any).maintenanceTickCounter++;
const verification = await manager.runBoardStallAutoRecoverySweep();
expect(verification.unrecovered).toBe(false);
expect(notify).not.toHaveBeenCalled();
});
it("enforces cooldown for repeated unrecovered alerts", async () => {
const holder = makeTask("FN-20", { column: "in-progress", paused: true, pausedReason: "waiting" });
const { store, byId } = makeStore([holder]);
const notify = vi.fn(async () => undefined);
const manager = new SelfHealingManager(store, { rootDir: process.cwd(), getExecutingTaskIds: () => new Set(), ntfyNotifier: { notifyBoardStallUnrecovered: notify } });
await manager.runBoardStallAutoRecoverySweep();
byId.set("FN-21", makeTask("FN-21", { column: "todo", blockedBy: "FN-20" }));
await manager.runBoardStallAutoRecoverySweep();
(manager as any).maintenanceTickCounter++;
await manager.runBoardStallAutoRecoverySweep();
(manager as any).boardStallWindow.pendingVerification = { holderIds: ["FN-20"], followerCount: 1, startedAt: Date.now(), tick: 0 };
(manager as any).maintenanceTickCounter++;
await manager.runBoardStallAutoRecoverySweep();
expect(notify).toHaveBeenCalledTimes(1);
});
});