ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-27 21:07:01 -06:00
Code Issues Packages Projects Releases Wiki Activity

test(agents): mock incremental registry persistence (#116307)

Browse Source
This commit is contained in:
Vincent Koc
2026-07-30 16:27:31 +08:00
committed by GitHub
parent d952566385
commit ec53d0eaae
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/agents/subagent-registry.announce-loop-guard.test.ts
+6
View File
@@ -21,6 +21,7 @@ const mocks = vi.hoisted(() => ({
runSubagentAnnounceFlow: vi.fn().mockResolvedValue(false),
captureSubagentCompletionReply: vi.fn(),
loadSubagentRegistryFromSqlite: vi.fn(() => new Map()),
saveSubagentRegistryChangesToSqlite: vi.fn(),
saveSubagentRegistryToSqlite: vi.fn(),
resolveAgentTimeoutMs: vi.fn(() => 60_000),
scheduleOrphanRecovery: vi.fn(),
@@ -68,6 +69,7 @@ vi.mock("../infra/agent-events.js", () => ({
vi.mock("./subagent-registry.store.sqlite.js", () => ({
loadSubagentRegistryFromSqlite: mocks.loadSubagentRegistryFromSqlite,
saveSubagentRegistryChangesToSqlite: mocks.saveSubagentRegistryChangesToSqlite,
saveSubagentRegistryToSqlite: mocks.saveSubagentRegistryToSqlite,
}));
@@ -131,6 +133,7 @@ describe("announce loop guard (#18264)", () => {
mocks.runSubagentAnnounceFlow.mockReset();
mocks.runSubagentAnnounceFlow.mockResolvedValue(false);
mocks.scheduleOrphanRecovery.mockClear();
mocks.saveSubagentRegistryChangesToSqlite.mockClear();
mocks.saveSubagentRegistryToSqlite.mockClear();
mocks.updateSessionStore.mockClear();
registry.resetSubagentRegistryForTests({ persist: false });
@@ -221,6 +224,9 @@ describe("announce loop guard (#18264)", () => {
expect(mocks.runSubagentAnnounceFlow).not.toHaveBeenCalled();
expect(entry.cleanupCompletedAt).toBeGreaterThanOrEqual(beforeInit);
expect(mocks.saveSubagentRegistryChangesToSqlite).toHaveBeenCalledWith(expect.any(Map), [
entry.runId,
]);
});
test("expired completion-message entries are still resumed for announce", async () => {