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

test(gateway): allow cold plugin route dispatch

Browse Source
This commit is contained in:
Vincent Koc
2026-04-29 03:17:41 -07:00
parent 923837accd
commit 0f6fea813c
1 changed files with 38 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

67
src/gateway/server.agent.gateway-server-agent-b.test.ts
View File

@@ -208,35 +208,44 @@ describe("gateway server agent", () => {
setRegistry(emptyRegistry);
});
test("agent reuses the last plugin delivery route when channel=last", async () => {
const registry = createRegistry([
{
pluginId: "msteams",
source: "test",
plugin: createMSTeamsPlugin(),
},
]);
setRegistry(registry);
await writeMainSessionEntry({
sessionId: "sess-teams",
lastChannel: "msteams",
lastTo: "conversation:teams-123",
});
const res = await rpcReq(ws, "agent", {
message: "hi",
sessionKey: "main",
channel: "last",
deliver: true,
idempotencyKey: "idem-agent-last-msteams",
});
expect(res.ok).toBe(true);
await expectAgentRoutingCall({
channel: "msteams",
deliver: true,
to: "conversation:teams-123",
runId: "idem-agent-last-msteams",
});
});
test(
"agent reuses the last plugin delivery route when channel=last",
{ timeout: 20_000 },
async () => {
const registry = createRegistry([
{
pluginId: "msteams",
source: "test",
plugin: createMSTeamsPlugin(),
},
]);
setRegistry(registry);
await writeMainSessionEntry({
sessionId: "sess-teams",
lastChannel: "msteams",
lastTo: "conversation:teams-123",
});
const res = await rpcReq(
ws,
"agent",
{
message: "hi",
sessionKey: "main",
channel: "last",
deliver: true,
idempotencyKey: "idem-agent-last-msteams",
},
20_000,
);
expect(res.ok).toBe(true);
await expectAgentRoutingCall({
channel: "msteams",
deliver: true,
to: "conversation:teams-123",
runId: "idem-agent-last-msteams",
});
},
);
test("agent preserves CLI session binding metadata when refreshing session state", async () => {
await useTempSessionStorePath();