fix(tui): flush mailbox mail before ask wake on settle and gate close

settleRunToIdle (idle-with-fleet) and gateClosed flushed the ask wake before mailbox mail, letting a re-surface wake steal the turn occupancy should take. Match the #1080 abort-path rule: mail first, wake only if mail did not start a turn (isProcessing guard, deliveredAskWake dedupe — no duplicate wake).

Tests: 4 new CL-8061 order/suppression cases in agent-ask-wake.test.ts (failed pre-fix, pass post-fix).

Fixes CL-8061

Author: TheGreatAxios

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

@@ -405,6 +405,86 @@ describe("agent ask wake delivery", () => {
     });
   });
 
+  test("gate close flushes mailbox mail before the ask wake (CL-8061)", async () => {
+    await withWakeBridge((bridge, sends) => {
+      const order: string[] = [];
+      bridge.setOnAskWakeSent(() => {
+        order.push("wake");
+      });
+      bridge.setMailboxMailDriver(() => {
+        order.push("mail");
+        return false;
+      });
+      bridge.gateOpened();
+      bridge.handle({ type: "agent-ask", asks: [wake("a1", "q1")] });
+      expect(sends).toEqual([]);
+      bridge.gateClosed();
+      expect(order).toEqual(["mail", "wake"]);
+      expect(sends).toHaveLength(1);
+    });
+  });
+
+  test("gate close suppresses the wake when mail takes the turn (CL-8061)", async () => {
+    await withWakeBridge((bridge, sends) => {
+      const order: string[] = [];
+      bridge.setOnAskWakeSent(() => {
+        order.push("wake");
+      });
+      bridge.setMailboxMailDriver(() => {
+        order.push("mail");
+        bridge.beginSystemContinuation("mailbox occupancy");
+        return true;
+      });
+      bridge.gateOpened();
+      bridge.handle({ type: "agent-ask", asks: [wake("a1", "q1")] });
+      expect(sends).toEqual([]);
+      bridge.gateClosed();
+      expect(order).toEqual(["mail"]);
+      expect(sends).toEqual([]);
+    });
+  });
+
+  test("idle-with-fleet settle flushes mailbox mail before the ask wake (CL-8061)", async () => {
+    await withWakeBridge((bridge, sends) => {
+      const order: string[] = [];
+      bridge.setOnAskWakeSent(() => {
+        order.push("wake");
+      });
+      bridge.setMailboxMailDriver(() => {
+        order.push("mail");
+        return false;
+      });
+      bridge.handle({ type: "inference.start", data: {} });
+      bridge.handle({ type: "fleet", running: 1 });
+      bridge.handle({ type: "agent-ask", asks: [wake("a1", "q1")] });
+      expect(sends).toEqual([]);
+      bridge.handle({ type: "inference.done", data: {} });
+      expect(order).toEqual(["mail", "wake"]);
+      expect(sends).toHaveLength(1);
+    });
+  });
+
+  test("idle-with-fleet settle suppresses the wake when mail takes the turn (CL-8061)", async () => {
+    await withWakeBridge((bridge, sends) => {
+      const order: string[] = [];
+      bridge.setOnAskWakeSent(() => {
+        order.push("wake");
+      });
+      bridge.setMailboxMailDriver(() => {
+        order.push("mail");
+        bridge.beginSystemContinuation("mailbox occupancy");
+        return true;
+      });
+      bridge.handle({ type: "inference.start", data: {} });
+      bridge.handle({ type: "fleet", running: 1 });
+      bridge.handle({ type: "agent-ask", asks: [wake("a1", "q1")] });
+      expect(sends).toEqual([]);
+      bridge.handle({ type: "inference.done", data: {} });
+      expect(order).toEqual(["mail"]);
+      expect(sends).toEqual([]);
+    });
+  });
+
   test("clearQueuedDelivery drops stashed wakes and resets delivered identities", async () => {
     await withWakeBridge((bridge, sends) => {
       bridge.handle({ type: "inference.start", data: {} });

src/tui/runtime-bridge.ts

@@ -1322,9 +1322,11 @@ function settleRunToIdle(shell: AppShell, bag: BridgeBag): void {
     // Hold: the fleet is still live, so the run stays busy. Steers left
     // pending send now — the parent they were steering has stopped, so
     // each one starts its own turn — while follow-ups keep waiting.
+    // Occupancy/mailbox first so a re-surface wake cannot steal that turn;
+    // the trailing wake flush restates only if mail did not start one.
     drainSteersAtBoundary(shell, bag);
-    bag.flushPendingAskWake?.();
     bag.flushMailboxMail?.();
+    if (!bag.turn.isProcessing) bag.flushPendingAskWake?.();
     return;
   }
   if (!bag.droveOpenTasksThisDry) {
@@ -2032,8 +2034,10 @@ export function attachSessionBridge(
     if (bag.disposed) return;
     bag.turn = turnStateGateClosed(bag.turn, now());
     paintPhase();
-    flushPendingAskWake();
+    // Occupancy/mailbox first so a re-surface wake cannot steal that turn;
+    // the trailing wake flush restates only if mail did not start one.
     flushMailboxMail();
+    if (!bag.turn.isProcessing) flushPendingAskWake();
   };
 
   const tick = (): void => {