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

test: share qa channel harness

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-20 21:16:24 +01:00
parent 512dc4f2b1
commit c12500cf50
1 changed files with 56 additions and 82 deletions
Download Patch File Download Diff File Expand all files Collapse all files

138
extensions/qa-channel/src/channel.test.ts
View File

@@ -83,44 +83,62 @@ function createMockQaRuntime(params?: {
} as unknown as PluginRuntime;
}
function createQaChannelConfig(params: { baseUrl: string; allowFrom?: string[] }) {
return {
channels: {
"qa-channel": {
baseUrl: params.baseUrl,
botUserId: "openclaw",
botDisplayName: "OpenClaw QA",
allowFrom: params.allowFrom,
},
},
};
}
async function startQaChannelTestHarness(params?: {
runtime?: PluginRuntime;
allowFrom?: string[];
}) {
installQaChannelTestRegistry();
const state = createQaBusState();
const bus = await startQaBusServer({ state });
setQaChannelRuntime(params?.runtime ?? createMockQaRuntime());
const cfg = createQaChannelConfig({ baseUrl: bus.baseUrl, allowFrom: params?.allowFrom });
const account = qaChannelPlugin.config.resolveAccount(cfg, "default");
const abort = new AbortController();
const startAccount = qaChannelPlugin.gateway?.startAccount;
expect(startAccount).toBeDefined();
const task = startAccount!(
createStartAccountContext({
account,
cfg,
abortSignal: abort.signal,
}),
);
return {
state,
async stop() {
abort.abort();
await task;
await bus.stop();
},
};
}
describe("qa-channel plugin", () => {
it("roundtrips inbound DM traffic through the qa bus", { timeout: 20_000 }, async () => {
installQaChannelTestRegistry();
const state = createQaBusState();
const bus = await startQaBusServer({ state });
setQaChannelRuntime(createMockQaRuntime());
const cfg = {
channels: {
"qa-channel": {
baseUrl: bus.baseUrl,
botUserId: "openclaw",
botDisplayName: "OpenClaw QA",
allowFrom: ["*"],
},
},
};
const account = qaChannelPlugin.config.resolveAccount(cfg, "default");
const abort = new AbortController();
const startAccount = qaChannelPlugin.gateway?.startAccount;
expect(startAccount).toBeDefined();
const task = startAccount!(
createStartAccountContext({
account,
cfg,
abortSignal: abort.signal,
}),
);
const harness = await startQaChannelTestHarness({ allowFrom: ["*"] });
try {
state.addInboundMessage({
harness.state.addInboundMessage({
conversation: { id: "alice", kind: "direct" },
senderId: "alice",
senderName: "Alice",
text: "hello",
});
const outbound = await state.waitFor({
const outbound = await harness.state.waitFor({
kind: "message-text",
textIncludes: "qa-echo: hello",
direction: "outbound",
@@ -128,49 +146,23 @@ describe("qa-channel plugin", () => {
});
expect("text" in outbound && outbound.text).toContain("qa-echo: hello");
} finally {
abort.abort();
await task;
await bus.stop();
await harness.stop();
}
});
it("stages inbound image attachments into agent media payload", { timeout: 20_000 }, async () => {
installQaChannelTestRegistry();
const state = createQaBusState();
const bus = await startQaBusServer({ state });
let dispatchedCtx: Record<string, unknown> | null = null;
setQaChannelRuntime(
createMockQaRuntime({
const harness = await startQaChannelTestHarness({
allowFrom: ["*"],
runtime: createMockQaRuntime({
onDispatch: (ctx) => {
dispatchedCtx = ctx;
},
}),
);
const cfg = {
channels: {
"qa-channel": {
baseUrl: bus.baseUrl,
botUserId: "openclaw",
botDisplayName: "OpenClaw QA",
allowFrom: ["*"],
},
},
};
const account = qaChannelPlugin.config.resolveAccount(cfg, "default");
const abort = new AbortController();
const startAccount = qaChannelPlugin.gateway?.startAccount;
expect(startAccount).toBeDefined();
const task = startAccount!(
createStartAccountContext({
account,
cfg,
abortSignal: abort.signal,
}),
);
});
try {
state.addInboundMessage({
harness.state.addInboundMessage({
conversation: { id: "alice", kind: "direct" },
senderId: "alice",
senderName: "Alice",
@@ -187,7 +179,7 @@ describe("qa-channel plugin", () => {
],
});
await state.waitFor({
await harness.state.waitFor({
kind: "message-text",
textIncludes: "qa-echo: describe this image",
direction: "outbound",
@@ -209,9 +201,7 @@ describe("qa-channel plugin", () => {
expect(mediaCtx.MediaPaths).toEqual([mediaCtx.MediaPath]);
expect(mediaCtx.MediaTypes).toEqual(["image/png"]);
} finally {
abort.abort();
await task;
await bus.stop();
await harness.stop();
}
});
@@ -221,15 +211,7 @@ describe("qa-channel plugin", () => {
const bus = await startQaBusServer({ state });
try {
const cfg = {
channels: {
"qa-channel": {
baseUrl: bus.baseUrl,
botUserId: "openclaw",
botDisplayName: "OpenClaw QA",
},
},
};
const cfg = createQaChannelConfig({ baseUrl: bus.baseUrl });
const handleAction = qaChannelPlugin.actions?.handleAction;
expect(handleAction).toBeDefined();
@@ -328,15 +310,7 @@ describe("qa-channel plugin", () => {
const bus = await startQaBusServer({ state });
try {
const cfg = {
channels: {
"qa-channel": {
baseUrl: bus.baseUrl,
botUserId: "openclaw",
botDisplayName: "OpenClaw QA",
},
},
};
const cfg = createQaChannelConfig({ baseUrl: bus.baseUrl });
const sendTarget = qaChannelPlugin.actions?.extractToolSend?.({
args: {