Accept message microcompact summaries

Author: SqlRush

docs/cc-100-roadmap.md

@@ -44,6 +44,8 @@ M6 补充：microcompact disk cache loader 现在接受 JSON:API/resource-style
 
 M6 补充：microcompact disk cache loader 的 summary-like payload 现在接受 text content-block object、text content-block array 和 string array，会把可见 text block 合并为 summary，兼容官方/SDK 响应内容块形态的 cached microcompact 文件。
 
+M6 补充：microcompact disk cache loader 的 summary-like payload 现在也接受完整 contract message object，并会递归解包 `message`/`assistantMessage`/`resultMessage`/`outputMessage`/`completionMessage` wrapper，从 message content 中恢复 visible text summary。
+
 M6 补充：sidechain/subagent lifecycle state loader 现在接受 `subagent_started`、`agentStarted`、`task_failed`、`sidechainCompleted` 等相邻 subtype aliases，支持 `taskID`/`workerId`/`runId`、`agentName`/`kind`、`resultText`/`finalMessage` 等字段，并在 failed/cancelled subtype 没有显式 status 时自动归一状态。
 
 M6 补充：sidechain/subagent lifecycle content 读取现在接受 JSON:API/resource-style `resource`/`attributes`/`properties` wrapper，外层 resource `id` 可作为 sidechain ID fallback，内层 agent metadata、status/outcome 和 summary 字段仍能恢复到 state/list/resume。
@@ -490,6 +492,8 @@ M7 补充：prompt history `LogEntry` 读取现在接受 `sessionID`/`session`/`
 
 本轮补充：microcompact disk cache loader 的 summary-like payload 现在接受 text content-block object、text content-block array 和 string array，会把可见 text block 合并为 summary，兼容官方/SDK 响应内容块形态的 cached microcompact 文件。
 
+本轮补充：microcompact disk cache loader 的 summary-like payload 现在也接受完整 contract message object，并会递归解包 `message`/`assistantMessage`/`resultMessage`/`outputMessage`/`completionMessage` wrapper，从 message content 中恢复 visible text summary。
+
 本轮补充：contract content block 解码现在接受文本块字段别名 `body`/`message`/`value`/`output`/`contentText`/`content_text`，并在 `text`/`thinking` block 中从字符串 `content` 回填文本，transcript resume 可恢复这些嵌套文本块格式。
 
 本轮补充：contract image source 解码现在接受 `mediaType`/`mimeType`/`contentType`、`base64`/`payload` 等 source 字段别名，并支持顶层 image block 直接携带媒体类型和 base64 数据，transcript resume 会保留为规范 `ImageSource`。

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

@@ -253,6 +253,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：microcompact disk cache loader 现在会从 `metadata`/`meta`/`cacheInfo`/`cacheDetails`/`cacheEntry`/`entry`/`record`/`cache` 等 sidecar object 中补缺失的 digest、version、cache-hit、timestamp、TTL 和 count aliases；主 summary payload 字段仍保持优先。
 - 本轮补充：microcompact disk cache loader 现在也接受 JSON:API/resource-style `resource`/`attributes`/`properties` wrapper，summary payload 可放在 attributes/properties 内，外层 resource `id` 可作为 digest fallback。
 - 本轮补充：microcompact disk cache loader 的 summary-like payload 现在接受 text content-block object、text content-block array 和 string array，会把可见 text block 合并为 summary，兼容官方/SDK 响应内容块形态的 cached microcompact 文件。
+- 本轮补充：microcompact disk cache loader 的 summary-like payload 现在也接受完整 contract message object，并会递归解包 `message`/`assistantMessage`/`resultMessage`/`outputMessage`/`completionMessage` wrapper，从 message content 中恢复 visible text summary。
 
 ### M7: TUI renderer 和交互体验
 

docs/first-second-parity-audit.md

@@ -131,6 +131,7 @@ M6 progress now includes:
 - `internal/compact`: microcompact disk cache loading now accepts non-strict cache-hit booleans for `cached`/`fromCache`/`cacheHit`/`isCached`, including `yes`/`no`, `on`/`off`, and `1`/`0` JSON number or string values.
 - `internal/compact`: microcompact disk cache loading now accepts JSON:API/resource-style `resource`/`attributes`/`properties` wrappers, with summary payloads inside attributes/properties and outer resource IDs used as digest fallback when needed.
 - `internal/compact`: microcompact disk cache summary payloads now accept text content-block objects, text content-block arrays, and string arrays, joining visible text blocks into the recovered summary for official/SDK-style cached microcompact files.
+- `internal/compact`: microcompact disk cache summary payloads now also accept full contract message objects and unwrap `message`/`assistantMessage`/`resultMessage`/`outputMessage`/`completionMessage` response wrappers before extracting visible text summary.
 - `internal/conversation`: optional auto-compact can now run before the main request, fail open with a consecutive-failure circuit breaker, emit runtime `token_warning` events from compact warning state, persist compact boundary metadata to transcript, write a session-memory summary, inject recalled session-memory snippets into API request context when enabled, and optionally extract turn-end memory facts into session memory.
 - `internal/memory`: session-memory summaries can now be loaded with frontmatter field aliases, rolled up/pruned into an archive summary with prior rollup archives excluded from candidate compaction and merged across archive IDs, rune-safe rollup truncation, recalled by query with deterministic scoring and recency ordering, ranked through a model-assisted candidate/session-id selection path with fallback when selected IDs are invalid or excluded, alternate/camel response-key parsing, fenced/prose JSON extraction, scalar session-id parsing, nested/wrapped/collection-alias selection parsing, and nested selected-memory item parsing, and injected into resume context through the same optional recall agent path; deterministic and model-backed memory fact extraction can summarize user preferences, requests, decisions, and tool-use facts, including fenced/prose JSON, wrapped facts responses, alternate and structured fact field names, nested source objects, nested fact response shapes, and fact kind aliases.
 - `internal/session`: project session listing and pagination, prompt-history lock/buffered flush/field aliases, lightweight transcript index/title/text-preview inference, line-offset transcript indexing/window/byte-budget-window/parent-chain/resume/tail/byte-budget-tail loading, AI-title/last-prompt/task/agent/PR/worktree transcript metadata loading and type/field aliases, transcript message/session UUID field aliases, tombstone metadata loading with target/session/reason aliases and delete/relink replay, agent-scoped content replacement metadata/record field-alias loading, session-scoped metadata reappend including AI-title/last-prompt/task-summary, streaming transcript search snippets for resume/search UI, official `subagents/agent-*.jsonl` transcript layout with legacy sidechain listing, agent metadata sidecar read/write/field aliases, sidechain runtime start/append/finish/cancel/fail summary bridging plus parent-chain append/finish, sidechain manager orchestration for spawn/append/finish/cancel/fail/list/resume, sidechain state/list/resume support with content-field aliases, sidechain resume context construction, sidechain conversation and agent-scoped content-replacement reconstruction, transcript tail/window loading and byte-budget tail loading for bounded-memory resume/UI paths, lightweight transcript metadata loading, remote-history token refresh retry, page-field/event-list/records/entries/last-id/cursor/event-id/has-next aliases plus wrapped-data/links/paging/bare-array/keyed-event-map responses, before_id resume, fallback field fill, and duplicate-aware parent linking during transcript materialization.

internal/compact/compact_test.go

@@ -521,6 +521,80 @@ func TestLoadMicroResultAcceptsContentBlockSummaryPayloads(t *testing.T) {
 	}
 }
 
+func TestLoadMicroResultAcceptsMessageSummaryPayloads(t *testing.T) {
+	cacheDir := filepath.Join(t.TempDir(), "micro")
+	if err := os.MkdirAll(cacheDir, 0o755); err != nil {
+		t.Fatal(err)
+	}
+	for _, tc := range []struct {
+		digest  string
+		payload string
+		want    string
+	}{
+		{
+			digest: "summary-message",
+			payload: `{
+				"summary": {
+					"role": "assistant",
+					"content": [
+						{"type": "text", "text": "message summary"},
+						{"type": "thinking", "text": "not part of visible summary"}
+					]
+				},
+				"digest": "summary-message",
+				"version": "microcompact.v1",
+				"createdAt": 100
+			}`,
+			want: "message summary",
+		},
+		{
+			digest: "message-wrapper",
+			payload: `{
+				"message": {
+					"role": "assistant",
+					"content": [
+						{"type": "text", "text": "wrapped message summary"},
+						"tail line"
+					]
+				},
+				"cacheKey": "message-wrapper",
+				"cacheVersion": "microcompact.v1",
+				"cachedAt": 100
+			}`,
+			want: "wrapped message summary\ntail line",
+		},
+		{
+			digest: "response-message-wrapper",
+			payload: `{
+				"response": {
+					"message": {
+						"type": "assistant",
+						"content": {"type": "text", "body": "response message summary"}
+					},
+					"cacheDigest": "response-message-wrapper",
+					"formatVersion": "microcompact.v1",
+					"createdAt": 100
+				}
+			}`,
+			want: "response message summary",
+		},
+	} {
+		if err := os.WriteFile(microResultPath(cacheDir, tc.digest), []byte(tc.payload), 0o600); err != nil {
+			t.Fatal(err)
+		}
+		result, ok, err := LoadMicroResult(cacheDir, tc.digest)
+		if err != nil {
+			t.Fatalf("%s load error: %v", tc.digest, err)
+		}
+		if !ok {
+			t.Fatalf("%s was not loaded", tc.digest)
+		}
+		if result.Summary != tc.want || result.Digest != tc.digest || result.Version != DefaultMicroCacheVersion {
+			t.Fatalf("%s result = %#v", tc.digest, result)
+		}
+	}
+}
+
 func TestLoadMicroResultAcceptsMetadataCacheAliases(t *testing.T) {
 	cacheDir := filepath.Join(t.TempDir(), "micro")
 	if err := os.MkdirAll(cacheDir, 0o755); err != nil {

internal/compact/micro.go

@@ -190,6 +190,7 @@ func microResultWrappedJSON(fields map[string]json.RawMessage) (json.RawMessage,
 	for _, name := range []string{
 		"result", "data", "cache", "cacheEntry", "cache_entry", "entry", "record", "item", "resource", "payload", "response", "body",
 		"microcompact", "microCompact", "micro_compact", "micro_result", "microResult", "microcompactResult", "microCompactResult", "micro_compact_result",
+		"message", "assistantMessage", "assistant_message", "resultMessage", "result_message", "outputMessage", "output_message", "completion", "completionMessage", "completion_message",
 		"attributes", "properties", "value",
 	} {
 		raw, ok := fields[name]
@@ -528,14 +529,17 @@ func microSummaryFromRaw(raw json.RawMessage, field string) (string, bool, error
 	}
 	switch trimmed[0] {
 	case '{':
-		var block contracts.ContentBlock
-		if err := json.Unmarshal(trimmed, &block); err != nil {
+		if text, ok, err := microSummaryContentBlockText(trimmed); err != nil {
 			return "", false, err
+		} else if ok {
+			return text, true, nil
 		}
-		if block.Type == contracts.ContentText && block.Text != "" {
-			return block.Text, true, nil
+		if text, ok, err := microSummaryMessageText(trimmed); err != nil {
+			return "", false, err
+		} else if ok {
+			return text, true, nil
 		}
-		return "", false, fmt.Errorf("invalid summary field %q: expected text content block", field)
+		return "", false, fmt.Errorf("invalid summary field %q: expected text content block or message", field)
 	case '[':
 		var items []json.RawMessage
 		if err := json.Unmarshal(trimmed, &items); err != nil {
@@ -572,8 +576,12 @@ func microSummaryArrayItemFromRaw(raw json.RawMessage, field string) (string, bo
 	if trimmed[0] != '{' {
 		return "", false, fmt.Errorf("invalid summary field %q", field)
 	}
+	return microSummaryContentBlockText(trimmed)
+}
+
+func microSummaryContentBlockText(raw json.RawMessage) (string, bool, error) {
 	var block contracts.ContentBlock
-	if err := json.Unmarshal(trimmed, &block); err != nil {
+	if err := json.Unmarshal(raw, &block); err != nil {
 		return "", false, err
 	}
 	if block.Type == contracts.ContentText && block.Text != "" {
@@ -582,6 +590,17 @@ func microSummaryArrayItemFromRaw(raw json.RawMessage, field string) (string, bo
 	return "", false, nil
 }
 
+func microSummaryMessageText(raw json.RawMessage) (string, bool, error) {
+	var message contracts.Message
+	if err := json.Unmarshal(raw, &message); err != nil {
+		return "", false, err
+	}
+	if text := msgs.TextContent(message); text != "" {
+		return text, true, nil
+	}
+	return "", false, nil
+}
+
 func microBoolJSONField(fields map[string]json.RawMessage, names ...string) (bool, bool, error) {
 	for _, name := range names {
 		raw, ok := fields[name]