Drop the occupancy continuation echo when the send aborts

beginSystemContinuation queues the occupancy string on pendingEchoes. Abort without a matching message.received left that echo in place, so a later inbound with the same text could be swallowed. Pop that continuation echo on abort without wiping unrelated operator echoes.

Author: TheGreatAxios

src/tui/runtime-bridge.test.ts

@@ -1626,6 +1626,48 @@ describe("fleet-dry open-task drive (CL-7540)", () => {
     );
   });
 
+  test("occupancy send abort drops the continuation echo so a later matching inbound paints", 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);
+        try {
+          const occupancy =
+            "The fleet has gone dry. Remaining open tasks:\n- t1: keep going (todo)\n";
+          const operator = "dispatch workers";
+          bridge.submit(operator, "immediate");
+          const userRowsAfterSubmit = shell.streamLog.filter((r) => r.role === "user").length;
+          bridge.beginSystemContinuation(occupancy);
+          bridge.abortSystemContinuation();
+          expect(shell.session.run).toBe("idle");
+
+          bridge.handle({
+            type: "message.received",
+            data: { message: { content: operator } },
+          });
+          expect(shell.streamLog.filter((r) => r.role === "user").length).toBe(userRowsAfterSubmit);
+
+          bridge.handle({
+            type: "message.received",
+            data: { message: { content: occupancy } },
+          });
+          expect(shell.streamLog.filter((r) => r.role === "user").length).toBe(
+            userRowsAfterSubmit + 1,
+          );
+        } finally {
+          bridge.dispose();
+          shell.dispose();
+        }
+      },
+      { width: 80, height: 24 },
+    );
+  });
+
   test("occupancy send abort resets the turn without a following reply", async () => {
     await withTestRenderer(
       async (h) => {

src/tui/runtime-bridge.ts

@@ -221,7 +221,8 @@ export interface SessionBridge {
    */
   beginSystemContinuation: (text: string) => void;
   /**
-   * Occupancy send failed after beginSystemContinuation. Re-arm the dry-open
+   * Occupancy send failed after beginSystemContinuation. Drop the occupancy
+   * echo so a later matching inbound is not swallowed, re-arm the dry-open
    * latch, drop the continuation hold, and idle so follow-ups can drain and a
    * later settle can take another occupancy shot.
    */
@@ -1617,6 +1618,18 @@ export function attachSessionBridge(
     },
     abortSystemContinuation: () => {
       if (bag.disposed) return;
+      if (bag.awaitingContinuationInference) {
+        const occupancy = bag.lastSentMessage;
+        if (occupancy.length > 0) {
+          const last = bag.pendingEchoes.length - 1;
+          if (last >= 0 && bag.pendingEchoes[last] === occupancy) {
+            bag.pendingEchoes.pop();
+          } else {
+            const index = bag.pendingEchoes.lastIndexOf(occupancy);
+            if (index !== -1) bag.pendingEchoes.splice(index, 1);
+          }
+        }
+      }
       bag.awaitingContinuationInference = false;
       bag.pendingDryOpenDrive = true;
       bag.lastSentMessage = "";