fix(bridge): buffer all delivery events for idle-Claude fallback

Channel notifications are fire-and-forget — if Claude is idle when a
DM or room message arrives the push is silently lost. Buffering every
event in the drain ensures it surfaces on the next tool call regardless
of whether the channel notification landed.

Actionable events still get the eager channel push for mid-turn delivery;
the drain echo on the following call is an acceptable trade-off.

Author: Mearman

src/bridges/claude-code/channel.ts

@@ -38,7 +38,7 @@ export async function run(): Promise<void> {
   store.setTransport(new TlsTransport(store.events, identity));
   const tool = new CommsTool(store, store.discovery);
   let agentId: string | undefined;
-  const informationalBuffer: string[] = [];
+  const pendingBuffer: string[] = [];
 
   const mcp = new McpServer(
     { name: "agent-comms", version: "0.2.0" },
@@ -49,14 +49,17 @@ export async function run(): Promise<void> {
     },
   );
 
-  // Actionable events with a non-info hint push immediately as channel
-  // notifications. Everything else (informational system events, or messages
-  // the sender flagged as info) buffers and drains on the next tool call.
+  // All events land in the drain buffer so idle-Claude never silently misses
+  // a message. Actionable events also get an eager channel push for mid-turn
+  // delivery. If the push fired and Claude caught it, the drain will echo it
+  // on the next tool call — acceptable duplication, far better than loss.
   store.onDelivery = async (_targetId: string, event) => {
     const line = formatDeliveryEvent(event);
     const hint = extractStreamingBehavior(event);
     const shouldPush = isActionableEvent(event) && hint !== "info";
 
+    pendingBuffer.push(line);
+
     if (shouldPush) {
       await mcp.server.notification({
         method: "notifications/claude/channel",
@@ -65,8 +68,6 @@ export async function run(): Promise<void> {
           meta: { streamingBehavior: hint ?? "steer" },
         },
       });
-    } else {
-      informationalBuffer.push(line);
     }
   };
 
@@ -114,7 +115,7 @@ export async function run(): Promise<void> {
         action,
       );
 
-      const pending = informationalBuffer.splice(0);
+      const pending = pendingBuffer.splice(0);
       const prefix =
         pending.length > 0
           ? `[comms] Pending:\n${pending.map((l) => `  📬 ${l}`).join("\n")}\n\n`