Accept transcript metadata numeric aliases

Author: SqlRush

docs/cc-100-roadmap.md

@@ -276,6 +276,8 @@ M7 补充：Ctrl-S prompt stash 现在保存并恢复 prompt text、cursor 和 p
 
 本轮补充：remote history HTTP `Link` header 分页接受 `previous`/`prev`/`older`/`next` rel URL，并以 body cursor 优先、header cursor fallback 的方式继续抓取。
 
+本轮补充：transcript metadata loader 现在接受 `sessionID` 和 `session` 作为 session-scoped metadata ID 别名，并容忍 `prNumber`、`timeSavedMs`、`lastSpawnTokens` 等计数字段使用数字字符串。
+
 本轮补充：sidechain/subagent state loader 接受 legacy/fork 命名的 start/finish subtype、ID/type/summary 字段别名和常见状态别名，提升旧 subagent transcript resume/list 的恢复率。
 
 本轮补充：conversation runner 现在会在用户消息入队后计算 compact token warning state，并在触发 warning/error/auto-compact/blocking 阈值时发出 `token_warning` event；warning state 接入 blocking-limit override，auto-compact threshold 判断接入 `CLAUDE_AUTOCOMPACT_PCT_OVERRIDE`，使 runtime warning 和自动压缩使用同一套 window 输入。

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

@@ -193,6 +193,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：remote history response parser 会递归解包 `data.session.events`、`data.projectSession.eventConnection`、`conversation`、`remoteHistory` 等 GraphQL/session wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。
 - 本轮补充：transcript resume 的嵌套 content block 接受 `toolUseId`/`toolUseID`、`isError`、`cacheControl`、`cacheReference` 字段别名，并保留 cache edit 的 `cacheReference`。
 - 本轮补充：lightweight transcript metadata loader 在 `system`/`compact_boundary` 后清空旧 `marble-origami-commit`/`marble-origami-snapshot` 状态，和 full loader/官方 sessionStorage compact-boundary 语义一致。
+- 本轮补充：transcript metadata loader 接受 `sessionID`/`session` 作为 session-scoped metadata ID 别名，并容忍 `prNumber`、`timeSavedMs`、`lastSpawnTokens` 等计数字段使用数字字符串。
 - 本轮补充：memory 层补齐官方 `memoryAge`/freshness note 语义，`ReadDocumentsWithOptions` 可为超过 1 天的 memory 文档前缀 system-reminder，提示模型把 memory 当作 point-in-time observation 并核对当前代码。
 - 本轮补充：Read tool 在 metadata 提供 auto-memory 目录时，会为读取旧 auto-memory 文件的 tool result 前缀 freshness system-reminder，和官方 FileReadTool 的 memory freshness prefix 对齐。
 - 本轮补充：memory 层补齐官方 `relevant_memories` attachment 基础，包含 stable memory header、system-reminder 渲染、surfaced path/byte 扫描、按 200 行/4096 bytes 读取并附截断提示的 surfacing reader、mark-after-filter 的 duplicate memory attachment 过滤、最后非 meta user prompt/单词 prompt/60KB session cap 的 prefetch gating、多目录结果排除 read-state/surfaced 后取前 5 个候选的选择逻辑，以及 recent successful tools 窗口收集并排除 pending/failed/同名失败工具。

docs/first-second-parity-audit.md

@@ -145,6 +145,7 @@ M6 progress now includes:
 - `internal/session`: transcript indexes and session search now recover message `cwd` as project path, accept project/working-directory aliases, and can match sessions by project path.
 - `internal/session`: transcript message loading now preserves structured SerializedMessage metadata such as `userType`, `entrypoint`, `version`, and `slug`, including common alias spellings.
 - `internal/session`: lightweight transcript metadata loading now clears stale context-collapse commit/snapshot state after compact-boundary messages, matching the full loader and official sessionStorage restore semantics.
+- `internal/session`: transcript metadata loading now accepts `sessionID` and `session` as session-scoped ID aliases and tolerates numeric strings for counters such as `prNumber`, `timeSavedMs`, and `lastSpawnTokens`.
 - `internal/memory`: memory age/freshness helpers now match official stale-memory guidance, and document loading can prefix old memory files with a system-reminder that they are point-in-time observations.
 - `internal/memory`: relevant-memory attachment primitives now match the official `relevant_memories` shape for stable headers, system-reminder rendering, surfaced path/byte scanning, 200-line/4096-byte surfacing reads with truncation notices, mark-after-filter duplicate attachment handling, last-non-meta-user/single-word/session-byte-cap prefetch gating, top-5 candidate filtering after read-state/surfaced de-dup, and recent successful tools collection excluding pending/failed/same-name-failed tools.
 - `internal/conversation`: request building now expands `relevant_memories` attachment messages into user/meta system-reminders before Anthropic API normalization.

internal/session/transcript_metadata_fields.go

@@ -3,6 +3,8 @@ package session
 import (
 	"bytes"
 	"encoding/json"
+	"strconv"
+	"strings"
 
 	"ccgo/internal/contracts"
 )
@@ -36,7 +38,7 @@ func (f transcriptMetadataFields) idValue(keys ...string) contracts.ID {
 }
 
 func (f transcriptMetadataFields) sessionIDValue() contracts.ID {
-	return f.idValue("sessionId", "session_id", "sessionUuid", "sessionUUID", "session_uuid")
+	return f.idValue("sessionId", "sessionID", "session_id", "session", "sessionUuid", "sessionUUID", "session_uuid")
 }
 
 func (f transcriptMetadataFields) intValue(keys ...string) int {
@@ -49,6 +51,13 @@ func (f transcriptMetadataFields) intValue(keys ...string) int {
 		if err := json.Unmarshal(raw, &value); err == nil {
 			return value
 		}
+		var text string
+		if err := json.Unmarshal(raw, &text); err == nil {
+			value, err := strconv.Atoi(strings.TrimSpace(text))
+			if err == nil {
+				return value
+			}
+		}
 	}
 	return 0
 }
@@ -102,25 +111,23 @@ func parseTaskSummaryMetadata(line []byte) (TaskSummaryEntry, bool) {
 }
 
 func parsePRLinkMetadata(line []byte) (PRLinkEntry, bool) {
-	var entry PRLinkEntry
-	if err := json.Unmarshal(line, &entry); err != nil {
-		return PRLinkEntry{}, false
-	}
 	fields, err := parseTranscriptMetadataFields(line)
 	if err != nil {
 		return PRLinkEntry{}, false
 	}
+	var entry PRLinkEntry
+	_ = json.Unmarshal(line, &entry)
 	if entry.SessionID == "" {
 		entry.SessionID = fields.sessionIDValue()
 	}
 	if entry.PRNumber == 0 {
-		entry.PRNumber = fields.intValue("pr_number")
+		entry.PRNumber = fields.intValue("prNumber", "pr_number", "number")
 	}
 	if entry.PRURL == "" {
-		entry.PRURL = fields.stringValue("pr_url")
+		entry.PRURL = fields.stringValue("prUrl", "prURL", "pr_url", "url")
 	}
 	if entry.PRRepository == "" {
-		entry.PRRepository = fields.stringValue("pr_repository")
+		entry.PRRepository = fields.stringValue("prRepository", "pr_repository", "repository", "repo")
 	}
 	return entry, true
 }
@@ -199,16 +206,17 @@ func parseTombstoneMetadata(line []byte) (TombstoneEntry, bool) {
 }
 
 func parseSpeculationAcceptMetadata(line []byte) (SpeculationAcceptEntry, bool) {
-	var entry SpeculationAcceptEntry
-	if err := json.Unmarshal(line, &entry); err != nil {
-		return SpeculationAcceptEntry{}, false
-	}
 	fields, err := parseTranscriptMetadataFields(line)
 	if err != nil {
 		return SpeculationAcceptEntry{}, false
 	}
+	var entry SpeculationAcceptEntry
+	_ = json.Unmarshal(line, &entry)
 	if entry.TimeSavedMS == 0 {
-		entry.TimeSavedMS = fields.intValue("time_saved_ms")
+		entry.TimeSavedMS = fields.intValue("timeSavedMs", "timeSavedMS", "time_saved_ms", "timeSaved", "time_saved")
+	}
+	if entry.Timestamp == "" {
+		entry.Timestamp = fields.stringValue("timestamp", "createdAt", "created_at", "time")
 	}
 	return entry, true
 }
@@ -244,19 +252,17 @@ func parseContextCollapseCommitMetadata(line []byte) (ContextCollapseCommitEntry
 }
 
 func parseContextCollapseSnapshotMetadata(line []byte) (ContextCollapseSnapshotEntry, bool) {
-	var entry ContextCollapseSnapshotEntry
-	if err := json.Unmarshal(line, &entry); err != nil {
-		return ContextCollapseSnapshotEntry{}, false
-	}
 	fields, err := parseTranscriptMetadataFields(line)
 	if err != nil {
 		return ContextCollapseSnapshotEntry{}, false
 	}
+	var entry ContextCollapseSnapshotEntry
+	_ = json.Unmarshal(line, &entry)
 	if entry.SessionID == "" {
 		entry.SessionID = fields.sessionIDValue()
 	}
 	if entry.LastSpawnTokens == 0 {
-		entry.LastSpawnTokens = fields.intValue("last_spawn_tokens")
+		entry.LastSpawnTokens = fields.intValue("lastSpawnTokens", "last_spawn_tokens")
 	}
 	return entry, true
 }

internal/session/transcript_test.go

@@ -689,6 +689,38 @@ func TestLoadTranscriptCollectsMetadataEntries(t *testing.T) {
 	}
 }
 
+func TestLoadTranscriptMetadataAcceptsSessionIDAndNumericStrings(t *testing.T) {
+	path := writeTranscript(t, []string{
+		`{"type":"pr-link","sessionID":"s4","prNumber":"44","prUrl":"https://github.com/o/r/pull/44","prRepository":"o/r"}`,
+		`{"type":"speculation-accept","createdAt":"2026-01-01T00:00:05Z","timeSavedMs":"5600"}`,
+		`{"type":"marble-origami-snapshot","sessionID":"s4","armed":true,"lastSpawnTokens":"96"}`,
+	})
+	transcript, err := LoadTranscript(path)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if transcript.PRLinks["s4"].PRNumber != 44 || transcript.PRLinks["s4"].PRRepository != "o/r" {
+		t.Fatalf("transcript pr link = %#v", transcript.PRLinks)
+	}
+	if len(transcript.SpeculationAccepts) != 1 || transcript.SpeculationAccepts[0].TimeSavedMS != 5600 || transcript.SpeculationAccepts[0].Timestamp != "2026-01-01T00:00:05Z" {
+		t.Fatalf("transcript speculation = %#v", transcript.SpeculationAccepts)
+	}
+	if transcript.ContextCollapseSnapshot == nil || transcript.ContextCollapseSnapshot.SessionID != "s4" || transcript.ContextCollapseSnapshot.LastSpawnTokens != 96 {
+		t.Fatalf("transcript snapshot = %#v", transcript.ContextCollapseSnapshot)
+	}
+
+	metadata, err := LoadTranscriptMetadata(path)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if metadata.PRLinks["s4"].PRNumber != 44 || metadata.ContextCollapseSnapshot == nil || metadata.ContextCollapseSnapshot.LastSpawnTokens != 96 {
+		t.Fatalf("metadata = %#v snapshot=%#v", metadata.PRLinks, metadata.ContextCollapseSnapshot)
+	}
+	if len(metadata.SpeculationAccepts) != 1 || metadata.SpeculationAccepts[0].TimeSavedMS != 5600 {
+		t.Fatalf("metadata speculation = %#v", metadata.SpeculationAccepts)
+	}
+}
+
 func TestReappendSessionMetadataWritesSessionScopedTailEntries(t *testing.T) {
 	path := writeTranscript(t, []string{
 		`{"type":"custom-title","sessionId":"s1","customTitle":"Title"}`,