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

test(agents): share websocket tool followup helper

Browse Source
This commit is contained in:
Vincent Koc
2026-04-12 16:34:35 +01:00
parent f3b636481f
commit 93abf5ee4d
1 changed files with 40 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
src/agents/openai-ws-stream.e2e.test.ts
View File

@@ -88,6 +88,32 @@ function makeToolResultMessage(
} as unknown as StreamFnParams[1]["messages"][number];
}
async function runWebsocketToolFollowupTurn(params: {
streamFn: ReturnType<StreamFactory>;
context: StreamFnParams[1];
firstDone: AssistantMessage;
toolCallId: string;
output: string;
}) {
const secondContext = {
...params.context,
messages: [
...params.context.messages,
params.firstDone,
makeToolResultMessage(params.toolCallId, params.output),
],
} as unknown as StreamFnParams[1];
return expectDone(
await collectEvents(
params.streamFn(model, secondContext, {
transport: "websocket",
maxTokens: 128,
}),
),
);
}
async function collectEvents(stream: StreamReturn): Promise<AssistantMessageEvent[]> {
const events: AssistantMessageEvent[] = [];
const resolvedStream: AssistantMessageEventStream = await stream;
@@ -256,22 +282,13 @@ describe("OpenAI WebSocket e2e", () => {
expect(toolCall?.name).toBe("noop");
expect(toolCall?.id).toBeTruthy();
const secondContext = {
...firstContext,
messages: [
...firstContext.messages,
firstDone,
makeToolResultMessage(toolCall!.id, "TOOL_OK"),
],
} as unknown as StreamFnParams[1];
const secondDone = expectDone(
await collectEvents(
streamFn(model, secondContext, {
transport: "websocket",
maxTokens: 128,
}),
),
);
const secondDone = await runWebsocketToolFollowupTurn({
streamFn,
context: firstContext,
firstDone,
toolCallId: toolCall!.id,
output: "TOOL_OK",
});
expect(assistantText(secondDone)).toMatch(/TOOL_OK/);
},
@@ -340,22 +357,13 @@ describe("OpenAI WebSocket e2e", () => {
rawToolCall ? `${rawToolCall.call_id}|${rawToolCall.id}` : undefined,
);
const secondContext = {
...firstContext,
messages: [
...firstContext.messages,
firstDone,
makeToolResultMessage(toolCall!.id, "TOOL_OK"),
],
} as unknown as StreamFnParams[1];
const secondDone = expectDone(
await collectEvents(
streamFn(model, secondContext, {
transport: "websocket",
maxTokens: 128,
}),
),
);
const secondDone = await runWebsocketToolFollowupTurn({
streamFn,
context: firstContext,
firstDone,
toolCallId: toolCall!.id,
output: "TOOL_OK",
});
expect(assistantText(secondDone)).toMatch(/TOOL_OK/);
},