From 7b7d6d01cf94ecad1dcaaa4b87670d50fe15790a Mon Sep 17 00:00:00 2001
From: Adam Malczewski <github@tradam.dev>
Date: Wed, 21 Oct 2026 19:39:47 +0900
Subject: fix(chat): bound live subscriptions and preserve unconfirmed input

---
 src/core/wire/conformance.test.ts | 8 ++++++++
 src/core/wire/conformance.ts      | 4 ++++
 2 files changed, 12 insertions(+)

(limited to 'src/core/wire')

diff --git a/src/core/wire/conformance.test.ts b/src/core/wire/conformance.test.ts
index b3c774f..6bafda1 100644
--- a/src/core/wire/conformance.test.ts
+++ b/src/core/wire/conformance.test.ts
@@ -178,6 +178,12 @@ describe("classifies every WsServerMessage type", () => {
         event: { type: "done" as const, conversationId: "c", turnId: "t", reason: "r" },
       },
       { type: "chat.error" as const, message: "e" },
+      { type: "chat.accepted" as const, conversationId: "c1", requestId: "r1" },
+      {
+        type: "chat.subscription-rejected" as const,
+        conversationId: "c1",
+        reason: "subscription-limit" as const,
+      },
       {
         type: "chat.queued" as const,
         conversationId: "conv-1",
@@ -235,6 +241,8 @@ describe("classifies every WsServerMessage type", () => {
       "error",
       "chat.delta",
       "chat.error",
+      "chat.accepted",
+      "chat.subscription-rejected",
       "chat.queued",
       "chat.resync-required",
       "conversation.open",
diff --git a/src/core/wire/conformance.ts b/src/core/wire/conformance.ts
index 3429ed0..cd53b65 100644
--- a/src/core/wire/conformance.ts
+++ b/src/core/wire/conformance.ts
@@ -87,6 +87,10 @@ export function assertWsServerMessageExhaustive(msg: WsServerMessage): string {
       return "chat.delta";
     case "chat.resync-required":
       return "chat.resync-required";
+    case "chat.accepted":
+      return "chat.accepted";
+    case "chat.subscription-rejected":
+      return "chat.subscription-rejected";
     case "chat.queued":
       return "chat.queued";
     case "chat.error":
-- 
cgit v1.2.3