Accept remote history resource aliases

Author: SqlRush

docs/cc-100-roadmap.md

@@ -74,6 +74,8 @@ M6 补充：contract `ID` JSON 读取现在接受 JSON number/null，remote hist
 
 M6 补充：remote history response parser 现在会递归解包 `data.session.events`、`data.projectSession.eventConnection`、`conversation`、`remoteHistory`、`_embedded` 等 GraphQL/session/HAL wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。
 
+M6 补充：remote history event-list 现在接受 `value`/`values`/`resources`/`collection` 别名，connection edge 也接受 `resource`/`value` 作为 node payload，覆盖 OData/HAL/resource collection 风格响应。
+
 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

@@ -196,6 +196,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：remote history pagination 现在接受 `nextPageToken`/`nextToken`/`pageToken`/`continuationToken` 及 snake_case 形式，响应字段和 link URL query 参数都会归一到续抓 before-id。
 - 本轮补充：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 风格响应。
 - 本轮补充：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

@@ -144,6 +144,7 @@ M6 progress now includes:
 - `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`: 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 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

@@ -52,6 +52,10 @@ type sessionEventsResponse struct {
 	Events               []contracts.SDKEvent `json:"events"`
 	Items                []contracts.SDKEvent `json:"items"`
 	Results              []contracts.SDKEvent `json:"results"`
+	Value                []contracts.SDKEvent `json:"value"`
+	Values               []contracts.SDKEvent `json:"values"`
+	Resources            []contracts.SDKEvent `json:"resources"`
+	Collection           []contracts.SDKEvent `json:"collection"`
 	Records              []contracts.SDKEvent `json:"records"`
 	Rows                 []contracts.SDKEvent `json:"rows"`
 	Entries              []contracts.SDKEvent `json:"entries"`
@@ -140,6 +144,10 @@ func (r *sessionEventsResponse) mergeJSON(data []byte) error {
 		{name: "events", target: &r.Events},
 		{name: "items", target: &r.Items},
 		{name: "results", target: &r.Results},
+		{name: "value", target: &r.Value},
+		{name: "values", target: &r.Values},
+		{name: "resources", target: &r.Resources},
+		{name: "collection", target: &r.Collection},
 		{name: "records", target: &r.Records},
 		{name: "rows", target: &r.Rows},
 		{name: "entries", target: &r.Entries},
@@ -380,6 +388,18 @@ func (r *sessionEventsResponse) mergeFrom(other sessionEventsResponse) {
 	if r.Results == nil {
 		r.Results = other.Results
 	}
+	if r.Value == nil {
+		r.Value = other.Value
+	}
+	if r.Values == nil {
+		r.Values = other.Values
+	}
+	if r.Resources == nil {
+		r.Resources = other.Resources
+	}
+	if r.Collection == nil {
+		r.Collection = other.Collection
+	}
 	if r.Records == nil {
 		r.Records = other.Records
 	}
@@ -558,7 +578,7 @@ func decodeRemoteHistoryEventArray(name string, data json.RawMessage) ([]contrac
 	events := make([]contracts.SDKEvent, 0, len(rawEdges))
 	for index, edge := range rawEdges {
 		cursor := remoteHistoryStringField(edge, "cursor")
-		rawEvent := firstRawField(edge, "node", "event", "record", "item")
+		rawEvent := firstRawField(edge, "node", "event", "record", "item", "resource", "value")
 		if rawEvent == nil {
 			rawEvent = edgeJSON(edge)
 		}
@@ -1038,7 +1058,7 @@ func firstEventList(values ...[]contracts.SDKEvent) []contracts.SDKEvent {
 }
 
 func responseEventList(response sessionEventsResponse) []contracts.SDKEvent {
-	return firstEventList(response.Data, response.Events, response.Items, response.Results, response.Records, response.Rows, response.Entries, response.Messages, response.History, response.Nodes, response.Edges)
+	return firstEventList(response.Data, response.Events, response.Items, response.Results, response.Value, response.Values, response.Resources, response.Collection, response.Records, response.Rows, response.Entries, response.Messages, response.History, response.Nodes, response.Edges)
 }
 
 func cloneHeader(header http.Header) http.Header {

internal/session/remote_history_test.go

@@ -650,6 +650,40 @@ func TestFetchRemoteHistoryAcceptsConnectionWrappers(t *testing.T) {
 	}
 }
 
+func TestFetchRemoteHistoryAcceptsValueAndResourceAliases(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(`{"value":[{"type":"status","eventId":"evt_value","session_id":"s","status":"latest"}],"hasNext":true,"nextPageToken":"evt_value"}`))
+		case "evt_value":
+			_, _ = w.Write([]byte(`{"history":{"edges":[{"cursor":"evt_resource","resource":{"type":"status","session_id":"s","status":"resource"}}],"pageInfo":{"hasNextPage":true}}}`))
+		case "evt_resource":
+			_, _ = w.Write([]byte(`{"resources":[{"type":"status","event_id":"evt_old","session_id":"s","status":"oldest"}],"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: 3})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if !events.Complete || events.Pages != 3 || len(events.Events) != 3 || events.NextBeforeID != "" {
+		t.Fatalf("events = %#v", events)
+	}
+	if events.Events[0].ID != "evt_value" || events.Events[0].Status != "latest" || events.Events[1].ID != "evt_resource" || events.Events[1].Status != "resource" || events.Events[2].ID != "evt_old" || events.Events[2].Status != "oldest" {
+		t.Fatalf("events = %#v", events.Events)
+	}
+	if len(seen) != 3 || seen[1].Get("before_id") != "evt_value" || seen[2].Get("before_id") != "evt_resource" {
+		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) {