fix(status): preserve delegated identities and large snapshots

Signed-off-by: huangruiteng <huangrt01@163.com>

Author: huangruiteng

loopx/control_plane/effect_runtime_snapshot_methods.json

@@ -12,6 +12,7 @@
   "work_item.interaction_reads.project",
   "scheduler.hint.project",
   "work_item.task_graph.goal_topology",
+  "work_item.task_graph.status",
   "work_item.replan_semantics.project",
   "quota.settlement.read",
   "quota.spend.commit",

loopx/control_plane/work_items/task_graph.ts

@@ -434,6 +434,7 @@ function publicTextCodec(request: JsonObject): {
 } {
   const texts = requireJsonObject(request.public_texts, "public text codecs");
   const composedTexts = new Set<string>();
+  const foldedTexts = new Set<string>();
   const composed = (value: string, parts: unknown[] = []): string => {
     for (const part of parts) {
       const text = String(part);
@@ -448,6 +449,10 @@ function publicTextCodec(request: JsonObject): {
       if (typeof text === "string") composed(text);
     }
   }
+  for (const source of Object.keys(texts)) {
+    const folded = source.toLowerCase();
+    if (folded !== source) foldedTexts.add(folded);
+  }
   const safe: PublicText = (value, limit) => {
     if (!truthy(value)) return null;
     const text = String(value);
@@ -460,6 +465,13 @@ function publicTextCodec(request: JsonObject): {
       if (result) composed(result);
       return result as string | null;
     }
+    // Agent identities are normalized case-insensitively by the existing
+    // handoff owner. The lower-case form is still derived from an approved
+    // source fact; accept it only without inventing or recompacting text.
+    if (foldedTexts.has(text) && Array.from(text).length <= limit) {
+      composed(text);
+      return text;
+    }
     if (!composedTexts.has(text)) {
       throw new EffectRuntimeRequestError(`Missing public text facts for display cap ${limit}`);
     }

tests/control_plane/test_status_task_graph_characterization.py

@@ -147,3 +147,22 @@ def test_empty_display_text_does_not_steal_selection(monkeypatch):
     output = status.build_task_graph_projection({"goal_id": "graph-fixture", "agent_todos": {
         "items": [todo("todo_empty", text="  "), todo("todo_visible")]}}, goal={"id": "graph-fixture"})
     assert output["nodes"][0]["refs"] == {"todo_ids": ["todo_visible"]}
+
+
+def test_large_status_note_uses_the_existing_snapshot_transport(monkeypatch):
+    arguments = deepcopy(cases()["handoff_evidence"])
+    parent = arguments["item"]["agent_todos"]["items"][1]
+    parent.pop("evidence", None)
+    parent["note"] = "Public note " + "x" * 4_300_016
+    calls = []
+    real = task_graph.effect_runtime_result
+
+    def observe(method, params, **kwargs):
+        calls.append((method, kwargs.get("large_local_snapshot", False)))
+        return real(method, params, **kwargs)
+
+    monkeypatch.setattr(task_graph, "effect_runtime_result", observe)
+    monkeypatch.setattr(task_graph, "now_utc_iso", lambda: NOW)
+    output = status.build_task_graph_projection(**arguments)
+    assert output["nodes"]
+    assert calls == [("work_item.task_graph.status", True)]

tests/control_plane_ts/task_graph.test.ts

@@ -463,3 +463,25 @@ test("status compaction fallback enumerates composed titles, identities, referen
     assert.match(String(edge.edge_id), /^edge_[a-z0-9_]+$/);
   }
 });
+
+test("status accepts lower-case agent identities derived from approved source facts", () => {
+  const values = {
+    "synthetic-goal": {"120": "synthetic-goal", "80": "synthetic-goal"},
+    "todo_root": {"120": "todo_root"}, "Review todo_root": {"160": "Review todo_root"},
+    "open": {"80": "open"}, "todo_done:todo_parent": {"240": "todo_done:todo_parent"},
+    "todo_parent": {"120": "todo_parent"}, "Review todo_parent": {"160": "Review todo_parent"},
+    "done": {"80": "done"}, "Builder": {"80": "Builder"}, "Reviewer": {"80": "Reviewer"},
+  };
+  const result = projectStatusTaskGraph({
+    schema_version: STATUS_TASK_GRAPH_REQUEST, goal_id: "synthetic-goal",
+    summaries: {agent: {items: [
+      statusTodo("todo_root", {resume_when: "todo_done:todo_parent"}),
+      statusTodo("todo_parent", {status: "done", done: true, successor_todo_ids: ["todo_root"],
+        handoff_note: {from_agent: "builder", to_agent: "reviewer", status: "done"}}),
+    ]}, user: {}},
+    max_status_todos_per_role: 8, latest_runs: [], public_texts: values,
+    fallback_time: "2026-11-02T12:00:00Z",
+  });
+  assert.equal(statusNodes(result).find(node => node.kind === "handoff")?.title,
+    "Handoff from builder to reviewer");
+});