summaryrefslogtreecommitdiffhomepage
path: root/src/core/wire
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/wire')
-rw-r--r--src/core/wire/conformance.test.ts8
-rw-r--r--src/core/wire/conformance.ts4
2 files changed, 10 insertions, 2 deletions
diff --git a/src/core/wire/conformance.test.ts b/src/core/wire/conformance.test.ts
index a258873..2fdd3cb 100644
--- a/src/core/wire/conformance.test.ts
+++ b/src/core/wire/conformance.test.ts
@@ -75,6 +75,7 @@ describe("classifies every AgentEvent type", () => {
{ type: "error", conversationId: "c1", turnId: "t1", message: "oops" },
{ type: "done", conversationId: "c1", turnId: "t1", reason: "complete" },
{ type: "turn-sealed", conversationId: "c1", turnId: "t1" },
+ { type: "steering", conversationId: "c1", turnId: "t1", text: "steer mid-turn" },
];
it("returns a stable label for every AgentEvent.type variant", () => {
@@ -93,11 +94,12 @@ describe("classifies every AgentEvent type", () => {
"error",
"done",
"turn-sealed",
+ "steering",
]);
});
- it("covers all 13 AgentEvent variants", () => {
- expect(samples).toHaveLength(13);
+ it("covers all 14 AgentEvent variants", () => {
+ expect(samples).toHaveLength(14);
});
});
@@ -152,6 +154,7 @@ describe("classifies every WsClientMessage type", () => {
{ type: "chat.send" as const, message: "hi" },
{ type: "chat.subscribe" as const, conversationId: "c1" },
{ type: "chat.unsubscribe" as const, conversationId: "c1" },
+ { type: "chat.queue" as const, conversationId: "c1", text: "steer" },
];
const labels = msgs.map(assertWsClientMessageExhaustive);
expect(labels).toEqual([
@@ -161,6 +164,7 @@ describe("classifies every WsClientMessage type", () => {
"chat.send",
"chat.subscribe",
"chat.unsubscribe",
+ "chat.queue",
]);
});
});
diff --git a/src/core/wire/conformance.ts b/src/core/wire/conformance.ts
index 13be78c..6e87e5c 100644
--- a/src/core/wire/conformance.ts
+++ b/src/core/wire/conformance.ts
@@ -34,6 +34,8 @@ export function assertAgentEventExhaustive(event: AgentEvent): string {
return "turn-sealed";
case "step-complete":
return "step-complete";
+ case "steering":
+ return "steering";
default:
return event satisfies never;
}
@@ -102,6 +104,8 @@ export function assertWsClientMessageExhaustive(msg: WsClientMessage): string {
return "chat.subscribe";
case "chat.unsubscribe":
return "chat.unsubscribe";
+ case "chat.queue":
+ return "chat.queue";
default:
return msg satisfies never;
}