LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-13 23:56:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: verify acp spawn wake routing

Browse Source
This commit is contained in:
Shakker
2026-05-11 15:41:36 +01:00
parent 0693603e5f
commit af4e90f41b
1 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/agents/acp-spawn-parent-stream.test.ts
View File

@@ -175,20 +175,19 @@ describe("startAcpSpawnParentStreamRelay", () => {
});
vi.advanceTimersByTime(15);
expect(enqueueSystemEventMock).toHaveBeenCalledWith(
expect.stringContaining("codex: hello from child"),
expect.objectContaining({
contextKey: "acp-spawn:run-cron:progress",
sessionKey: "global",
trusted: false,
}),
);
expect(requestHeartbeatMock).toHaveBeenCalledWith(
expect.objectContaining({
agentId: "ops",
reason: "acp:spawn:stream",
}),
const progressEvent = enqueueSystemEventMock.mock.calls.find(
([text]) => typeof text === "string" && text.includes("codex: hello from child"),
);
expect(progressEvent?.[0]).toContain("codex: hello from child");
const progressOptions = progressEvent?.[1] as
| { contextKey?: unknown; sessionKey?: unknown; trusted?: unknown }
| undefined;
expect(progressOptions?.contextKey).toBe("acp-spawn:run-cron:progress");
expect(progressOptions?.sessionKey).toBe("global");
expect(progressOptions?.trusted).toBe(false);
const heartbeatOptions = requestHeartbeatMock.mock.calls[0]?.[0];
expect(heartbeatOptions?.agentId).toBe("ops");
expect(heartbeatOptions?.reason).toBe("acp:spawn:stream");
expect(requestHeartbeatMock.mock.calls[0]?.[0]).not.toHaveProperty("sessionKey");
relay.dispose();
});