Accept remote history generic wrappers

Author: SqlRush

docs/cc-100-roadmap.md

@@ -78,6 +78,8 @@ M6 补充：remote history response parser 现在会递归解包 `data.session.e
 
 M6 补充：remote history event-list 现在接受 `value`/`values`/`resources`/`collection` 别名，connection edge 也接受 `resource`/`value` 作为 node payload，覆盖 OData/HAL/resource collection 风格响应。
 
+M6 补充：remote history response parser 现在会解包 `payload`/`response`/`result`/`body` 等通用响应外壳，外壳内的 event list、pagination、links 会继续递归解析。
+
 M6 补充：remote history REST/link 风格分页现在接受 `links`/`_links` 的 `next`/`previous`/`prev`/`older` 字符串 URL 或 `{href,url,uri,link}` 对象，并从 `before_id`、`beforeId`、`cursor`、`pageCursor`、`previousCursor`、`prevCursor`、`beforeCursor`、`olderCursor`、`startCursor`、`endCursor` 等 query 参数提取下一页 before-id。
 
 M6 补充：remote history REST/link 风格分页现在也接受 RFC/JSON:API 风格的 `links` 数组，按 `rel`/`relation`/`name`/`type` 中的 `previous`/`prev`/`older`/`next` 选择续抓 URL，并从同一组 before/cursor query 参数提取 before-id。

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

@@ -198,6 +198,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：contract `ID` JSON 读取现在接受 JSON number/null，remote history event/message/session/parent ID alias 可继承数字 ID 兼容面并在 transcript materialization 中保留为字符串。
 - 本轮补充：remote history response parser 会递归解包 `data.session.events`、`data.projectSession.eventConnection`、`conversation`、`remoteHistory`、`_embedded` 等 GraphQL/session/HAL wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。
 - 本轮补充：remote history event-list 接受 `value`/`values`/`resources`/`collection` 别名，connection edge 也接受 `resource`/`value` 作为 node payload，覆盖 OData/HAL/resource collection 风格响应。
+- 本轮补充：remote history response parser 会解包 `payload`/`response`/`result`/`body` 等通用响应外壳，外壳内的 event list、pagination、links 会继续递归解析。
 - 本轮补充：transcript resume 的嵌套 content block 接受 `toolUseId`/`toolUseID`、`isError`、`cacheControl`、`cacheReference` 字段别名，并保留 cache edit 的 `cacheReference`。
 - 本轮补充：transcript resume 的 nested content block `id`/`tool_use_id`/`toolUseId` 现在接受 JSON number，并保留为字符串 tool-use ID。
 - 本轮补充：lightweight transcript metadata loader 在 `system`/`compact_boundary` 后清空旧 `marble-origami-commit`/`marble-origami-snapshot` 状态，和 full loader/官方 sessionStorage compact-boundary 语义一致。

docs/first-second-parity-audit.md

@@ -145,6 +145,7 @@ M6 progress now includes:
 - `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`: remote-history parsing now also accepts `value`, `values`, `resources`, and `collection` event-list aliases, plus `edges[].resource`/`edges[].value` node payload aliases.
+- `internal/session`: remote-history parsing now unwraps generic response envelopes such as `payload`, `response`, `result`, and `body` when they contain event lists and pagination fields.
 - `internal/session`: remote-history pageInfo parsing now accepts previous/older pagination signals such as `hasPrevious`/`hasPreviousPage`, `hasOlder`/`more`, and before-id cursors such as `previousCursor`/`prevCursor`/`beforeCursor`/`olderCursor`.
 - `internal/session`: remote-history pagination bool parsing now accepts numeric and yes/no-style bool values in addition to JSON bools and true/false strings.
 - `internal/session`: remote-history pagination cursor/id parsing now accepts JSON numbers and preserves them as string cursors for page fields and `edges[].cursor`.

internal/session/remote_history.go

@@ -148,6 +148,10 @@ func (r *sessionEventsResponse) mergeJSON(data []byte) error {
 		{name: "values", target: &r.Values},
 		{name: "resources", target: &r.Resources},
 		{name: "collection", target: &r.Collection},
+		{name: "payload", target: &r.Events},
+		{name: "response", target: &r.Events},
+		{name: "result", target: &r.Results},
+		{name: "body", target: &r.Events},
 		{name: "records", target: &r.Records},
 		{name: "rows", target: &r.Rows},
 		{name: "entries", target: &r.Entries},

internal/session/remote_history_test.go

@@ -718,6 +718,44 @@ func TestFetchRemoteHistoryAcceptsValueAndResourceAliases(t *testing.T) {
 	}
 }
 
+func TestFetchRemoteHistoryAcceptsGenericResponseWrappers(t *testing.T) {
+	var seen []url.Values
+	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		seen = append(seen, r.URL.Query())
+		w.Header().Set("Content-Type", "application/json")
+		switch r.URL.Query().Get("before_id") {
+		case "":
+			_, _ = w.Write([]byte(`{"payload":{"events":[{"type":"status","event_id":"evt_payload","session_id":"s","status":"payload"}],"hasMore":true,"nextCursor":"evt_payload"}}`))
+		case "evt_payload":
+			_, _ = w.Write([]byte(`{"response":{"items":[{"type":"status","event_id":"evt_response","session_id":"s","status":"response"}],"paging":{"more":true,"olderCursor":"evt_response"}}}`))
+		case "evt_response":
+			_, _ = w.Write([]byte(`{"result":{"value":[{"type":"status","event_id":"evt_result","session_id":"s","status":"result"}],"@odata.nextLink":"/v1/sessions/s/events?skipToken=evt_body"}}`))
+		case "evt_body":
+			_, _ = w.Write([]byte(`{"body":{"resources":[{"type":"status","event_id":"evt_body","session_id":"s","status":"body"}],"has_more":false}}`))
+		default:
+			t.Fatalf("unexpected before_id = %q", r.URL.Query().Get("before_id"))
+		}
+	}))
+	defer server.Close()
+
+	authCtx := NewRemoteHistoryAuthContext("s", "token", "", auth.OAuthConfig{BaseAPIURL: server.URL})
+	events, err := FetchRemoteHistory(context.Background(), server.Client(), authCtx, RemoteHistoryFetchOptions{Limit: 4})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if !events.Complete || events.Pages != 4 || len(events.Events) != 4 || events.NextBeforeID != "" {
+		t.Fatalf("events = %#v", events)
+	}
+	for index, want := range []string{"payload", "response", "result", "body"} {
+		if events.Events[index].Status != want {
+			t.Fatalf("event %d = %#v, want status %q", index, events.Events[index], want)
+		}
+	}
+	if len(seen) != 4 || seen[1].Get("before_id") != "evt_payload" || seen[2].Get("before_id") != "evt_response" || seen[3].Get("before_id") != "evt_body" {
+		t.Fatalf("queries = %#v", seen)
+	}
+}
+
 func TestFetchRemoteHistoryUsesEdgeCursorWhenNodeIDMissing(t *testing.T) {
 	var seen []url.Values
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {