Accept resource attribute remote history events

Author: SqlRush

docs/cc-100-roadmap.md

@@ -488,6 +488,8 @@ M7 补充：prompt history `LogEntry` 读取现在接受 `sessionID`/`session`/`
 
 本轮补充：remote history 普通事件数组现在也会解包元素级 `event`/`record`/`entry`/`item`/`resource`/`value` 以及无事件本体字段时的 `data`/`payload`/`body` wrapper，并用元素 `cursor` 作为事件 ID fallback，覆盖非 GraphQL edges 的 wrapper item 响应。
 
+本轮补充：remote history 普通事件数组现在也接受 JSON:API/resource-style 元素，事件 payload 可放在 `attributes` 或 `properties` 里，并使用外层 resource `id` 作为 SDK event ID fallback。
+
 本轮补充：remote history event-list 字段现在接受 keyed event map，例如 `events: {"evt_1": {...}}`，会按 key 稳定排序并在事件缺 ID 时用 map key 作为 fallback event ID。
 
 本轮补充：contract content block `type` 解码现在会归一化 `toolUse`/`tool-result`/`cacheEdits`/`inputImage`/`chain-of-thought` 等 camel/kebab/compact 别名，transcript resume 可保留为规范 block type。

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

@@ -200,6 +200,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：remote history pagination 现在也接受 `previousPageToken`/`prevPageToken`/`olderPageToken`、`previousToken`/`prevToken`/`olderToken` 及 snake_case 形式，响应字段、link object 和 link URL query 参数都会归一到续抓 before-id。
 - 本轮补充：remote history pagination 现在也接受相邻 before-cursor aliases，包括 `before`、`beforeID`、`olderThan`、`endingBefore` 和 `untilId`，响应字段、link object 和 link URL query 参数都会归一到续抓 before-id。
 - 本轮补充：remote history pagination 现在也接受 OData next-link 字段 `@odata.nextLink`、`odata.nextLink` 和 `__next`，并从 `$skiptoken`/`skipToken` link query 参数提取续抓 cursor。
+- 本轮补充：remote history 普通事件数组现在也接受 JSON:API/resource-style 元素，事件 payload 可放在 `attributes` 或 `properties` 里，并使用外层 resource `id` 作为 SDK event ID fallback。
 - 本轮补充：remote history fetch 把 HTTP 204 和 200 空 body 视为空的终止页，避免空历史响应被标成 incomplete 或触发 JSON EOF。
 - 本轮补充：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`、`data.viewer.session.events`、`data.node.eventConnection`、`conversation`、`remoteHistory`、`_embedded` 等 GraphQL/session/HAL wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。

docs/first-second-parity-audit.md

@@ -347,6 +347,7 @@ M7 progress now includes:
 - `internal/tui`: interaction script loading now recurses through outer API/fixture wrappers such as `data`/`payload`/`body`/`result`/`response`/`recording`/`session`/`run`.
 - `internal/contracts`/`internal/session`: remote history `SDKEvent` message extraction now recurses through nested payload wrappers such as `record`/`entry`/`item`/`event`/`result`/`response`/`output`.
 - `internal/session`: remote-history event arrays now unwrap element-level wrappers such as `event`/`record`/`entry`/`item`/`resource`/`value` and wrapper-only `data`/`payload`/`body`, using element cursors as event ID fallback outside GraphQL edges.
+- `internal/session`: remote-history event arrays now accept JSON:API/resource-style elements with event payloads inside `attributes` or `properties`, preserving the outer resource `id` as the SDK event ID fallback.
 - `internal/contracts`/`internal/session`: content block `type` decoding now normalizes camel/kebab/compact aliases such as `toolUse`, `tool-result`, `cacheEdits`, `inputImage`, and `chain-of-thought`.
 - `internal/session`: image history dimensions now default display size to original size when only `width`/`height` or original dimensions are present, preserving source metadata for single-size image fixtures.
 - `internal/session`: pasted-content history type decoding now normalizes aliases such as `inputImage`/`pasted-image`/`input_text`/`pasted-text` to canonical `image`/`text` for runtime and stored history.

internal/session/remote_history.go

@@ -742,11 +742,13 @@ func decodeRemoteHistoryEventElement(name string, index int, data json.RawMessag
 		return contracts.SDKEvent{}, nil
 	}
 	cursor := ""
+	resourceID := ""
 	rawEvent := data
 	if data[0] == '{' {
 		var fields map[string]json.RawMessage
 		if err := json.Unmarshal(data, &fields); err == nil {
 			cursor = remoteHistoryStringField(fields, "cursor")
+			resourceID = remoteHistoryStringField(fields, "id", "event_id", "eventId", "uuid")
 			if nested := remoteHistoryWrappedEventRaw(fields); nested != nil {
 				rawEvent = nested
 			}
@@ -757,16 +759,21 @@ func decodeRemoteHistoryEventElement(name string, index int, data json.RawMessag
 		return contracts.SDKEvent{}, fmt.Errorf("%s[%d]: %w", name, index, err)
 	}
 	if event.ID == "" {
-		event.ID = contracts.ID(cursor)
+		event.ID = contracts.ID(firstNonEmpty(resourceID, cursor))
 	}
 	return event, nil
 }
 
 func remoteHistoryWrappedEventRaw(fields map[string]json.RawMessage) json.RawMessage {
+	if remoteHistoryRecognizedEventType(fields) == "" {
+		if nested := firstObjectRawField(fields, "attributes", "properties"); nested != nil {
+			return nested
+		}
+	}
 	if remoteHistoryHasDirectEventFields(fields) {
 		return nil
 	}
-	return firstObjectRawField(fields, "node", "event", "record", "entry", "item", "resource", "value", "data", "payload", "body", "result", "response", "output")
+	return firstObjectRawField(fields, "node", "event", "record", "entry", "item", "resource", "value", "attributes", "properties", "data", "payload", "body", "result", "response", "output")
 }
 
 func remoteHistoryHasDirectEventFields(fields map[string]json.RawMessage) bool {

internal/session/remote_history_test.go

@@ -888,6 +888,54 @@ func TestFetchRemoteHistoryAcceptsWrappedEventArrayItems(t *testing.T) {
 	}
 }
 
+func TestFetchRemoteHistoryAcceptsResourceAttributeEvents(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(`{
+				"data": [
+					{"id":"evt_attr_1","type":"session-events","attributes":{"eventType":"status","sessionID":"s","status":"latest"}},
+					{"id":"evt_attr_2","type":"session-events","attributes":{"event_type":"assistant","session_id":"s","parentMessageID":"evt_attr_1","createdAt":"2026-01-01T00:00:02Z","message":{"type":"assistant","content":[{"type":"text","text":"hello"}]}}}
+				],
+				"links": {"prev": "/v1/sessions/s/events?before_id=evt_attr_2"}
+			}`))
+		case "evt_attr_2":
+			_, _ = w.Write([]byte(`{
+				"data": [
+					{"id":"evt_attr_3","type":"session-events","properties":{"role":"user","sessionId":"s","createdAt":"2026-01-01T00:00:03Z","message":{"type":"user","content":[{"type":"text","text":"older"}]}}}
+				]
+			}`))
+		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 != 2 || len(events.Events) != 3 || events.NextBeforeID != "" {
+		t.Fatalf("events = %#v", events)
+	}
+	if events.Events[0].ID != "evt_attr_1" || events.Events[0].Status != "latest" || events.Events[0].SessionID != "s" {
+		t.Fatalf("status resource event = %#v", events.Events[0])
+	}
+	if events.Events[1].ID != "evt_attr_2" || events.Events[1].Type != contracts.SDKEventAssistant || events.Events[1].Message == nil || len(events.Events[1].Message.Content) != 1 || events.Events[1].Message.Content[0].Text != "hello" {
+		t.Fatalf("assistant resource event = %#v", events.Events[1])
+	}
+	if events.Events[2].ID != "evt_attr_3" || events.Events[2].Type != contracts.SDKEventUser || events.Events[2].Message == nil || len(events.Events[2].Message.Content) != 1 || events.Events[2].Message.Content[0].Text != "older" {
+		t.Fatalf("properties resource event = %#v", events.Events[2])
+	}
+	if len(seen) != 2 || seen[1].Get("before_id") != "evt_attr_2" {
+		t.Fatalf("queries = %#v", seen)
+	}
+}
+
 func TestFetchRemoteHistoryAcceptsKeyedEventMaps(t *testing.T) {
 	var seen []url.Values
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {