Accept remote history single event pages

Author: SqlRush

docs/cc-100-roadmap.md

@@ -88,6 +88,8 @@ M6 补充：remote history event-list 现在接受 `value`/`values`/`resources`/
 
 M6 补充：remote history response parser 现在会解包 `payload`/`response`/`result`/`body` 等通用响应外壳，外壳内的 event list、pagination、links 会继续递归解析。
 
+M6 补充：remote history `data`/`payload`/`response`/`result`/`body` 等 event-list 字段现在也接受单个 SDK event 对象，避免非数组单事件页被当作普通 wrapper 后丢失。
+
 M6 补充：remote history `SDKEvent` 本体现在接受 `eventType`/`event_type`/`role` 类型别名、`createdAt`/`created_at` 时间戳别名，以及 `payload`/`data`/`body`/`serializedMessage` message payload 别名；payload 只有 `role`/`content` 时也能 materialize 成 transcript message。
 
 M6 补充：remote history REST/link 风格分页现在接受 `links`/`_links` 的 `next`/`previous`/`prev`/`older` 字符串 URL、`{href,url,uri,link}` 对象，或直接携带 `cursor`/`beforeId`/`lastEvaluatedKey` 等 cursor 字段的 link object，并从 `before_id`、`beforeId`、`cursor`、`pageCursor`、`previousCursor`、`prevCursor`、`beforeCursor`、`olderCursor`、`startCursor`、`endCursor` 等 query 参数提取下一页 before-id。
@@ -390,6 +392,8 @@ M7 补充：prompt history `LogEntry` 读取现在接受 `sessionID`/`session`/`
 
 本轮补充：remote history response parser 会递归解包 `data.session.events`、`data.projectSession.eventConnection`、`conversation`、`remoteHistory` 等 GraphQL/session wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。
 
+本轮补充：remote history event-list 字段现在可直接承载单个 SDK event 对象；`data`/`result` 等字段不再必须是数组或 wrapper 才能进入分页结果。
+
 本轮补充：remote history REST/link 风格分页接受 `links.next`/`links.previous`/`links.prev`/`links.older` 的字符串 URL、`{href,url,uri,link}` 对象，或直接携带 cursor 字段的 link object，并从 before/cursor query 参数或 direct cursor fields 提取续抓 before-id。
 
 本轮补充：remote history HTTP `Link` header 分页接受 `previous`/`prev`/`older`/`next` rel URL，并以 body cursor 优先、header cursor fallback 的方式继续抓取。

docs/first-second-parity-audit.md

@@ -149,6 +149,7 @@ M6 progress now includes:
 - `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 event-list fields such as `data` and `result` now accept a single SDK event object directly, preserving non-array single-event pages instead of treating them only as wrappers.
 - `internal/contracts`/`internal/session`: remote-history event materialization now accepts `eventType`/`event_type`/`role` type aliases, `createdAt`/`created_at` timestamp aliases, and message payload aliases such as `payload`, `data`, `body`, and `serializedMessage`, including role/content-only payloads.
 - `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.go

@@ -336,6 +336,17 @@ func (r *sessionEventsResponse) mergeEventListField(name string, target *[]contr
 		return nil
 	}
 	if data[0] == '{' {
+		var fields map[string]json.RawMessage
+		if err := json.Unmarshal(data, &fields); err == nil && remoteHistoryLooksLikeSingleEvent(fields) {
+			event, err := decodeRemoteHistoryEventElement(name, 0, data)
+			if err != nil {
+				return err
+			}
+			if *target == nil {
+				*target = []contracts.SDKEvent{event}
+			}
+			return nil
+		}
 		var nested sessionEventsResponse
 		if err := nested.mergeJSON(data); err != nil {
 			return fmt.Errorf("%s: %w", name, err)
@@ -702,6 +713,31 @@ func remoteHistoryHasDirectEventFields(fields map[string]json.RawMessage) bool {
 	return false
 }
 
+func remoteHistoryLooksLikeSingleEvent(fields map[string]json.RawMessage) bool {
+	if remoteHistoryRecognizedEventType(fields) != "" {
+		return true
+	}
+	status := remoteHistoryStringField(fields, "status")
+	if status == "" {
+		return false
+	}
+	return firstNonEmpty(
+		remoteHistoryStringField(fields, "id", "event_id", "eventId", "uuid"),
+		remoteHistoryStringField(fields, "session_id", "sessionId", "sessionID", "session_uuid", "sessionUuid", "sessionUUID"),
+		remoteHistoryStringField(fields, "timestamp", "created_at", "createdAt", "time", "datetime", "dateTime"),
+	) != ""
+}
+
+func remoteHistoryRecognizedEventType(fields map[string]json.RawMessage) string {
+	for _, name := range []string{"type", "event_type", "eventType", "event", "name", "kind", "role", "messageType", "message_type"} {
+		switch strings.ToLower(strings.TrimSpace(remoteHistoryStringField(fields, name))) {
+		case "system", "assistant", "user", "result", "error", "status":
+			return name
+		}
+	}
+	return ""
+}
+
 func firstObjectRawField(raw map[string]json.RawMessage, names ...string) json.RawMessage {
 	for _, name := range names {
 		value, ok := raw[name]

internal/session/remote_history_test.go

@@ -920,6 +920,38 @@ func TestFetchRemoteHistoryAcceptsGenericResponseWrappers(t *testing.T) {
 	}
 }
 
+func TestFetchRemoteHistoryAcceptsSingleObjectEventPages(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":{"eventType":"status","eventId":"evt_single","session_id":"s","status":"single"},"hasNext":true,"nextCursor":"evt_single"}`))
+		case "evt_single":
+			_, _ = w.Write([]byte(`{"result":{"type":"status","id":"evt_result","session_id":"s","status":"result"},"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: 2})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if !events.Complete || events.Pages != 2 || len(events.Events) != 2 || events.NextBeforeID != "" {
+		t.Fatalf("events = %#v", events)
+	}
+	if events.Events[0].ID != "evt_single" || events.Events[0].Status != "single" || events.Events[1].ID != "evt_result" || events.Events[1].Status != "result" {
+		t.Fatalf("events = %#v", events.Events)
+	}
+	if len(seen) != 2 || seen[1].Get("before_id") != "evt_single" {
+		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) {