44 lines
955 B
TypeScript
44 lines
955 B
TypeScript
import assert from "node:assert/strict";
|
|
import test from "node:test";
|
|
|
|
const { sanitizeRunStreamOptions } = await import(
|
|
new URL("./stream-mode.ts", import.meta.url).href
|
|
);
|
|
|
|
void test("drops unsupported stream modes from array payloads", () => {
|
|
const sanitized = sanitizeRunStreamOptions({
|
|
streamMode: [
|
|
"values",
|
|
"messages-tuple",
|
|
"custom",
|
|
"updates",
|
|
"events",
|
|
"tools",
|
|
],
|
|
});
|
|
|
|
assert.deepEqual(sanitized.streamMode, [
|
|
"values",
|
|
"messages-tuple",
|
|
"custom",
|
|
"updates",
|
|
"events",
|
|
]);
|
|
});
|
|
|
|
void test("drops unsupported stream modes from scalar payloads", () => {
|
|
const sanitized = sanitizeRunStreamOptions({
|
|
streamMode: "tools",
|
|
});
|
|
|
|
assert.equal(sanitized.streamMode, undefined);
|
|
});
|
|
|
|
void test("keeps payloads without streamMode untouched", () => {
|
|
const options = {
|
|
streamSubgraphs: true,
|
|
};
|
|
|
|
assert.equal(sanitizeRunStreamOptions(options), options);
|
|
});
|