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

perf(test): flush mcp notifications directly

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-20 20:50:57 +01:00
parent 3d19f018ab
commit 553cc80027
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -67,6 +67,11 @@ function attachReadyGateway(
).resolveReady();
}
async function flushMcpNotifications() {
await Promise.resolve();
await Promise.resolve();
}
describe("openclaw channel mcp server", () => {
describe("gateway-backed flows", () => {
describe("gateway integration", () => {
@@ -190,9 +195,8 @@ describe("openclaw channel mcp server", () => {
},
});
await vi.waitFor(() => {
expect(channelNotifications).toHaveLength(1);
});
await flushMcpNotifications();
expect(channelNotifications).toHaveLength(1);
expect(channelNotifications[0]).toMatchObject({
content: "hello Claude",
meta: expect.objectContaining({
@@ -229,9 +233,8 @@ describe("openclaw channel mcp server", () => {
},
});
await vi.waitFor(() => {
expect(permissionNotifications).toHaveLength(1);
});
await flushMcpNotifications();
expect(permissionNotifications).toHaveLength(1);
expect(permissionNotifications[0]).toEqual({
request_id: "abcde",
behavior: "allow",
@@ -253,9 +256,8 @@ describe("openclaw channel mcp server", () => {
},
});
await vi.waitFor(() => {
expect(channelNotifications).toHaveLength(2);
});
await flushMcpNotifications();
expect(channelNotifications).toHaveLength(2);
expect(channelNotifications[1]).toMatchObject({
content: "plain string user turn",
meta: expect.objectContaining({