From 129bb1fe74df502bd4e5d07babcd9a58a2b34e74 Mon Sep 17 00:00:00 2001
From: huangruiteng <14976749+huangruiteng@users.noreply.github.com>
Date: Mon, 21 Sep 2026 02:05:26 +0800
Subject: [PATCH 1/2] fix(replan): close lane-owned long-chain obligations from
 projected vision

Signed-off-by: huangruiteng <14976749+huangruiteng@users.noreply.github.com>
---
 .../goals/goal_frontier/__init__.py           |  20 +--
 .../goals/goal_frontier/ack_policy.py         |   3 +-
 .../goals/goal_frontier/long_todo_chain.py    |   1 +
 .../control_plane/todos/frontier_revision.ts  |  35 ++++--
 .../autonomous_replan_obligation.py           |   5 +-
 .../work_items/replan_semantics.ts            |  11 +-
 .../test_canonical_frontier_revision.py       |   3 +-
 .../test_goal_frontier_replan_rules.py        |   2 +
 .../test_long_chain_projected_closeout.py     | 114 ++++++++++++++++++
 .../test_quota_settlement_cli.py              |  97 ---------------
 .../frontier_revision.test.ts                 |  22 +++-
 .../control_plane_ts/replan_semantics.test.ts |  29 +++++
 12 files changed, 210 insertions(+), 132 deletions(-)
 create mode 100644 tests/control_plane/test_long_chain_projected_closeout.py

diff --git a/loopx/control_plane/goals/goal_frontier/__init__.py b/loopx/control_plane/goals/goal_frontier/__init__.py
index 610894e389..7b95fcb645 100644
--- a/loopx/control_plane/goals/goal_frontier/__init__.py
+++ b/loopx/control_plane/goals/goal_frontier/__init__.py
@@ -1216,7 +1216,7 @@ def derive_goal_frontier_replan_obligation_from_summaries(
                     "kind": LONG_TODO_CHAIN_TRIGGER,
                     "section": "agent_todo_summary",
                     "text": (
-                        "current agent lane has a long selectable todo chain; "
+                        "current agent lane has a long claimed todo chain; "
                         "run a vision checkpoint/replan before continuing linearly"
                     ),
                     **long_chain_trigger,
@@ -1229,18 +1229,7 @@ def derive_goal_frontier_replan_obligation_from_summaries(
                 "update_agent_vision",
                 "create_successor",
             ],
-            todo_actions=[
-                {
-                    "action": "add",
-                    "role": "agent",
-                    "priority": "P1",
-                    "text": (
-                        "run a bounded long-chain vision replan: compare evidence "
-                        "with the active vision, group or prune the todo chain, "
-                        "and select the next high-value runnable slice"
-                    ),
-                }
-            ],
+            todo_actions=[],
             stop_condition=(
                 "stop if pruning or external research requires private material, "
                 "credentials, destructive git, production actions, or owner-only decisions"
@@ -1248,7 +1237,10 @@ def derive_goal_frontier_replan_obligation_from_summaries(
             recommended_action=(
                 "run a bounded long-chain vision replan before continuing a 15+ "
                 "todo lane: read evidence, use public research if local evidence "
-                "is weak, group/prune work, and write a concrete todo or vision delta"
+                "is weak, group/prune work, and record an evidence-linked vision "
+                "path through replan_action_packet.writeback_contract using the "
+                "current Turn settlement binding; retain existing runnable work "
+                "when appropriate instead of adding a Todo whose only action is replan"
             ),
             rearmed_after_obligation_id=(
                 long_chain_ack_decision.rearmed_after_obligation_id
diff --git a/loopx/control_plane/goals/goal_frontier/ack_policy.py b/loopx/control_plane/goals/goal_frontier/ack_policy.py
index 19f372d15e..85a96286be 100644
--- a/loopx/control_plane/goals/goal_frontier/ack_policy.py
+++ b/loopx/control_plane/goals/goal_frontier/ack_policy.py
@@ -135,7 +135,8 @@ def replan_successor_transition_ack(
                 eligible_ids.add(binding["todo_id"])
             elif binding["kind"] == "predecessor":
                 prior = ensure_replan_novelty_policy({**(replan_obligation or {}), "triggers": [
-                    {**trigger, "frontier_revision": binding["frontier_revision"]}
+                    {**trigger, "frontier_revision": binding["frontier_revision"],
+                     "obligation_identity_revision": binding["obligation_identity_revision"]}
                     for trigger in (replan_obligation or {}).get("triggers") or []]})
                 if prior["obligation_id"] == origins[binding["todo_id"]]:
                     eligible_ids.add(binding["todo_id"])
diff --git a/loopx/control_plane/goals/goal_frontier/long_todo_chain.py b/loopx/control_plane/goals/goal_frontier/long_todo_chain.py
index 99a2e5ce31..d7dbb3d491 100644
--- a/loopx/control_plane/goals/goal_frontier/long_todo_chain.py
+++ b/loopx/control_plane/goals/goal_frontier/long_todo_chain.py
@@ -24,6 +24,7 @@ class LongTodoChainObservation:
     count_kind: str
     selectable_open_count: int
     selectable_advancement_count: int
+    current_agent_claimed_open_count: int
     current_agent_claimed_advancement_count: int
     unclaimed_advancement_count: int
     threshold: int
diff --git a/loopx/control_plane/todos/frontier_revision.ts b/loopx/control_plane/todos/frontier_revision.ts
index cfc225eda3..d8d7a0f37b 100644
--- a/loopx/control_plane/todos/frontier_revision.ts
+++ b/loopx/control_plane/todos/frontier_revision.ts
@@ -24,8 +24,10 @@ type Row = {
 };
 type LongChainObservation = {
   trigger_count: number;
-  count_kind: "selectable_advancement_todos" | "selectable_open_todos";
+  count_kind: "selectable_advancement_todos" | "selectable_open_todos" |
+    "claimed_advancement_todos" | "claimed_open_todos";
   selectable_open_count: number; selectable_advancement_count: number;
+  current_agent_claimed_open_count: number;
   current_agent_claimed_advancement_count: number; unclaimed_advancement_count: number;
   threshold: 15 | 20; agent_id: string | null;
   frontier_revision: string | null; frontier_revision_complete: boolean;
@@ -33,7 +35,7 @@ type LongChainObservation = {
 };
 type AckDecision = {acknowledged: boolean; rearmed_after_obligation_id: string | null};
 type SuccessorBinding = {kind: "exact"; todo_id: string} |
-  {kind: "predecessor"; todo_id: string; frontier_revision: string};
+  {kind: "predecessor"; todo_id: string; frontier_revision: string; obligation_identity_revision: string};
 type TriggerCheckpoint = {
   kind: string; frontier_revision: string; frontier_owned_identity?: string;
 };
@@ -162,8 +164,10 @@ function successorCheckpoints(request: JsonObject, agent: string | null): JsonOb
   // A new successor changes the revision it was created to settle. Reconstruct
   // only a unique fresh insertion, using a complete source matching the index.
   // The existing obligation-id owner still verifies the predecessor revision.
-  const priorAdvancement = count(trigger.selectable_advancement_count) - 1;
-  const priorOpen = count(trigger.selectable_open_count) - 1;
+  const priorAdvancement = count(agent === null ? trigger.selectable_advancement_count
+    : trigger.current_agent_claimed_advancement_count) - 1;
+  const priorOpen = count(agent === null ? trigger.selectable_open_count
+    : trigger.current_agent_claimed_open_count) - 1;
   if (bindings.length === 0 && candidates.length === 1 && triggers.length === 1 &&
       trigger.kind === TRIGGER && trigger.frontier_revision === source.frontier_revision && (priorAdvancement >= 15 || priorOpen >= 20 && priorAdvancement > 0)) {
     const completeSource = indexed === null ? source : checkpoint(rows, agent);
@@ -171,7 +175,8 @@ function successorCheckpoints(request: JsonObject, agent: string | null): JsonOb
       const candidate = candidates[0];
       const prior = checkpoint(rows === null ? null : rows.filter(row => row.id !== candidate.todo_id), agent);
       if (prior.complete && prior.frontier_revision !== source.frontier_revision) {
-        bindings.push({kind: "predecessor", todo_id: text(candidate.todo_id), frontier_revision: prior.frontier_revision});
+        bindings.push({kind: "predecessor", todo_id: text(candidate.todo_id), frontier_revision: prior.frontier_revision,
+          obligation_identity_revision: prior.frontier_owned_identity ?? prior.frontier_revision});
       }
     }
   }
@@ -229,19 +234,27 @@ export function evaluateLongTodoChain(value: unknown): JsonObject {
   if (request.schema_version !== "long_todo_chain_request_v0") throw new EffectRuntimeRequestError("long chain schema mismatch");
   if (request.operation !== "observe") throw new EffectRuntimeRequestError("unsupported long chain operation");
   const summary = object(request.summary), frontier = object(request.frontier_counts);
+  const agent = agentId(request.agent_id);
   const current = count(frontier.current_agent_claimed_advancement_count);
   const unclaimed = count(frontier.unclaimed_advancement_count);
   const advancement = current + unclaimed;
   const open = Math.max(advancement, request.summary == null ? count(object(request.agent_counts).open) :
     count(summary.current_agent_claimed_open_count) + count(summary.unclaimed_open_count));
-  const threshold = advancement >= 15 ? 15 : open >= 20 && advancement > 0 ? 20 : null;
+  const claimedOpen = Math.max(current, count(summary.current_agent_claimed_open_count));
+  // A lane replans commitments it owns. Shared candidates remain selectable,
+  // but must not impose a chain obligation with no owned ACK fence.
+  const measuredAdvancement = agent === null ? advancement : current;
+  const measuredOpen = agent === null ? open : claimedOpen;
+  const threshold = measuredAdvancement >= 15 ? 15 : measuredOpen >= 20 && measuredAdvancement > 0 ? 20 : null;
   if (threshold === null) return {observation: null, decision: null};
-  const agent = agentId(request.agent_id);
   const revision = readIndex(summary.advancement_frontier_revision_index, agent)
     ?? checkpoint(decodeRows(request.rows), agent);
-  const observation: LongChainObservation = {trigger_count: threshold === 15 ? advancement : open,
-    count_kind: threshold === 15 ? "selectable_advancement_todos" : "selectable_open_todos",
+  const observation: LongChainObservation = {trigger_count: threshold === 15 ? measuredAdvancement : measuredOpen,
+    count_kind: agent === null
+      ? threshold === 15 ? "selectable_advancement_todos" : "selectable_open_todos"
+      : threshold === 15 ? "claimed_advancement_todos" : "claimed_open_todos",
     selectable_open_count: open, selectable_advancement_count: advancement,
+    current_agent_claimed_open_count: claimedOpen,
     current_agent_claimed_advancement_count: current, unclaimed_advancement_count: unclaimed,
     threshold, agent_id: agent, frontier_revision: revision.complete ? revision.frontier_revision : null,
     frontier_revision_complete: revision.complete,
@@ -249,6 +262,8 @@ export function evaluateLongTodoChain(value: unknown): JsonObject {
   const {frontier_revision, frontier_revision_complete, frontier_owned_identity, ...counts} = observation;
   const receipt = triggerCheckpoint({kind: TRIGGER, frontier_revision,
     frontier_revision_complete, frontier_owned_identity});
-  return {observation: {...observation, trigger: {...counts, ...receipt}},
+  return {observation: {...observation, trigger: {...counts, ...receipt,
+    ...(revision.complete ? {obligation_identity_revision:
+      revision.frontier_owned_identity ?? revision.frontier_revision} : {})}},
     decision: classifyAck(observation, request.ack)};
 }
diff --git a/loopx/control_plane/work_items/autonomous_replan_obligation.py b/loopx/control_plane/work_items/autonomous_replan_obligation.py
index 38a30d6754..86a4119df4 100644
--- a/loopx/control_plane/work_items/autonomous_replan_obligation.py
+++ b/loopx/control_plane/work_items/autonomous_replan_obligation.py
@@ -203,7 +203,10 @@ def ensure_replan_novelty_policy(
         normalized.pop("rearmed_after_obligation_id", None)
     trigger_identity = [
         {
-            key: trigger.get(key)
+            key: (
+                trigger.get("obligation_identity_revision", trigger.get(key))
+                if key == "frontier_revision" else trigger.get(key)
+            )
             for key in (
                 "kind",
                 "frontier_identity",
diff --git a/loopx/control_plane/work_items/replan_semantics.ts b/loopx/control_plane/work_items/replan_semantics.ts
index eecced5b93..6155461adf 100644
--- a/loopx/control_plane/work_items/replan_semantics.ts
+++ b/loopx/control_plane/work_items/replan_semantics.ts
@@ -36,8 +36,13 @@ export function requiredSemanticOutcomes(obligation: JsonObject): SemanticOutcom
     return [...new Set(declared)] as SemanticOutcome[];
   }
   const triggers = Array.isArray(obligation.triggers) ? obligation.triggers : [];
-  return [...(triggers.some(trigger => VISION_TRIGGERS.has(String(object(trigger).kind ?? "").trim()))
-    ? VISION_OUTCOMES : PROGRESS_OUTCOMES)];
+  const kinds = triggers.map(trigger => String(object(trigger).kind ?? "").trim());
+  if (kinds.some(kind => VISION_TRIGGERS.has(kind))) return [...VISION_OUTCOMES];
+  // Reviewing a long chain may retain existing runnable work. Its projected
+  // vision decision must close the checkpoint without manufacturing another
+  // successor or progress identifier. Keep previously legal progress exits.
+  return kinds.includes("long_todo_chain")
+    ? ["fresh_vision_path_outcome", ...PROGRESS_OUTCOMES] : [...PROGRESS_OUTCOMES];
 }
 
 function writebackProjection(required: SemanticOutcome[]): JsonObject {
@@ -51,7 +56,7 @@ function writebackProjection(required: SemanticOutcome[]): JsonObject {
         vision_authoring: visionAuthoringContract(),
         required_fields: ["vision_patch.acceptance_summary", "path_delta.outcome", "path_delta.evidence_refs"],
         path_outcomes: [...FRESH_PATH_DISPOSITIONS],
-        rule: "Author the JSON file from observed evidence, then execute the bound refresh and spend. A new progress identifier or unchanged reason alone cannot resolve this vision obligation. Other required_any_of exits remain subject to their typed contracts.",
+        rule: "Author the JSON file from observed evidence, then execute the bound refresh and spend. This path requires an acceptance summary and evidence-linked path outcome; an unchanged reason alone is insufficient. Other required_any_of exits remain subject to their typed contracts.",
       },
     };
   }
diff --git a/tests/control_plane/test_canonical_frontier_revision.py b/tests/control_plane/test_canonical_frontier_revision.py
index 5a60ef2081..e00191768a 100644
--- a/tests/control_plane/test_canonical_frontier_revision.py
+++ b/tests/control_plane/test_canonical_frontier_revision.py
@@ -59,7 +59,8 @@ def test_complex_canonical_frontier_ack_tracks_only_selectable_material_changes(
             "role": "agent", "status": "open", "done": False, "task_class": "advancement_task",
             "text": "Synthetic independent work", "archive_state": "active", "source_section": "Agent Todo",
             "index": len(projection["todos"]) + 1, "updated_at": "2026-09-01T00:00:00.000002Z",
-            **({"claimed_by": "agent-a"} if index == 0 else {}),
+            # Reach the lane-owned threshold; retain a shared tail for ACK parity.
+            **({"claimed_by": "agent-a"} if index < 15 else {}),
             **({"excluded_agents": ["agent-a"]} if index == 29 else {}),
         })
     from loopx.control_plane.coordination.local_authority_shadow_projection import canonical_bytes
diff --git a/tests/control_plane/test_goal_frontier_replan_rules.py b/tests/control_plane/test_goal_frontier_replan_rules.py
index 7bbd6f829a..18b04d3d3f 100644
--- a/tests/control_plane/test_goal_frontier_replan_rules.py
+++ b/tests/control_plane/test_goal_frontier_replan_rules.py
@@ -314,6 +314,8 @@ def derive(rows, ack=None):
         changed[0]["priority"] = "P0"
     else:
         changed[0]["updated_at"] = "2026-08-22T10:00:00+08:00"
+    # The open Turn must keep its binding even before an ACK is recorded.
+    assert (derive(changed)["obligation_id"] != original["obligation_id"]) is rearms
     assert (derive(changed, ack) is not None) is rearms
 
 
diff --git a/tests/control_plane/test_long_chain_projected_closeout.py b/tests/control_plane/test_long_chain_projected_closeout.py
new file mode 100644
index 0000000000..c97ebce7c0
--- /dev/null
+++ b/tests/control_plane/test_long_chain_projected_closeout.py
@@ -0,0 +1,114 @@
+"""Follow the long-chain packet through one real, durable CLI Turn (#4667)."""
+from __future__ import annotations
+
+import json
+from pathlib import Path
+
+from tests.control_plane.test_quota_settlement_cli import (
+    AGENT_ID, GOAL_ID, SELECTED_REPLAN_TODO_ID, TURN_ID,
+    _configure_selected_todo_replan_fixture, _projected_cli_args,
+    _run_cli, _spend_run_count, _write_fixture,
+)
+
+
+def test_projected_vision_replan_settles_without_a_meta_successor(tmp_path: Path) -> None:
+    project, runtime, registry = _write_fixture(tmp_path)
+    _configure_selected_todo_replan_fixture(project, registry)
+    state = project / f".codex/goals/{GOAL_ID}/ACTIVE_GOAL_STATE.md"
+    # Complete material source, independently authored before admission.
+    source = state.read_text().replace(" -->", " updated_at=2026-08-01T00%3A00%3A00Z -->")
+    # Fourteen commitments plus a shared candidate is not this lane's long chain.
+    last_id = "todo_chain_000000000014"
+    source = source.replace(
+        f"todo_id={last_id} status=open task_class=advancement_task action_kind=validate claimed_by={AGENT_ID}",
+        f"todo_id={last_id} status=open task_class=advancement_task action_kind=validate",
+    )
+    state.write_text(source)
+
+    def call(*args):
+        rc, result = _run_cli(registry, runtime, *args, cwd=project)
+        assert rc == 0, result.get("error") or result
+        return result
+
+    def guard(turn):
+        return call("quota", "should-run", "--codex-app", "--goal-id", GOAL_ID,
+                    "--agent-id", AGENT_ID, "--turn-instance-id", turn,
+                    "--scan-path", str(project))
+
+    shared = call("quota", "should-run", "--runtime-profile", "generic_cli",
+                  "--goal-id", GOAL_ID, "--agent-id", AGENT_ID)
+    assert shared["goal_frontier_projection"]["replan_required"] is False
+    call("todo", "claim", "--goal-id", GOAL_ID, "--todo-id", last_id,
+         "--agent-id", AGENT_ID, "--claimed-by", AGENT_ID)
+    before = guard(TURN_ID)
+    original = before["heartbeat_recommendation"]["replan_obligation"]
+    assert [trigger["kind"] for trigger in original["triggers"]] == ["long_todo_chain"]
+    assert original["triggers"][0]["count_kind"] == "claimed_advancement_todos"
+    assert before["selected_todo"]["todo_id"] == SELECTED_REPLAN_TODO_ID
+    actions = before["interaction_contract"]["cli_channel"]["next_cli_actions"]
+    contract = before["interaction_contract"]["cli_channel"]["replan_settlement_contract"]
+    assert contract["settlement_binding"] == {
+        "kind": "todo", "id": SELECTED_REPLAN_TODO_ID, "cli_argument": "--todo-id",
+    }
+    assert contract["semantic_obligation"] == {
+        "kind": "autonomous_replan", "id": original["obligation_id"],
+        "settlement_bound": False, "discharge": "todo_bound_writeback",
+    }
+    refresh, spend = actions
+    assert "--agent-vision-json" in refresh
+    assert "--replan-obligation-id" not in refresh
+    # No invented Todo, progress identifiers, or legacy repair ACK is necessary.
+    assert "--autonomous-replan-recorded" not in refresh
+    # Shared-pool churn after admission must not invalidate this Turn's duty.
+    call("todo", "add", "--goal-id", GOAL_ID, "--role", "agent",
+         "--text", "Validate a separate shared candidate",
+         "--task-class", "advancement_task", "--action-kind", "validate",
+         "--target-key", "shared-candidate")
+    decision = tmp_path / "decision.json"
+    decision.write_text(json.dumps({
+        "schema_version": "goal_vision_replan_contract_v0",
+        "state": "vision_patch_proposed",
+        "vision_patch": {
+            "vision_summary": "Validate the existing bounded slices in dependency order.",
+            "acceptance_summary": "Each slice has independent validation before dependent work proceeds.",
+            "advancement_policy": "as_needed",
+        },
+        "path_delta": {
+            "schema_version": "goal_path_delta_v0", "outcome": "replan",
+            "prior_assumption": "The long chain needed a bounded review.",
+            "observed_reality": "The reviewed chain has a runnable validation slice.",
+            "retained": ["Existing acceptance boundaries"],
+            "changed": ["Proceed with the first validation slice"],
+            "evidence_refs": ["evidence:synthetic-chain-review"],
+        },
+    }))
+    refresh = refresh.replace("<path-to-evidence-linked-goal-vision-replan-contract-v0.json>", str(decision))
+    refreshed = call(*_projected_cli_args(refresh, turn_instance_id=TURN_ID))
+    assert refreshed["vision_checkpoint"]["satisfied"] is True
+    ack = refreshed["autonomous_replan_ack"]
+    assert ack["recorded"] and ack["semantic_delta"]["accepted"]
+    assert ack["semantic_delta"]["satisfying_outcomes"] == ["fresh_vision_path_outcome"]
+    assert ack["semantic_delta"]["trigger_checkpoints"][0]["frontier_revision"]
+    identity = refreshed["settlement_identity"]
+    assert identity["todo_id"] == SELECTED_REPLAN_TODO_ID
+    assert identity["turn_instance_id"] == TURN_ID
+    persisted = json.loads(Path(refreshed["json_path"]).read_text())
+    assert persisted["autonomous_replan_ack"] == ack
+    assert _spend_run_count(runtime) == 0
+    settled = call(*_projected_cli_args(spend, turn_instance_id=TURN_ID))
+    assert settled["settlement_result"]["ok"] is True
+    assert _spend_run_count(runtime) == 1
+    assert state.read_text().count("<!-- loopx:todo ") == 16
+    # Timestamp/evidence bookkeeping is not a new material frontier.
+    call("todo", "update", "--goal-id", GOAL_ID, "--todo-id", SELECTED_REPLAN_TODO_ID,
+         "--agent-id", AGENT_ID, "--evidence", "evidence:synthetic-chain-review")
+    after = guard("turn-after-chain-review")
+    assert after["decision"] == "run"
+    assert after["goal_frontier_projection"]["replan_required"] is False
+    assert _spend_run_count(runtime) == 1
+    call("todo", "update", "--goal-id", GOAL_ID, "--todo-id", SELECTED_REPLAN_TODO_ID,
+         "--agent-id", AGENT_ID, "--text", "Validate a changed acceptance boundary")
+    changed = call("quota", "should-run", "--runtime-profile", "generic_cli",
+                   "--goal-id", GOAL_ID, "--agent-id", AGENT_ID)
+    rearmed = changed["autonomous_replan_obligation"]
+    assert rearmed["rearmed_after_obligation_id"] == ack["semantic_delta"]["obligation_id"]
diff --git a/tests/control_plane/test_quota_settlement_cli.py b/tests/control_plane/test_quota_settlement_cli.py
index c8f9ba7107..d595fedddb 100644
--- a/tests/control_plane/test_quota_settlement_cli.py
+++ b/tests/control_plane/test_quota_settlement_cli.py
@@ -4421,103 +4421,6 @@ def test_unbound_visible_goal_todoless_replan_reenters_through_guided_turn(
         assert f"--turn-instance-id {identity['turn_instance_id']}" in command
 
 
-def test_todo_bound_autonomous_replan_uses_one_binding_for_refresh_and_spend(
-    tmp_path: Path,
-) -> None:
-    project, runtime, registry_path = _write_fixture(tmp_path)
-    _configure_selected_todo_replan_fixture(project, registry_path)
-    turn_instance_id = "turn-todo-bound-replan-settlement-1"
-
-    guard_rc, guard = _run_cli(
-        registry_path,
-        runtime,
-        "quota",
-        "should-run",
-        "--codex-app",
-        "--goal-id",
-        GOAL_ID,
-        "--agent-id",
-        AGENT_ID,
-        "--turn-instance-id",
-        turn_instance_id,
-        "--scan-path",
-        str(project),
-    )
-
-    assert guard_rc == 0, guard
-    assert guard["decision"] == "autonomous_replan_required", guard
-    assert guard["selected_todo"]["todo_id"] == SELECTED_REPLAN_TODO_ID
-    obligation_id = guard["replan_action_packet"]["obligation_id"]
-    assert guard["heartbeat_receipt"]["semantic_replan_obligation_id"] == (
-        obligation_id
-    )
-    cli_channel = guard["interaction_contract"]["cli_channel"]
-    contract = cli_channel["replan_settlement_contract"]
-    assert contract["settlement_binding"] == {
-        "kind": "todo",
-        "id": SELECTED_REPLAN_TODO_ID,
-        "cli_argument": "--todo-id",
-    }
-    assert contract["semantic_obligation"] == {
-        "kind": "autonomous_replan",
-        "id": obligation_id,
-        "settlement_bound": False,
-        "discharge": "todo_bound_writeback",
-    }
-    identity = cli_channel["settlement_plan"]["identity"]
-    assert identity["todo_id"] == SELECTED_REPLAN_TODO_ID
-    assert "replan_obligation_id" not in identity
-    actions = cli_channel["next_cli_actions"]
-    refresh_command = next(action for action in actions if "refresh-state" in action)
-    spend_command = next(action for action in actions if "spend-slot" in action)
-    for command in (refresh_command, spend_command):
-        assert f"--todo-id {SELECTED_REPLAN_TODO_ID}" in command
-        assert "--replan-obligation-id" not in command
-        assert f"--turn-instance-id {turn_instance_id}" in command
-
-    refresh_command = (
-        refresh_command.replace(
-            "<advanced|blocked|exploration_exhausted|no_followup>",
-            "advanced",
-        )
-        .replace("<surface-id>", "surface-new")
-        .replace("<hypothesis-id>", "hypothesis-new")
-        .replace("<probe-kind>", "probe-new")
-        .replace("<evidence-id>", "evidence-new")
-    )
-    refresh_rc, refresh = _run_cli(
-        registry_path,
-        runtime,
-        *_projected_cli_args(
-            refresh_command,
-            turn_instance_id=turn_instance_id,
-        ),
-    )
-
-    assert refresh_rc == 0, refresh.get("error") or refresh
-    assert refresh["settlement_result"]["ok"] is True
-    assert refresh["autonomous_replan_ack"]["semantic_delta"]["accepted"] is True
-
-    spend_args = _projected_cli_args(
-        spend_command,
-        turn_instance_id=turn_instance_id,
-    )
-    spend_rc, spend = _run_cli(
-        registry_path,
-        runtime,
-        *spend_args,
-        "--scan-path",
-        str(project),
-    )
-
-    assert spend_rc == 0, spend
-    assert spend["settlement_result"]["ok"] is True
-    assert [
-        receipt["step_kind"] for receipt in spend["settlement_result"]["receipts"]
-    ] == ["validation", "durable_writeback", "quota_spend"]
-    assert _spend_run_count(runtime) == 1
-
-
 def test_autonomous_replan_semantic_delta_keeps_accountable_receipt_chain(
     tmp_path: Path,
 ) -> None:
diff --git a/tests/control_plane_ts/frontier_revision.test.ts b/tests/control_plane_ts/frontier_revision.test.ts
index f8337c2001..5bd61be309 100644
--- a/tests/control_plane_ts/frontier_revision.test.ts
+++ b/tests/control_plane_ts/frontier_revision.test.ts
@@ -67,12 +67,22 @@ test("duplicate identities and malformed or absent revision facts cannot authori
   assert.deepEqual(result.decision, {acknowledged: false, rearmed_after_obligation_id: null});
 });
 
-test("long-chain thresholds remain 15 advancement or 20 selectable with advancement", () => {
+test("lane thresholds count 15 claimed advancement or 20 claimed open with advancement", () => {
   assert.notEqual(observe().observation, null);
   assert.equal(observe({frontier_counts: {current_agent_claimed_advancement_count: 14}}).observation, null);
   const open = {current_agent_claimed_open_count: 20, unclaimed_open_count: 0};
-  assert.notEqual(observe({summary: open, frontier_counts: {unclaimed_advancement_count: 1}}).observation, null);
+  const result = observe({summary: open, frontier_counts: {current_agent_claimed_advancement_count: 1}});
+  assert.equal((result.observation as Record<string, unknown>).count_kind, "claimed_open_todos");
+  assert.equal((result.observation as Record<string, unknown>).trigger_count, 20);
   assert.equal(observe({summary: open, frontier_counts: {}}).observation, null);
+  assert.equal(observe({summary: open, frontier_counts: {unclaimed_advancement_count: 100}}).observation, null);
+  for (const current of [0, 14]) {
+    assert.equal(observe({summary: {current_agent_claimed_open_count: current, unclaimed_open_count: 100},
+      frontier_counts: {current_agent_claimed_advancement_count: current, unclaimed_advancement_count: 100}}).observation, null);
+  }
+  // Unscoped overview keeps the existing selectable-chain contract.
+  assert.notEqual(observe({agent_id: null, summary: open,
+    frontier_counts: {unclaimed_advancement_count: 1}}).observation, null);
 });
 
 test("only exact accepted checkpoint suppresses a repeated trigger; material change rearms", () => {
@@ -200,12 +210,14 @@ test("successor reconstruction requires a complete matching source and an alread
   const request = {schema_version: "todo_frontier_revision_request_v0", operation: "successor_checkpoints",
     agent_id: "worker-a", rows, obligation_id: "replan-current",
     candidates: [{todo_id: "todo_15", updated_at: rows[15].updated, origin_obligation_id: "replan-prior"}],
-    triggers: [{kind: "long_todo_chain", ...current, selectable_advancement_count: 16, selectable_open_count: 16}]};
+    triggers: [{kind: "long_todo_chain", ...current,
+      current_agent_claimed_advancement_count: 16, current_agent_claimed_open_count: 16}]};
   const result = projectAdvancementFrontier(request).source_checkpoint as Record<string, unknown>;
   assert.deepEqual(result.bindings, [{kind: "predecessor", todo_id: "todo_15",
-    frontier_revision: project(rows.slice(0, 15), "worker-a").frontier_revision}]);
+    frontier_revision: project(rows.slice(0, 15), "worker-a").frontier_revision,
+    obligation_identity_revision: project(rows.slice(0, 15), "worker-a").frontier_owned_identity}]);
   for (const triggers of [
-    [{...request.triggers[0], selectable_advancement_count: 15, selectable_open_count: 15}],
+    [{...request.triggers[0], current_agent_claimed_advancement_count: 15, current_agent_claimed_open_count: 15}],
     [{...request.triggers[0], frontier_revision: "different-current-source"}],
     [...request.triggers, {kind: "periodic_review"}],
   ]) {
diff --git a/tests/control_plane_ts/replan_semantics.test.ts b/tests/control_plane_ts/replan_semantics.test.ts
index a380a10ec5..cef66cee6c 100644
--- a/tests/control_plane_ts/replan_semantics.test.ts
+++ b/tests/control_plane_ts/replan_semantics.test.ts
@@ -28,6 +28,35 @@ test("missing evidence or acceptance cannot manufacture a fresh path outcome", (
   }
 });
 
+test("long-chain review accepts its evidence-linked vision route and retains progress exits", () => {
+  const chain = {triggers: [{kind: "long_todo_chain"}]};
+  const projection = projectReplanSemantics({operation: "requirements", obligation: chain});
+  assert.match(String(projection.cli_semantic_args), /--agent-vision-json/);
+  assert.equal(projectReplanSemantics({operation: "qualify", obligation: chain,
+    agent_vision: vision}).accepted, true);
+  for (const outcome of ["new_surface", "new_hypothesis", "new_probe_family", "new_runnable_successor"]) {
+    assert.equal(projectReplanSemantics({operation: "qualify", obligation: chain,
+      observation_delta: {delta_kinds: [outcome]}}).accepted, true);
+  }
+  for (const incomplete of [{vision_patch: vision.vision_patch},
+    {...vision, path_delta: {outcome: "replan", evidence_refs: []}},
+    {...vision, vision_patch: {}}, {...vision, path_delta: {outcome: "wait", evidence_refs: ["evidence"]}}]) {
+    assert.equal(projectReplanSemantics({operation: "qualify", obligation: chain,
+      agent_vision: incomplete}).accepted, false);
+  }
+  // A stricter source, mixed vision duty or unrelated trigger keeps its policy.
+  for (const restricted of [
+    {...chain, satisfying_semantic_outcomes: ["new_runnable_successor"]},
+    {triggers: [{kind: "typed_progress_repeat", text: "long_todo_chain"}]},
+  ]) {
+    assert.equal(projectReplanSemantics({operation: "qualify", obligation: restricted,
+      agent_vision: vision}).accepted, false);
+  }
+  assert.equal(projectReplanSemantics({operation: "qualify",
+    obligation: {triggers: [...chain.triggers, ...obligation.triggers]},
+    observation_delta: {delta_kinds: ["new_surface"]}}).accepted, false);
+});
+
 test("explicit outcome restriction remains authoritative; trigger prose is not", () => {
   assert.deepEqual(requiredSemanticOutcomes({satisfying_semantic_outcomes: ["new_runnable_successor", "new_runnable_successor"]}), ["new_runnable_successor"]);
   assert.throws(() => requiredSemanticOutcomes({satisfying_semantic_outcomes: ["unrecognized"]}), /unknown typed outcome/);

From d86bbb1575e148a727c0a032b2db03c9bf2b4ea7 Mon Sep 17 00:00:00 2001
From: huangruiteng <14976749+huangruiteng@users.noreply.github.com>
Date: Mon, 21 Sep 2026 02:05:46 +0800
Subject: [PATCH 2/2] docs(replan): record claimed-chain scope and typed
 closeout contract

Signed-off-by: huangruiteng <14976749+huangruiteng@users.noreply.github.com>
---
 .../typescript-control-plane-migration-v0.md  | 21 ++++++++++---
 ...script-control-plane-migration-v0.zh-CN.md | 16 +++++++---
 .../topic-long-horizon-convergence.md         |  2 +-
 .../core-control-plane/state-machine.md       |  8 +++--
 .../goal-vision-replan-contract-v0.md         | 31 +++++++++++++++++--
 .../references/repair-patterns.md             |  2 +-
 6 files changed, 65 insertions(+), 15 deletions(-)

diff --git a/docs/architecture/rfcs/typescript-control-plane-migration-v0.md b/docs/architecture/rfcs/typescript-control-plane-migration-v0.md
index 8109e2e67a..29ce277639 100644
--- a/docs/architecture/rfcs/typescript-control-plane-migration-v0.md
+++ b/docs/architecture/rfcs/typescript-control-plane-migration-v0.md
@@ -959,16 +959,27 @@ lineage. Ambiguous, stale, truncated or unrelated material changes cannot close
 the current obligation. This closes one T3 rule group, not
 the remaining consumers or T1/T2/D1–D3.
 
-Thresholds remain 15 advancement Todos or 20 selectable open Todos with
-advancement work. Full material revisions include terminal advancement rows;
+Long-chain scope correction (#4667): Agent lanes count 15 claimed advancement
+Todos or 20 claimed open Todos with claimed advancement work. Shared candidates
+remain selectable but no longer impose this duty; unscoped Goal observations
+retain the selectable-pool thresholds. Full material revisions include terminal advancement rows;
 timestamp-only maintenance does not rearm them. A complete agent-owned identity
 also keeps an accepted long-chain ACK valid when peers change shared unclaimed
-work. Owned material edits still rearm; an entirely unclaimed chain cannot use
-that exemption. Historical revision-only ACKs keep exact-revision matching.
+work. Owned material edits still rearm; an entirely unclaimed lane has no
+long-chain duty. Historical revision-only ACKs keep exact-revision matching.
 Intentional corrections: semantic writeback now preserves the owned identity;
 an identity without a revision or an explicitly incomplete checkpoint cannot
 suppress replanning. Other trigger kinds cannot borrow long-chain identity
-matching. No threshold, write authority or obligation-id rule changes.
+matching. The same TS owner now supplies `obligation_identity_revision` from the
+owned basis for the existing Python identity codec and predecessor proof: peer
+churn cannot invalidate an open Turn before its ACK. Numeric thresholds and
+write authority remain unchanged. `replan_semantics.ts` accepts and projects an
+evidence-linked vision path for long-chain review, preserving existing progress
+exits and stricter vision obligations. The real CLI regression follows the
+projected binding through durable ACK, satisfied checkpoint, one spend and next
+Turn readback; maintenance stays quiet and an owned material edit rearms.
+This advances overall-roadmap S2/S3's existing T3 owner, with no new provider,
+store migration, frontend setting or claim of broader RFC acceptance.
 
 The canonical index is built before display truncation. Exclusions, duplicate
 ids/index lanes, incomplete timestamps and authoritative incomplete indexes
diff --git a/docs/architecture/rfcs/typescript-control-plane-migration-v0.zh-CN.md b/docs/architecture/rfcs/typescript-control-plane-migration-v0.zh-CN.md
index dd7e7d7954..30c7035a1b 100644
--- a/docs/architecture/rfcs/typescript-control-plane-migration-v0.zh-CN.md
+++ b/docs/architecture/rfcs/typescript-control-plane-migration-v0.zh-CN.md
@@ -728,14 +728,22 @@ Python 验证前置 obligation id。压缩保留实质字段 `done`，历史保
 多后继歧义、过期、来源截断或无关实质变化都不能关闭当前 obligation。
 这闭合一个 T3 规则组，不代表其余 consumer 或 T1/T2/D1–D3 完成。
 
-阈值仍是 15 项 advancement，或存在 advancement 时的 20 项可选 open Todo。
+长链口径修正（#4667）：Agent lane 统计 15 项已认领 advancement，或存在已认领
+advancement 时的 20 项已认领 open Todo。共享候选仍可选，但不再计入本 lane 的
+义务；无 Agent 的 Goal 总览保留原可选池口径。
 完整实质 revision 包含终态 advancement；仅更新时间不重新触发。完整的 Agent-owned
 identity 还能在同伴改变共享 unclaimed 工作时保持既有 long-chain ACK 有效。
-自己的实质工作变化仍重新触发；全是未认领工作的链不能使用 owned 豁免。
+自己的实质工作变化仍重新触发；没有认领工作的 lane 不产生长链义务。
 历史 revision-only ACK 仍按精确 revision 匹配。明确修正：语义写回不再丢失
 owned identity；只有 identity 而没有 revision、或明确不完整的 checkpoint 不能
-压制 replan；其他 trigger kind 不能借用长链身份匹配。阈值、写权限和 obligation-id
-规则均未改变。
+压制 replan；其他 trigger kind 不能借用长链身份匹配。同一 TS owner 现在提供
+基于 owned 实质内容的 `obligation_identity_revision`，供既有 Python 身份 codec
+及 predecessor 校验使用；同伴修改共享池不能在 ACK 前让本 Turn 的义务换 ID。
+阈值数值和写权限不变。`replan_semantics.ts` 为长链 review 接受并投影带证据的
+vision path，保留既有 progress 出口和严格 vision 义务。真实 CLI 回归沿投影绑定
+验证持久 ACK、checkpoint、一次 spend 和下一 Turn 回读；维护不触发，自己任务的
+实质修改重新触发。本次推进总路线 S2/S3 已有 T3 owner，不新增 provider、迁移存储
+或前端设置，也不宣称整个 RFC 验收完成。
 
 Canonical index 仍在展示截断前生成。Exclusion、重复 ID/index lane、不完整时间与
 权威 index 不完整时均保持 fail-closed。真实 CLI 验证两条 ACK 路径经过运行记录及
diff --git a/docs/development/control-plane-course/topic-long-horizon-convergence.md b/docs/development/control-plane-course/topic-long-horizon-convergence.md
index 999ec86a3c..4fdf0e1b54 100644
--- a/docs/development/control-plane-course/topic-long-horizon-convergence.md
+++ b/docs/development/control-plane-course/topic-long-horizon-convergence.md
@@ -952,7 +952,7 @@ def select_frontier_rule(facts):
 | 4 | `open_user_todo` | 存在真正阻塞当前路径的用户工作；系统应等待具体输入，不能把缺少 authority 误写成 Replan。 | 否 |
 | 5 | `todo_succession_gap` | Advancement 已完成，但没有 successor 或 `no_followup` 理由，且没有其他 advancement 接续；必须补上局部闭包。 | 是 |
 | 6 | `vision_acceptance_gap` | Acceptance 仍有缺口，但没有满足它的 selectable work，或 successor 需要 Vision 决策；必须重建方向与 Frontier。 | 是 |
-| 7 | `long_todo_chain` | 可选 Todo 链超过有界阈值；先做 Vision checkpoint、分组或裁剪，不能用无绑定 ACK 跳过。当前 obligation 只能由匹配其 id 的 semantic delta 闭合。 | 是 |
+| 7 | `long_todo_chain` | 当前 Agent 已认领的 Todo 链达到有界阈值；共享未认领候选不计入。先做 Vision checkpoint、分组或裁剪，不能用无绑定 ACK 跳过。当前 obligation 只能由匹配其 id 的 semantic delta 闭合。 | 是 |
 | 8 | `current_agent_blocker` | 当前 Agent 已有具体 blocker 解释为什么不能推进；下一步由 blocker 的 resume route 决定，而不是再造计划。 | 否 |
 | 9 | `monitor_no_change_streak` | Monitor-only lane 连续 unchanged 达到阈值；必须用 expiry、blocker、supersede 或 successor 结束热等待。 | 是 |
 | 10 | `not_monitor_only` | 当前 lane 并非纯 monitor 等待；monitor exhaustion 规则不适用，交还普通 advancement 路径处理。 | 否 |
diff --git a/docs/product/core-control-plane/state-machine.md b/docs/product/core-control-plane/state-machine.md
index 89bafc6a25..0a21e82184 100644
--- a/docs/product/core-control-plane/state-machine.md
+++ b/docs/product/core-control-plane/state-machine.md
@@ -474,12 +474,16 @@ The same ordering applies when an agent records a bounded
 as a goal-frontier `acceptance_gaps[]` entry. If no advancement frontier remains,
 the gap becomes a replan trigger before the lane can quietly back off.
 
-Long runnable lanes also pass through this machine. When the current agent can
-select about 15 advancement todos, or about 20 open todos with advancement work
+Long runnable lanes also pass through this machine. When the current agent owns
+15 open advancement todos, or 20 claimed open todos with claimed advancement work
 still present, quota should trigger a bounded vision replan before continuing
 linearly. The replan reads the agent-scoped evidence log, uses bounded public
 research when local evidence is insufficient for a public claim, then groups,
 prunes, or reprioritizes the chain into the next high-value runnable slice.
+Shared unclaimed candidates remain selectable but do not count toward this lane
+threshold. A valid evidence-linked vision path can retain existing runnable work
+and settle the projected Turn without adding another planning Todo. Shared-pool
+churn preserves its obligation identity; owned material changes rearm it.
 
 The same ordering also applies to `vision_checkpoint_v0`: if a role records
 material progress but omits both a vision patch and an unchanged/no-follow-up
diff --git a/docs/reference/protocols/goal-vision-replan-contract-v0.md b/docs/reference/protocols/goal-vision-replan-contract-v0.md
index 619d242782..5baeb1d85a 100644
--- a/docs/reference/protocols/goal-vision-replan-contract-v0.md
+++ b/docs/reference/protocols/goal-vision-replan-contract-v0.md
@@ -115,6 +115,17 @@ stays on the original Turn, and in-flight continuation remains unchanged.
 JSON 写作契约复用 vision 校验器，不新增 ACK 仪式，也不改变既有 successor、blocker、
 terminal 出口。语义接受、checkpoint 满足、Turn 结算与 Goal 完成仍须分别验证。
 
+Long-chain review also accepts `fresh_vision_path_outcome` and now projects this
+JSON route. An acceptance summary plus an evidence-linked `continue`, `no_change`
+or `replan` path can retain existing runnable work; no extra planning Todo or
+legacy repair ACK is required. Existing typed progress, successor and terminal
+exits remain available. Vision-only obligations still reject ordinary progress
+identifiers. Use the projected Todo **or** obligation binding, never both.
+
+长链 review 同样接受带验收摘要和证据的 vision path，并默认投影 JSON 写回路径；
+可以保留已有可执行工作，无需新增“再次重规划”的 Todo。既有 typed progress、
+successor 和 terminal 出口保留；严格 vision 义务仍不接受普通进度标识。
+
 Inline vision writes require `--agent-id`. JSON packets must also resolve to
 the same `agent_id` as the refresh run. This keeps `research-executor`,
 `evaluator-promoter`, and other roles from overwriting or satisfying each
@@ -501,8 +512,8 @@ or agent-scope wait decisions:
 - normalized progress shows no remaining advancement frontier;
 - monitor-only lanes have no material transition and acceptance remains open;
 - a cleared handoff has no successor or no-follow-up rationale;
-- the current agent lane has a long selectable todo chain, such as 15 or more
-  advancement todos or roughly 20 open todos with advancement work still present;
+- the current agent lane owns at least 15 open advancement Todos, or 20 claimed
+  open Todos with claimed advancement work still present;
 - a periodic autonomous replan obligation is due;
 - the user objective or acceptance contract changed;
 - an approved dreaming proposal requires a delivery route.
@@ -511,6 +522,22 @@ The replan decision must not be disturbed by monitor quiet skip, scoped gate
 waiting, or a single agent having no runnable todo. Those may explain local
 lane state, but they cannot erase a required goal-level replan.
 
+Long-chain scope correction (#4667): Agent-scoped counts now exclude shared
+unclaimed candidates. They remain selectable, but do not create a replan duty
+for a lane that has not claimed them. Unscoped Goal observations retain the
+selectable-pool thresholds. Numeric thresholds and other replan sources are
+unchanged. The typed frontier owner supplies `obligation_identity_revision`
+from the owned material identity, keeping an open obligation stable across
+peer/shared-pool churn; `frontier_revision` retains the full selectable-source
+checkpoint for diagnostics and historical ACK matching. Owned material changes
+still rearm. Timestamp/evidence bookkeeping does not. Existing accepted ACKs
+remain readable; an outstanding pre-upgrade Turn should refresh its guard.
+
+长链触发范围修正：Agent lane 只统计自己已认领的任务；共享未认领任务仍可选取，
+但不计入本 lane 的长链阈值。无 Agent 的 Goal 总览保留原可选池口径。
+义务身份使用 typed owner 给出的 owned 实质 revision，同伴修改共享池不会让正在
+处理的义务换 ID；自己任务的实质修改仍重新触发。证据补充或更新时间不重新触发。
+
 ## Replan Output
 
 A valid replan writes at least one bounded delta:
diff --git a/skills/loopx-self-repair/references/repair-patterns.md b/skills/loopx-self-repair/references/repair-patterns.md
index 9557bba0be..79e68f5785 100644
--- a/skills/loopx-self-repair/references/repair-patterns.md
+++ b/skills/loopx-self-repair/references/repair-patterns.md
@@ -198,7 +198,7 @@ teaches a reusable control-plane lesson.
 | `dashboard_status_source_generation_gap` | Switching between local and SSH sources leaves the old Goal list visible, or the selector and route oscillate between two sources after a slow tunnel ensure or status response. | User selection order, tunnel-ensure start/finish order, status fetch start/finish order, requested and loaded URLs, projection revision, route commits, and the rendered Goal identity. | Request freshness starts only after SSH preparation, a foreground request captures its revision before advancing it, or an older route commit clears a newer pending selection. | Fence the complete selection transaction—from user intent through tunnel ensure, fetch, payload commit, and route commit—with one monotonic selection generation plus a projection revision. Let only the current generation clear pending state; reject background responses whose target is no longer the committed source. Cover delayed A/B fetches and delayed SSH-then-local selection with a focused browser smoke that asserts payload, selector, and route remain aligned. |
 | `docs_surface_sprawl` | Root docs become hard for contributors to navigate; research/drafts/history compete with stable contracts. | `docs/README.md`, root docs count, docs governance smoke. | Documentation lacks audience and lifecycle ownership. | Move archive/outreach/research/reference material into indexed subdirs and keep new docs linked from an index. |
 | `external_wait_typed_repeat_obligation_gap` | An agent waits on an external gate (for example a PR review) and records the same typed `blocked` observation twice; `quota should-run` then stays `autonomous_replan_required` with a `typed_progress_repeat` trigger even after the blocker is reported, and the pi/generic_cli host loop thrashes on `repair_interaction_contract_projection` because the interaction contract becomes `delivery_allowed=true, must_attempt=false`. | quota `autonomous_replan_decision` + `autonomous_replan_obligation` (trigger kind, progress_baseline fingerprint), `interaction_contract.agent_channel`, `scheduler_hint.consistency_error`, run-history `progress_observation` fingerprints, heartbeat `recommended_mode`. | Repeated identical typed observations on an external wait are a stall signal that creates the replan obligation; `enforce_open_replan_writeback` only accepts a new typed semantic delta (or fresh evidence-linked vision path) in the same writeback, so a repair-delta/blocker-todo claim alone, or a repeated baseline observation, is rejected and cannot clear the obligation. | For external waits use `quota monitor-poll` (no-spend quiet evidence) or record a typed observation at most once per distinct state; never repeat the same fingerprint. When a repeat obligation is already open, close it in ONE atomic refresh: `loopx refresh-state --autonomous-replan-recorded --repair-delta-kind <accountable kind> --progress-result-class blocked --progress-blocker-id <new id, different from the obligation baseline> --progress-evidence-id <new evidence>` (keeping the matching scoped blocker todo open), so the same writeback carries both the accepted typed delta and the repair evidence; do not split the delta and a later fingerprint change across refreshes, because the later refresh still sees the open obligation and is rejected. |
-| `long_todo_chain_level_trigger_gap` | A lane remains at or above the long-chain threshold, an accepted replan writeback is durable, yet every heartbeat recreates the same replan obligation until Todos are manually pruned below the threshold. | Agent-scoped source Todo ids/status/owners/update revisions, derived trigger checkpoint, obligation id, accepted semantic ACK, and the next quota decision. | Threshold state was evaluated as a level on every read. The obligation identity omitted the Todo frontier revision, and the ACK did not retain an exact trigger checkpoint, so closed and materially changed frontiers were indistinguishable. | Derive a typed agent-scoped Todo-frontier revision, include it in obligation identity, and copy the exact trigger checkpoint into accepted ACKs and durable compaction. Suppress the long-chain rule while that checkpoint matches; rotate and re-arm only after a material Todo revision. Fail closed when source revisions are incomplete, and fence transition-derived successor ACKs against the current frontier update time. |
+| `long_todo_chain_level_trigger_gap` | Repeated wakes recreate a long-chain obligation after a valid review, or peer/shared-pool churn invalidates the open Turn before its ACK. | Claimed versus shared counts, full and owned frontier identities, admitted obligation id, projected writeback, durable ACK/checkpoint and next Turn. | A lane duty counted shared candidates, its identity used the shared revision, or its vision instruction was absent from accepted semantic outcomes. | Count Agent-owned commitments; keep shared candidates selectable. Have the typed frontier owner supply the owned obligation identity to both the identity codec and successor predecessor proof. Project and accept an evidence-linked vision path without inventing a planning Todo; retain strict vision, progress and terminal rules. Verify one projected Turn, one spend, peer churn before/after ACK, maintenance stability and owned material rearm through the real CLI. Preserve exact historical checkpoint matching and fail-closed incomplete sources. |
 | `lark_configured_chat_topic_filter_gap` | A `configured_chat_all` connection can read a message through provider history, but a real-time message from a new topic or topic reply in the same configured chat is absent from the Goal inbox and diagnostics report `topic_mismatch`. | Consuming bot target, configured chat id, incoming chat/root ids, capture scope, route decision reason, and persisted inbox message ids. | The router applied one presentation topic root as an ingress filter before evaluating chat-wide capture scope; profile polling could also route against bindings owned by another bot target in the same chat. | Scope polling to the consuming target first. Prefer an exact topic match; otherwise allow one unambiguous chat-wide route for any root in the configured chat, and fail closed when multiple chat-wide routes remain. Treat the topic root as reply/presentation context rather than an ingress boundary under chat-wide capture, and cover new topics plus multiple bots with focused tests. |
 | `lark_inbox_reply_placement_gap` | A top-level chat request is answered with an unnecessary new topic, or structured reply text loses line breaks. | Source `parent_id`/`root_id`, configured placement policy, provider send command, and readback text. | The reply path always forced thread mode and flattened all whitespace before sending. | Resolve placement from the captured source context, retain a compatibility policy for existing configs, preserve line breaks for structured replies, and verify both top-level and in-topic sends with provider readback. |
 | `lark_configured_chat_addressing_projection_gap` | `configured_chat_all` reports `reply_due` for a message addressed to another member, Bot-authored prose, or a historical invitation merely because the body also contains the product name; genuine structured Bot mentions may meanwhile lose their addressing evidence after persistence. | Provider-native `mentions`/`mentioned` fields, sender/reply verification summary, canonical event `addressed_to_bot`, content-free urgency counts, and source message settlement. | Provider mention evidence was discarded at the compact inbox boundary, then urgency reconstructed intent from a broad text heuristic such as any `@` plus a product-name token. | Normalize provider-native addressing once into a compact typed flag, persist that flag without raw identities, and make configured-chat urgency accept only the flag or a verified Bot reply. Preserve structured negative mention evidence during normalization, require message-context lookup when the event stream lacks it, and make legacy events without the flag fail closed to material review. Cover another-member mentions, Bot-name prose/self messages, verified direct mentions, and legacy events with public-safe fixtures. |