fix(tui): no-op occupancy abort after bridge dispose

Author: TheGreatAxios

src/subagent/fleet-dry-drive.ts

@@ -77,7 +77,7 @@ export function shouldDriveOpenTasks(input: {
   );
 }
 
-function isPromiseLike(value: unknown): value is Promise<unknown> {
+export function isPromiseLike(value: unknown): value is Promise<unknown> {
   return typeof value === "object" && value !== null && "then" in value;
 }
 

src/tui/runtime-bridge.test.ts

@@ -2221,6 +2221,47 @@ describe("fleet-dry open-task drive (CL-7540)", () => {
     );
   });
 
+  test("pending occupancy abort after dispose does not idle or drain", async () => {
+    await withTestRenderer(
+      async (h) => {
+        const shell = createAppShell(h.renderer, {
+          terminal: { columns: 80, rows: 24 },
+          wireKeys: false,
+          run: "idle",
+        });
+        const port = createRecordingPort();
+        const bridge = attachSessionBridge(shell, port);
+        const prompt =
+          "The fleet has gone dry. Remaining open tasks:\n- t1: keep going (todo)\n";
+        let resolveDrive: ((ok: boolean) => void) | undefined;
+        bridge.setDryOpenTaskDriver(() => {
+          bridge.beginSystemContinuation(prompt);
+          return new Promise((resolve) => {
+            resolveDrive = resolve;
+          });
+        });
+        bridge.submit("dispatch workers", "immediate");
+        bridge.handle({ type: "fleet", running: 1 });
+        settleToollessTurn(bridge);
+        bridge.handle({ type: "fleet", running: 0 });
+        expect(shell.session.run).toBe("busy");
+        bridge.submit("when it finishes, summarize", "queue");
+        expect(badgeCount(shell.session)).toBe(1);
+        port.clear();
+        bridge.dispose();
+        const runAfterDispose = shell.session.run;
+        expect(runAfterDispose).toBe("busy");
+        resolveDrive?.(false);
+        await Promise.resolve();
+        expect(shell.session.run).toBe(runAfterDispose);
+        expect(badgeCount(shell.session)).toBe(1);
+        expect(port.calls.some((c) => c.op === "deliver")).toBe(false);
+        shell.dispose();
+      },
+      { width: 80, height: 24 },
+    );
+  });
+
   test("occupancy send abort does not swallow a later matching inbound", async () => {
     await withTestRenderer(
       async (h) => {

src/tui/runtime-bridge.ts

@@ -99,6 +99,7 @@ import {
   pendingAskWakeText,
   type PendingAskWake,
 } from "../subagent/fleet-report.js";
+import { isPromiseLike } from "../subagent/fleet-dry-drive.js";
 
 /** Tool name a sub-agent dispatch call carries — its row gets live progress. */
 const SPAWN_AGENT_TOOL_NAME = "spawn_agent";
@@ -1225,10 +1226,6 @@ function occupancyHold(bag: BridgeBag): boolean {
   return bag.liveFleet > 0 || bag.awaitingContinuationInference;
 }
 
-function isPromiseLike(value: unknown): value is Promise<unknown> {
-  return typeof value === "object" && value !== null && "then" in value;
-}
-
 function releaseRunToIdle(shell: AppShell, bag: BridgeBag): void {
   shell.session = setRunState(shell.session, "idle");
   bag.awaitingContinuationInference = false;
@@ -1272,6 +1269,7 @@ function settleRunToIdle(shell: AppShell, bag: BridgeBag): void {
     if (isPromiseLike(driven)) {
       bag.droveOpenTasksThisDry = true;
       const abortPendingDrive = (): void => {
+        if (bag.disposed) return;
         bag.droveOpenTasksThisDry = false;
         if (shell.session.run !== "busy") return;
         bag.lastSentMessage = "";