Traverse sidechain lifecycle collections

Author: SqlRush

docs/cc-100-roadmap.md

@@ -502,6 +502,8 @@ M7 补充：prompt history `LogEntry` 读取现在接受 `sessionID`/`session`/`
 
 本轮补充：sidechain/subagent lifecycle content 读取现在也递归解包 GraphQL/JSON:API 风格的 `edge`/`node`/`attrs` wrapper，wrapped start/summary event 可继续恢复 ID、status、summary 和 agent metadata。
 
+本轮补充：sidechain/subagent lifecycle 字段提取现在也会穿透 `edges`/`nodes`/`included` 等 collection wrapper 和数组元素，GraphQL connection 或 JSON:API included 风格的 start/summary payload 可继续恢复 state/list/resume 所需字段。
+
 本轮补充：sidechain/subagent lifecycle content 的 ID 等 string-like 字段现在接受 JSON number/数字标量，numeric subagent ID 会保留为字符串并能通过 resume fallback 找回对应 sidechain。
 
 本轮补充：sidechain runtime 现在会拒绝同一 sidechain ID 的 running 状态重复 start；已完成后重新 start 会被视为新 lifecycle，state loader 会清空上一轮 summary/endedAt 并使用新的 startedAt。

docs/claude-code-go-rewrite-plan.md

@@ -186,6 +186,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：sidechain/subagent lifecycle content 读取会递归解包 `payload`/`data`/`body`/`result`/`response`/`metadata` 等 wrapper，嵌套的 subagent ID、status/outcome、summary、agent type、workspace path 和 task description 都可参与 state/list/resume 恢复。
 - 本轮补充：sidechain/subagent lifecycle content 读取现在也接受 JSON:API/resource-style 的 `resource`/`attributes`/`properties` wrapper；外层 resource `id` 可作为 sidechain ID fallback，内层 metadata、status/outcome 和 summary 仍会参与 state/list/resume 恢复。
 - 本轮补充：sidechain/subagent lifecycle content 读取现在也递归解包 GraphQL/JSON:API 风格的 `edge`/`node`/`attrs` wrapper，wrapped start/summary event 可继续恢复 ID、status、summary 和 agent metadata。
+- 本轮补充：sidechain/subagent lifecycle 字段提取现在也会穿透 `edges`/`nodes`/`included` 等 collection wrapper 和数组元素，GraphQL connection 或 JSON:API included 风格的 start/summary payload 可继续恢复 state/list/resume 所需字段。
 - 本轮补充：sidechain/subagent lifecycle 的 ID 等 string-like 字段接受 JSON number 和 Go 数字标量，numeric subagent ID 会保留为字符串并可用于 state/list/resume 查找。
 - 本轮补充：sidechain/subagent lifecycle subtype 现在接受 `subagent_started`、`agentStarted`、`task_failed`、`sidechainCompleted` 等相邻事件名，并从 `taskID`/`workerId`/`runId`、`agentName`/`kind`、`resultText`/`finalMessage` 等字段恢复 state/list/resume 信息；`*_failed`/`*_cancelled` subtype 无显式 status 时会归一到 failed/cancelled。
 - 本轮补充：sidechain/subagent lifecycle status 归一化现在接受 compact/camel aliases，包括 `inProgress`、`completedSuccessfully`、`cancelledByUser`/`canceledByUser`、`failedError`/`failedWithError` 和 `timedOut`，并继续写回 canonical running/completed/cancelled/failed 状态。

docs/first-second-parity-audit.md

@@ -184,6 +184,7 @@ M6 progress now includes:
 - `internal/session`: sidechain lifecycle content loading now recurses through wrapper objects such as `payload`, `data`, `result`, `response`, and `metadata`, preserving nested subagent IDs, status, summaries, agent type, worktree path, and task descriptions during state/list/resume recovery.
 - `internal/session`: sidechain lifecycle content loading now also accepts JSON:API/resource-style `resource`/`attributes`/`properties` wrappers, preserving outer resource IDs as sidechain ID fallback while recovering nested metadata, status, and summary fields.
 - `internal/session`: sidechain lifecycle content loading now also recurses through GraphQL/JSON:API `edge`/`node`/`attrs` wrappers, preserving wrapped start and summary event fields during state/list/resume recovery.
+- `internal/session`: sidechain lifecycle field extraction now also traverses collection wrappers such as `edges`, `nodes`, and `included`, plus array elements, so GraphQL connection or JSON:API included start/summary payloads can still recover state/list/resume fields.
 - `internal/session`: sidechain lifecycle scalar fields now accept JSON number values for IDs and other string-like fields, preserving numeric subagent IDs as strings across state/list/resume recovery.
 - `internal/session`: sidechain runtime finish now canonicalizes status aliases such as `success`, `error`, and `canceled` before writing summary records, keeping sidechain and main transcript lifecycle output stable.
 - `internal/session`: sidechain runtime now rejects duplicate starts while the same sidechain ID is running, and state loading treats a later start as a fresh lifecycle by clearing stale summary/end metadata.

internal/session/sidechain_status.go

@@ -361,13 +361,19 @@ func firstStringFieldDepth(value any, keys []string, depth int) string {
 				}
 			}
 		}
-		for _, key := range []string{"payload", "data", "body", "content", "result", "response", "record", "entry", "item", "event", "edge", "node", "resource", "attributes", "properties", "attrs", "metadata", "details", "value", "output"} {
+		for _, key := range []string{"payload", "data", "body", "content", "result", "response", "record", "records", "entry", "entries", "item", "items", "event", "events", "edge", "edges", "node", "nodes", "resource", "resources", "attributes", "properties", "attrs", "metadata", "details", "value", "values", "output", "outputs", "included", "collection", "list", "children"} {
 			if raw, ok := fields[key]; ok {
 				if value := firstStringFieldDepth(raw, keys, depth+1); value != "" {
 					return value
 				}
 			}
 		}
+	case []any:
+		for _, item := range fields {
+			if value := firstStringFieldDepth(item, keys, depth+1); value != "" {
+				return value
+			}
+		}
 	case map[string]string:
 		for _, key := range keys {
 			if raw := fields[key]; raw != "" {

internal/session/sidechain_test.go

@@ -487,6 +487,70 @@ func TestLoadSidechainStateAcceptsGraphQLResourceLifecycleWrappers(t *testing.T)
 	}
 }
 
+func TestLoadSidechainStateAcceptsLifecycleCollectionWrappers(t *testing.T) {
+	sessionPath := filepath.Join(t.TempDir(), "session.jsonl")
+	sessionID := contracts.ID("sess_1")
+	if err := AppendSidechainMessage(sessionPath, sessionID, "collection-resource", TranscriptMessage{
+		Type:      "system",
+		UUID:      "start_1",
+		Timestamp: "2026-01-01T00:00:01Z",
+		Subtype:   "agent_start",
+		Content: map[string]any{
+			"edges": []any{
+				map[string]any{
+					"node": map[string]any{
+						"attrs": map[string]any{
+							"subagentId":      "collection_worker",
+							"agentKind":       "collector",
+							"workspacePath":   "/tmp/collection-worktree",
+							"taskDescription": "collect wrapped lifecycle",
+							"lifecycleState":  "inProgress",
+						},
+					},
+				},
+			},
+		},
+	}); err != nil {
+		t.Fatal(err)
+	}
+	if err := AppendSidechainMessage(sessionPath, sessionID, "collection-resource", TranscriptMessage{
+		Type:      "system",
+		UUID:      "summary_1",
+		Timestamp: "2026-01-01T00:00:02Z",
+		Subtype:   "sidechainCompleted",
+		Content: map[string]any{
+			"included": []any{
+				map[string]any{
+					"resource": map[string]any{
+						"attributes": map[string]any{
+							"agentID":      "collection_worker",
+							"outcome":      "completedSuccessfully",
+							"finalMessage": "collection lifecycle complete",
+						},
+					},
+				},
+			},
+		},
+	}); err != nil {
+		t.Fatal(err)
+	}
+
+	states, err := ListSidechainStates(sessionPath, sessionID)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if len(states) != 1 {
+		t.Fatalf("states = %#v", states)
+	}
+	state := states[0]
+	if state.ID != "collection_worker" || state.Status != SidechainStatusCompleted || state.Summary != "collection lifecycle complete" {
+		t.Fatalf("state = %#v", state)
+	}
+	if state.Metadata.AgentType != "collector" || state.Metadata.WorktreePath != "/tmp/collection-worktree" || state.Metadata.Description != "collect wrapped lifecycle" {
+		t.Fatalf("metadata = %#v", state.Metadata)
+	}
+}
+
 func TestLoadSidechainStateAcceptsNumericLifecycleIDs(t *testing.T) {
 	sessionPath := filepath.Join(t.TempDir(), "session.jsonl")
 	sessionID := contracts.ID("sess_1")