vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 10:00:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(gateway): share hook session routing helper

Browse Source
This commit is contained in:
Vincent Koc
2026-04-12 17:09:07 +01:00
parent 43cb94a39a
commit 88dfc6e7b6
1 changed files with 32 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
src/gateway/server.hooks.test.ts
View File

@@ -102,6 +102,30 @@ async function expectFirstHookDelivery(
return firstBody;
}
async function expectHookAgentSessionRouting(params: {
port: number;
requestSessionKey: string;
expectedSessionKey: string;
}) {
mockIsolatedRunOkOnce();
const resAgent = await postHook(params.port, "/hooks/agent", {
message: "Do it",
name: "Email",
agentId: "hooks",
sessionKey: params.requestSessionKey,
});
expect(resAgent.status).toBe(200);
await waitForSystemEvent();
const routedCall = (cronIsolatedRun.mock.calls[0] as unknown[] | undefined)?.[0] as
| { sessionKey?: string; job?: { agentId?: string } }
| undefined;
expect(routedCall?.job?.agentId).toBe("hooks");
expect(routedCall?.sessionKey).toBe(params.expectedSessionKey);
drainSystemEvents(resolveMainKey());
}
describe("gateway server hooks", () => {
test("handles auth, wake, and agent flows", async () => {
testState.hooksConfig = { enabled: true, token: HOOK_TOKEN };
@@ -379,23 +403,11 @@ describe("gateway server hooks", () => {
};
setMainAndHooksAgents();
await withGatewayServer(async ({ port }) => {
mockIsolatedRunOkOnce();
const resAgent = await postHook(port, "/hooks/agent", {
message: "Do it",
name: "Email",
agentId: "hooks",
sessionKey: "agent:hooks:slack:channel:c123",
await expectHookAgentSessionRouting({
port,
requestSessionKey: "agent:hooks:slack:channel:c123",
expectedSessionKey: "agent:hooks:slack:channel:c123",
});
expect(resAgent.status).toBe(200);
await waitForSystemEvent();
const routedCall = (cronIsolatedRun.mock.calls[0] as unknown[] | undefined)?.[0] as
| { sessionKey?: string; job?: { agentId?: string } }
| undefined;
expect(routedCall?.job?.agentId).toBe("hooks");
expect(routedCall?.sessionKey).toBe("agent:hooks:slack:channel:c123");
drainSystemEvents(resolveMainKey());
});
});
@@ -408,23 +420,11 @@ describe("gateway server hooks", () => {
};
setMainAndHooksAgents();
await withGatewayServer(async ({ port }) => {
mockIsolatedRunOkOnce();
const resAgent = await postHook(port, "/hooks/agent", {
message: "Do it",
name: "Email",
agentId: "hooks",
sessionKey: "agent:main:slack:channel:c123",
await expectHookAgentSessionRouting({
port,
requestSessionKey: "agent:main:slack:channel:c123",
expectedSessionKey: "agent:hooks:slack:channel:c123",
});
expect(resAgent.status).toBe(200);
await waitForSystemEvent();
const routedCall = (cronIsolatedRun.mock.calls[0] as unknown[] | undefined)?.[0] as
| { sessionKey?: string; job?: { agentId?: string } }
| undefined;
expect(routedCall?.job?.agentId).toBe("hooks");
expect(routedCall?.sessionKey).toBe("agent:hooks:slack:channel:c123");
drainSystemEvents(resolveMainKey());
});
});