Give the session cap precedence over the open-task nudge

The cap policy's halt and abort decisions reuse the same wait/reply/done
action shapes as an ordinary end-of-turn yield, so the open-task nudge (and
the workflow nudge and goal continue-rule) could not tell a capped turn
apart from a plain one and rewrote its wait into a fresh infer(), silently
swallowing the cap and continuing the loop. Detect the moment the cap fires
and return its actions untouched before any continuation rewrite runs.

Claude-Session: https://claude.ai/code/session_01PiLfSXwRgDgMp5wC3SVAZn

Author: TheGreatAxios

src/agent/director.ts

@@ -652,9 +652,18 @@ class ChatDirectorImpl extends DefaultDirector {
       this.compaction.noteInferenceDone(event, state?.turns?.length ?? 0);
     }
 
+    const capAlreadyWarned = this.sessionCapWarned;
     const base = await super.decide(event, state, capabilities);
     const baseActions = Array.isArray(base) ? base : [base];
 
+    // The session cap's halt/abort reuses the same wait/reply/done shapes as
+    // an ordinary end-of-turn (see afterInferenceDone above), so every
+    // continuation rewrite below — open-task nudge, workflow nudge, goal
+    // continue-rule — would otherwise mistake it for a plain yield and
+    // replace it with a fresh infer(), silently swallowing the cap. Detect
+    // the false-to-true transition and return the cap's own actions as-is.
+    if (!capAlreadyWarned && this.sessionCapWarned) return base;
+
     this.compaction.noteIdleTurn(event, baseActions);
     const compacted = this.compaction.interceptActions(event, baseActions, capabilities);
     if (compacted !== null) return compacted;

src/director.test.ts

@@ -820,5 +820,48 @@ describe("session turn and token caps", () => {
       expect(isHalt(actions)).toBe(false);
     }
   });
+
+  const manageTasksEvent = (status: "todo" | "doing" | "done") =>
+    makeInferenceDoneEvent([
+      { id: "m", name: "manage_tasks", args: { action: "create", tasks: [{ id: "t1", title: "work", status }] } },
+    ]);
+
+  test("the turn cap still halts an interactive session when a task is left open on the capping turn", async () => {
+    const director = createChatDirector(
+      "base", [], undefined, undefined, undefined, undefined, undefined, undefined, undefined,
+      { maxTurns: 2, interactive: true },
+    );
+    // Turn 1: leaves a task open, well under the cap.
+    await director.decide(manageTasksEvent("doing"), stateWithTokens(0), mockCapabilities);
+    // Turn 2: reaches the cap while the task is still open. Without the fix,
+    // the open-task nudge rewrites the halt's wait into a fresh infer(),
+    // swallowing the cap and continuing the loop.
+    const actions = actionsArray(await director.decide(textTurn(), stateWithTokens(0), mockCapabilities));
+    expect(isHalt(actions)).toBe(true);
+    expect(actions.some((a) => a.type === "infer")).toBe(false);
+  });
+
+  test("the turn cap still aborts a headless run when a task is left open on the capping turn", async () => {
+    const director = createChatDirector(
+      "base", [], undefined, undefined, undefined, undefined, undefined, undefined, undefined,
+      { maxTurns: 2, interactive: false },
+    );
+    await director.decide(manageTasksEvent("doing"), stateWithTokens(0), mockCapabilities);
+    const actions = actionsArray(await director.decide(textTurn(), stateWithTokens(0), mockCapabilities));
+    expect(isAbort(actions)).toBe(true);
+    expect(actions.some((a) => a.type === "infer")).toBe(false);
+  });
+
+  test("the open-task nudge still fires normally when no cap is breached", async () => {
+    const director = createChatDirector(
+      "base", [], undefined, undefined, undefined, undefined, undefined, undefined, undefined,
+      { maxTurns: 100, interactive: true },
+    );
+    await director.decide(manageTasksEvent("doing"), stateWithTokens(0), mockCapabilities);
+    const actions = actionsArray(await director.decide(textTurn(), stateWithTokens(0), mockCapabilities));
+    expect(actions.some((a) => a.type === "infer")).toBe(true);
+    expect(isHalt(actions)).toBe(false);
+    expect(isAbort(actions)).toBe(false);
+  });
 });