github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 20:04:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf(test): tighten channel health monitor timer windows

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-18 22:36:44 +00:00
parent 65002b2b4b
commit 8a6b55e715
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/gateway/channel-health-monitor.test.ts
View File

@@ -91,7 +91,7 @@ describe("channel-health-monitor", () => {
it("does not run before the grace period", async () => { it("does not run before the grace period", async () => {
const manager = createMockChannelManager(); const manager = createMockChannelManager();
const monitor = startDefaultMonitor(manager, { startupGraceMs: 60_000 }); const monitor = startDefaultMonitor(manager, { startupGraceMs: 60_000 });
await vi.advanceTimersByTimeAsync(10_000); await vi.advanceTimersByTimeAsync(5_001);
expect(manager.getRuntimeSnapshot).not.toHaveBeenCalled(); expect(manager.getRuntimeSnapshot).not.toHaveBeenCalled();
monitor.stop(); monitor.stop();
}); });
@@ -244,9 +244,9 @@ describe("channel-health-monitor", () => {
cooldownCycles: 1, cooldownCycles: 1,
maxRestartsPerHour: 3, maxRestartsPerHour: 3,
}); });
await vi.advanceTimersByTimeAsync(5_500); await vi.advanceTimersByTimeAsync(5_001);
expect(manager.startChannel).toHaveBeenCalledTimes(3); expect(manager.startChannel).toHaveBeenCalledTimes(3);
await vi.advanceTimersByTimeAsync(2_000); await vi.advanceTimersByTimeAsync(1_001);
expect(manager.startChannel).toHaveBeenCalledTimes(3); expect(manager.startChannel).toHaveBeenCalledTimes(3);
monitor.stop(); monitor.stop();
}); });
@@ -282,7 +282,7 @@ describe("channel-health-monitor", () => {
const manager = createMockChannelManager(); const manager = createMockChannelManager();
const monitor = startDefaultMonitor(manager); const monitor = startDefaultMonitor(manager);
monitor.stop(); monitor.stop();
await vi.advanceTimersByTimeAsync(10_000); await vi.advanceTimersByTimeAsync(5_001);
expect(manager.getRuntimeSnapshot).not.toHaveBeenCalled(); expect(manager.getRuntimeSnapshot).not.toHaveBeenCalled();
}); });
@@ -291,7 +291,7 @@ describe("channel-health-monitor", () => {
const abort = new AbortController(); const abort = new AbortController();
const monitor = startDefaultMonitor(manager, { abortSignal: abort.signal }); const monitor = startDefaultMonitor(manager, { abortSignal: abort.signal });
abort.abort(); abort.abort();
await vi.advanceTimersByTimeAsync(10_000); await vi.advanceTimersByTimeAsync(5_001);
expect(manager.getRuntimeSnapshot).not.toHaveBeenCalled(); expect(manager.getRuntimeSnapshot).not.toHaveBeenCalled();
monitor.stop(); monitor.stop();
}); });