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

test: share mcp bridge gateway setup

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-20 19:19:35 +01:00
parent f8bb35ead0
commit 901f2f38fc
1 changed files with 29 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
src/mcp/channel-server.test.ts
View File

@@ -39,6 +39,33 @@ async function connectMcpWithoutGateway(params?: { claudeChannelMode?: "auto" |
};
}
function attachReadyGateway(
bridge: OpenClawChannelBridge,
gatewayRequest: ReturnType<typeof vi.fn>,
) {
(
bridge as unknown as {
gateway: { request: typeof gatewayRequest; stopAndWait: () => Promise<void> };
readySettled: boolean;
resolveReady: () => void;
}
).gateway = {
request: gatewayRequest,
stopAndWait: async () => {},
};
(
bridge as unknown as {
readySettled: boolean;
resolveReady: () => void;
}
).readySettled = true;
(
bridge as unknown as {
resolveReady: () => void;
}
).resolveReady();
}
describe("openclaw channel mcp server", () => {
describe("gateway-backed flows", () => {
describe("gateway integration", () => {
@@ -293,27 +320,7 @@ describe("openclaw channel mcp server", () => {
});
const gatewayRequest = vi.fn().mockResolvedValue({ ok: true, channel: "telegram" });
(
bridge as unknown as {
gateway: { request: typeof gatewayRequest; stopAndWait: () => Promise<void> };
readySettled: boolean;
resolveReady: () => void;
}
).gateway = {
request: gatewayRequest,
stopAndWait: async () => {},
};
(
bridge as unknown as {
readySettled: boolean;
resolveReady: () => void;
}
).readySettled = true;
(
bridge as unknown as {
resolveReady: () => void;
}
).resolveReady();
attachReadyGateway(bridge, gatewayRequest);
vi.spyOn(bridge, "getConversation").mockResolvedValue({
sessionKey: "agent:main:main",
@@ -369,27 +376,7 @@ describe("openclaw channel mcp server", () => {
],
});
(
bridge as unknown as {
gateway: { request: typeof gatewayRequest; stopAndWait: () => Promise<void> };
readySettled: boolean;
resolveReady: () => void;
}
).gateway = {
request: gatewayRequest,
stopAndWait: async () => {},
};
(
bridge as unknown as {
readySettled: boolean;
resolveReady: () => void;
}
).readySettled = true;
(
bridge as unknown as {
resolveReady: () => void;
}
).resolveReady();
attachReadyGateway(bridge, gatewayRequest);
await expect(bridge.listConversations()).resolves.toEqual([
expect.objectContaining({