Accept content replacement metadata aliases

Author: SqlRush

docs/cc-100-roadmap.md

@@ -54,6 +54,8 @@ M6 补充：summary/custom-title/ai-title/last-prompt metadata 现在接受 `con
 
 M6 补充：tag、agent-name、agent-color、agent-setting 和 mode metadata 现在接受 `label`/`name`/`color`/`setting`/`status` 等值字段别名，full loader、metadata loader 和 transcript index 的 agent/session 状态恢复保持一致。
 
+M6 补充：content-replacement metadata 现在接受 `records`/`contentReplacements` 等 record wrapper，以及 record 内 `type`/`content`/`hash` 等字段别名，full loader、metadata loader 和 transcript index 的 replacement 恢复保持一致。
+
 M6 补充：remote history GraphQL/connection 分页现在接受 `hasPrevious`/`hasPreviousPage`、`hasOlder`/`more` 继续分页标记，以及 `previousCursor`/`prevCursor`/`beforeCursor`/`olderCursor` 等 before-id cursor 别名，避免只返回第一页历史。
 
 M6 补充：remote history response parser 现在会递归解包 `data.session.events`、`data.projectSession.eventConnection`、`conversation`、`remoteHistory` 等 GraphQL/session wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。

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

@@ -206,6 +206,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：task-summary metadata 接受 `taskSummary`/`task_summary`/`content`/`text` 摘要别名和 `createdAt`/`created_at` timestamp 别名，旧任务摘要记录不会只保留 session id。
 - 本轮补充：summary/custom-title/ai-title/last-prompt metadata 接受 `content`/`text`/`title`/`name`/`prompt` 等值字段别名，full loader、metadata loader 和 transcript index 的标题/摘要恢复保持一致。
 - 本轮补充：tag、agent-name、agent-color、agent-setting 和 mode metadata 接受 `label`/`name`/`color`/`setting`/`status` 等值字段别名，full loader、metadata loader 和 transcript index 的 agent/session 状态恢复保持一致。
+- 本轮补充：content-replacement metadata 接受 `records`/`contentReplacements` 等 record wrapper，以及 record 内 `type`/`content`/`hash` 等字段别名，full loader、metadata loader 和 transcript index 的 replacement 恢复保持一致。
 - 本轮补充：remote history `SDKEvent` 解码接受顶层 `sessionID` 作为事件 session id 别名，materialize transcript 时会填充 record 与嵌套 message 的 session id（覆盖测试：`TestRemoteHistoryTranscriptMessagesAcceptsSessionIDUpperAlias`）。
 - 本轮补充：remote history `SDKEvent` 解码接受 `parentUUID`、`parentId`/`parentID`/`parent_id`、`parentMessageId`/`parentMessageID`/`parent_message_id` parent aliases，materialize transcript 时会保留 parent chain（覆盖测试：`TestRemoteHistoryTranscriptMessagesAcceptsParentIDAliases`）。
 - 本轮补充：memory 层补齐官方 `memoryAge`/freshness note 语义，`ReadDocumentsWithOptions` 可为超过 1 天的 memory 文档前缀 system-reminder，提示模型把 memory 当作 point-in-time observation 并核对当前代码。

docs/first-second-parity-audit.md

@@ -140,6 +140,7 @@ M6 progress now includes:
 - `internal/session`: task-summary metadata now accepts alternate summary and timestamp field names in both full and lightweight metadata loaders.
 - `internal/session`: summary/title/last-prompt metadata now accepts alternate value field names across the full loader, lightweight metadata loader, and transcript index.
 - `internal/session`: tag, agent, and mode metadata now accepts alternate value field names across the full loader, lightweight metadata loader, and transcript index.
+- `internal/session`: content-replacement metadata now accepts alternate record wrapper and record value/hash field names across the full loader, lightweight metadata loader, and transcript index.
 - `internal/session`: remote-history parsing now also accepts connection-style `history`/`messages` wrappers with `nodes`/`edges[].node` event lists and `pageInfo`/`page_info` `hasNextPage`/`endCursor`/`startCursor` pagination aliases.
 - `internal/session`: remote-history connection edges now use `edges[].cursor` as the event cursor when the nested node lacks an event ID, preserving pagination even when pageInfo omits a cursor.
 - `internal/session`: remote-history parsing now also accepts `eventList`/`event_list`, `sessionEvents`/`session_events`, and connection aliases such as `connection`, `eventConnection`, and `sessionEventsConnection`.

internal/session/transcript_aliases.go

@@ -315,26 +315,42 @@ func (r *ContentReplacementRecord) UnmarshalJSON(data []byte) error {
 	type ContentReplacementRecordJSON ContentReplacementRecord
 	var aux struct {
 		*ContentReplacementRecordJSON
-		ToolUseIDUpper    string `json:"toolUseID"`
-		ToolUseIDSnake    string `json:"tool_use_id"`
-		BlockIDUpper      string `json:"blockID"`
-		BlockIDSnake      string `json:"block_id"`
-		OriginalHashSnake string `json:"original_hash"`
+		KindType                 string `json:"type"`
+		KindReplacementCamel     string `json:"replacementKind"`
+		KindReplacementSnake     string `json:"replacement_kind"`
+		ToolUseIDUpper           string `json:"toolUseID"`
+		ToolUseIDSnake           string `json:"tool_use_id"`
+		BlockIDUpper             string `json:"blockID"`
+		BlockIDSnake             string `json:"block_id"`
+		ReplacementContent       string `json:"content"`
+		ReplacementText          string `json:"text"`
+		ReplacementValue         string `json:"value"`
+		ReplacementOutput        string `json:"output"`
+		OriginalHashSnake        string `json:"original_hash"`
+		OriginalHashShort        string `json:"hash"`
+		OriginalContentHashCamel string `json:"originalContentHash"`
+		OriginalContentHashSnake string `json:"original_content_hash"`
 	}
 	base := ContentReplacementRecordJSON{}
 	aux.ContentReplacementRecordJSON = &base
 	if err := json.Unmarshal(data, &aux); err != nil {
 		return err
 	}
 	*r = ContentReplacementRecord(base)
+	if r.Kind == "" {
+		r.Kind = firstNonEmptyString(aux.KindType, aux.KindReplacementCamel, aux.KindReplacementSnake)
+	}
 	if r.ToolUseID == "" {
 		r.ToolUseID = firstNonEmptyString(aux.ToolUseIDUpper, aux.ToolUseIDSnake)
 	}
 	if r.BlockID == "" {
 		r.BlockID = firstNonEmptyString(aux.BlockIDUpper, aux.BlockIDSnake)
 	}
+	if r.Replacement == "" {
+		r.Replacement = firstNonEmptyString(aux.ReplacementContent, aux.ReplacementText, aux.ReplacementValue, aux.ReplacementOutput)
+	}
 	if r.OriginalHash == "" {
-		r.OriginalHash = aux.OriginalHashSnake
+		r.OriginalHash = firstNonEmptyString(aux.OriginalHashSnake, aux.OriginalHashShort, aux.OriginalContentHashCamel, aux.OriginalContentHashSnake)
 	}
 	return nil
 }

internal/session/transcript_metadata_fields.go

@@ -189,9 +189,37 @@ func parseContentReplacementMetadata(line []byte) (ContentReplacementEntry, bool
 			"subagentId", "subagentID", "subagent_id",
 		)
 	}
+	if len(entry.Replacements) == 0 {
+		entry.Replacements = parseContentReplacementRecords(fields.rawValue(
+			"replacements",
+			"replacementRecords", "replacement_records",
+			"records",
+			"contentReplacements", "content_replacements",
+			"items",
+		))
+	}
 	return entry, true
 }
 
+func parseContentReplacementRecords(raw json.RawMessage) []ContentReplacementRecord {
+	if len(raw) == 0 {
+		return nil
+	}
+	var records []ContentReplacementRecord
+	if err := json.Unmarshal(raw, &records); err == nil {
+		return records
+	}
+	var record ContentReplacementRecord
+	if err := json.Unmarshal(raw, &record); err != nil || record.isEmpty() {
+		return nil
+	}
+	return []ContentReplacementRecord{record}
+}
+
+func (r ContentReplacementRecord) isEmpty() bool {
+	return r.Kind == "" && r.ToolUseID == "" && r.BlockID == "" && r.Replacement == "" && r.OriginalHash == ""
+}
+
 func parseTombstoneMetadata(line []byte) (TombstoneEntry, bool) {
 	var entry TombstoneEntry
 	if err := json.Unmarshal(line, &entry); err != nil {

internal/session/transcript_test.go

@@ -643,6 +643,7 @@ func TestLoadTranscriptCollectsMetadataEntries(t *testing.T) {
 		`{"type":"content-replacement","sessionId":"s1","agentId":"agent_1","replacements":[{"toolUseId":"toolu_2","replacement":"agent stub"}]}`,
 		`{"type":"content_replacement","session_id":"s3","agent_id":"agent_2","replacements":[{"tool_use_id":"toolu_4","block_id":"block_4","original_hash":"hash_4","replacement":"snake agent stub"}]}`,
 		`{"type":"content-replacement","sessionId":"s1","agentID":"agent_3","replacements":[{"toolUseID":"toolu_5","blockID":"block_5","originalHash":"hash_5","replacement":"upper agent stub"}]}`,
+		`{"type":"content-replacement","sessionID":"s9","records":{"type":"tool-result","toolUseID":"toolu_9","blockID":"block_9","hash":"hash_9","content":"record alias stub"}}`,
 		`{"type":"marble_origami_commit","session_id":"s3","collapse_id":"c1","summary_uuid":"sum1","summary_content":"collapsed","summary":"short","first_archived_uuid":"u1","last_archived_uuid":"a1"}`,
 		`{"type":"marble-origami-commit","sessionID":"s4","collapseID":"c2","summaryID":"sum2","content":"upper collapsed","firstArchivedID":"u2","lastArchivedID":"a2"}`,
 		`{"type":"marble-origami-snapshot","sessionId":"s1","armed":true,"lastSpawnTokens":42}`,
@@ -712,6 +713,9 @@ func TestLoadTranscriptCollectsMetadataEntries(t *testing.T) {
 	if got := transcript.ContentReplacements["agent_3"]; len(got) != 1 || got[0].ToolUseID != "toolu_5" || got[0].BlockID != "block_5" || got[0].Replacement != "upper agent stub" {
 		t.Fatalf("upper agent content replacements = %#v", got)
 	}
+	if got := transcript.ContentReplacements["s9"]; len(got) != 1 || got[0].Kind != "tool-result" || got[0].ToolUseID != "toolu_9" || got[0].BlockID != "block_9" || got[0].OriginalHash != "hash_9" || got[0].Replacement != "record alias stub" {
+		t.Fatalf("record alias content replacements = %#v", got)
+	}
 	if len(transcript.ContextCollapseCommits) != 2 || transcript.ContextCollapseCommits[0].CollapseID != "c1" || transcript.ContextCollapseCommits[0].SummaryUUID != "sum1" || transcript.ContextCollapseCommits[1].CollapseID != "c2" || transcript.ContextCollapseCommits[1].SummaryUUID != "sum2" || transcript.ContextCollapseCommits[1].FirstArchivedUUID != "u2" {
 		t.Fatalf("collapse commit = %#v", transcript.ContextCollapseCommits)
 	}
@@ -782,6 +786,9 @@ func TestLoadTranscriptCollectsMetadataEntries(t *testing.T) {
 	if got := metadata.ContentReplacements["agent_3"]; len(got) != 1 || got[0].ToolUseID != "toolu_5" || got[0].BlockID != "block_5" || got[0].Replacement != "upper agent stub" {
 		t.Fatalf("metadata upper agent replacements = %#v", got)
 	}
+	if got := metadata.ContentReplacements["s9"]; len(got) != 1 || got[0].Kind != "tool-result" || got[0].ToolUseID != "toolu_9" || got[0].BlockID != "block_9" || got[0].OriginalHash != "hash_9" || got[0].Replacement != "record alias stub" {
+		t.Fatalf("metadata record alias replacements = %#v", got)
+	}
 	if len(metadata.ContextCollapseCommits) != 2 || metadata.ContextCollapseCommits[0].CollapseID != "c1" || metadata.ContextCollapseCommits[0].SummaryUUID != "sum1" || metadata.ContextCollapseCommits[1].CollapseID != "c2" || metadata.ContextCollapseCommits[1].SummaryUUID != "sum2" || metadata.ContextCollapseCommits[1].FirstArchivedUUID != "u2" {
 		t.Fatalf("metadata collapse commit = %#v", metadata.ContextCollapseCommits)
 	}
@@ -802,6 +809,13 @@ func TestLoadTranscriptCollectsMetadataEntries(t *testing.T) {
 	if agentIndex.Tag != "aliased-tag" || agentIndex.AgentName != "Aliased Agent" || agentIndex.AgentColor != "green" || agentIndex.AgentSetting != "auditor" || agentIndex.Mode != "review" {
 		t.Fatalf("index agent value aliases = %#v", agentIndex)
 	}
+	contentIndex, err := LoadTranscriptIndex(path, "s9")
+	if err != nil {
+		t.Fatal(err)
+	}
+	if contentIndex.ContentReplacementCount != 1 {
+		t.Fatalf("index content replacement aliases = %#v", contentIndex)
+	}
 }
 
 func TestLoadTranscriptMetadataAcceptsSessionIDAndNumericStrings(t *testing.T) {