fix(tui): skip occupancy flush while the operator pause holds

Pause already holds the delivery queue. Occupancy and ask-wake still
started a new primary after Ctrl+C. Stall and expire do not pause,
so they still flush.

Author: TheGreatAxios

src/tui/agent-ask-wake.test.ts

@@ -11,8 +11,10 @@ import {
   createDeliveryGeneration,
   createLeftoverSend,
   createSessionOperationQueue,
+  isPaused,
   routeQueuedDelivery,
 } from "./delivery-queue.js";
+import { handleCtrlC } from "./shell/keys.js";
 import { ingestOperatorPrompt } from "./prompt-attachments.js";
 import {
   armFeedbackCapture,
@@ -623,6 +625,50 @@ describe("agent ask wake delivery", () => {
     });
   }
 
+  test("operator pause does not flush a stashed ask or mailbox occupancy", async () => {
+    await withAppShell(
+      async (shell) => {
+        const sends: string[] = [];
+        const bridge = attachSessionBridge(
+          shell,
+          createLiveSessionPort({
+            send: (text) => {
+              sends.push(text);
+            },
+            deliver: (text) => {
+              sends.push(text);
+            },
+            interrupt: () => undefined,
+          }),
+        );
+        try {
+          const order = trackMailOrder(bridge, true);
+          bridge.handle({ type: "inference.start", data: {} });
+          bridge.handle({
+            type: "inference.text.delta",
+            data: { token: "ok" },
+          });
+          bridge.handle({ type: "agent-ask", asks: [wake("a1", "q1")] });
+          expect(sends).toEqual([]);
+
+          handleCtrlC(shell);
+          expect(isPaused(shell.session)).toBe(true);
+          expect(sends).toEqual([]);
+          expect(order).toEqual([]);
+          expect(bridge.turn.isProcessing).toBe(false);
+
+          bridge.handle({ type: "agent-ask", asks: [wake("a2", "q2")] });
+          expect(sends).toEqual([]);
+          expect(order).toEqual([]);
+          expect(bridge.turn.isProcessing).toBe(false);
+        } finally {
+          bridge.dispose();
+        }
+      },
+      { shell: { run: "busy" } },
+    );
+  });
+
   test("a wake question with bracket lines does not spoof attachment-echo matching", async () => {
     await withWakeBridge((bridge, sends, shell) => {
       const ask = {

src/tui/runtime-bridge.ts

@@ -2093,6 +2093,7 @@ export function attachSessionBridge(
     });
   };
   const flushMailboxMail = (): boolean => {
+    if (isPaused(shell.session)) return false;
     if (bag.disposed || bag.turn.isProcessing) return false;
     try {
       if (bag.mailboxMailDriver?.() === true) return true;
@@ -2104,6 +2105,7 @@ export function attachSessionBridge(
   bag.flushMailboxMail = flushMailboxMail;
 
   const flushPendingAskWake = (): void => {
+    if (isPaused(shell.session)) return;
     if (bag.disposed || bag.turn.isProcessing || bag.turn.blockedGateCount > 0)
       return;
     if (mailboxMailDriveClaimed(bag.mailboxMailDriver)) return;
@@ -2133,6 +2135,7 @@ export function attachSessionBridge(
   bag.flushPendingAskWake = flushPendingAskWake;
 
   const flushOccupancyThenWake = (): void => {
+    if (isPaused(shell.session)) return;
     if (flushMailboxMail() || bag.turn.isProcessing) return;
     flushPendingAskWake();
   };
@@ -2188,7 +2191,10 @@ export function attachSessionBridge(
     bag.askWakeTurnArmed = false;
     bag.turn = turnStateOnInterrupt(bag.turn, now());
     paintPhase();
-    flushOccupancyThenWake();
+    // Operator pause holds occupancy/ask-wake: a stashed mailbox or ask must
+    // not start a new primary until an explicit send. Stall/expire do not
+    // set paused, so they still flush here.
+    if (!isPaused(shell.session)) flushOccupancyThenWake();
   };
 
   /**