test(gateway): cover internal provider defaults

This commit is contained in:
Peter Steinberger
2026-01-09 22:40:32 +01:00
parent 92cc7a841c
commit f8bf041396
4 changed files with 75 additions and 1 deletions

View File

@@ -268,7 +268,10 @@ describe("sessions tools", () => {
);
expect(agentCalls).toHaveLength(8);
for (const call of agentCalls) {
expect(call.params).toMatchObject({ lane: "nested" });
expect(call.params).toMatchObject({
lane: "nested",
provider: "webchat",
});
}
expect(
agentCalls.some(
@@ -394,6 +397,15 @@ describe("sessions tools", () => {
await new Promise((resolve) => setTimeout(resolve, 0));
await new Promise((resolve) => setTimeout(resolve, 0));
const agentCalls = calls.filter((call) => call.method === "agent");
expect(agentCalls).toHaveLength(4);
for (const call of agentCalls) {
expect(call.params).toMatchObject({
lane: "nested",
provider: "webchat",
});
}
const replySteps = calls.filter(
(call) =>
call.method === "agent" &&

View File

@@ -169,6 +169,12 @@ describe("subagents", () => {
expect(first?.provider).toBe("discord");
expect(first?.sessionKey?.startsWith("agent:main:subagent:")).toBe(true);
expect(childSessionKey?.startsWith("agent:main:subagent:")).toBe(true);
const second = agentCalls[1]?.params as
| { provider?: string; deliver?: boolean; lane?: string }
| undefined;
expect(second?.lane).toBe("nested");
expect(second?.deliver).toBe(false);
expect(second?.provider).toBe("webchat");
expect(sendParams.provider).toBe("discord");
expect(sendParams.to).toBe("channel:req");

View File

@@ -375,6 +375,50 @@ describe("gateway server agent", () => {
await server.close();
});
test("agent uses webchat for internal runs when last provider is webchat", async () => {
const dir = await fs.mkdtemp(path.join(os.tmpdir(), "clawdbot-gw-"));
testState.sessionStorePath = path.join(dir, "sessions.json");
await fs.writeFile(
testState.sessionStorePath,
JSON.stringify(
{
main: {
sessionId: "sess-main-webchat-internal",
updatedAt: Date.now(),
lastProvider: "webchat",
lastTo: "+1555",
},
},
null,
2,
),
"utf-8",
);
const { server, ws } = await startServerWithClient();
await connectOk(ws);
const res = await rpcReq(ws, "agent", {
message: "hi",
sessionKey: "main",
provider: "last",
deliver: false,
idempotencyKey: "idem-agent-webchat-internal",
});
expect(res.ok).toBe(true);
const spy = vi.mocked(agentCommand);
const call = spy.mock.calls.at(-1)?.[0] as Record<string, unknown>;
expectProviders(call, "webchat");
expect(call.to).toBeUndefined();
expect(call.deliver).toBe(false);
expect(call.bestEffortDeliver).toBe(true);
expect(call.sessionId).toBe("sess-main-webchat-internal");
ws.close();
await server.close();
});
test(
"agent ack response then final response",
{ timeout: 8000 },

View File

@@ -0,0 +1,12 @@
import { describe, expect, it } from "vitest";
import { resolveGatewayMessageProvider } from "./message-provider.js";
describe("message-provider", () => {
it("normalizes gateway message providers and rejects unknown values", () => {
expect(resolveGatewayMessageProvider("discord")).toBe("discord");
expect(resolveGatewayMessageProvider(" imsg ")).toBe("imessage");
expect(resolveGatewayMessageProvider("teams")).toBe("msteams");
expect(resolveGatewayMessageProvider("nope")).toBeUndefined();
});
});