wehub-resource-sync
24 lines
1.3 KiB
TypeScript
24 lines
1.3 KiB
TypeScript
import test from "node:test";
|
|
import assert from "node:assert/strict";
|
|
|
|
import { transformChatCompletionSseToResponses } from "../../src/lib/translator/streamTransform.ts";
|
|
|
|
const SIMPLE_SSE = `data: {"id":"chatcmpl_demo","object":"chat.completion.chunk","created":1745366400,"model":"gpt-4o-mini","choices":[{"index":0,"delta":{"role":"assistant","content":"Hello"},"finish_reason":null}]}
|
|
|
|
data: {"id":"chatcmpl_demo","object":"chat.completion.chunk","created":1745366400,"model":"gpt-4o-mini","choices":[{"index":0,"delta":{"content":" world"},"finish_reason":null}]}
|
|
|
|
data: {"id":"chatcmpl_demo","object":"chat.completion.chunk","created":1745366400,"model":"gpt-4o-mini","choices":[{"index":0,"delta":{},"finish_reason":"stop"}],"usage":{"prompt_tokens":12,"completion_tokens":4,"total_tokens":16}}
|
|
|
|
data: [DONE]
|
|
`;
|
|
|
|
test("transformChatCompletionSseToResponses emits Responses API events", async () => {
|
|
const transformed = await transformChatCompletionSseToResponses(SIMPLE_SSE);
|
|
|
|
assert.match(transformed, /event: response\.output_item\.added/);
|
|
assert.match(transformed, /event: response\.output_text\.delta/);
|
|
assert.match(transformed, /event: response\.output_text\.done/);
|
|
assert.match(transformed, /event: response\.completed/);
|
|
assert.match(transformed, /data: \[DONE\]/);
|
|
});
|