Accept remote history pagination token aliases

Author: SqlRush

docs/cc-100-roadmap.md

@@ -68,6 +68,8 @@ M6 补充：remote history pagination bool 字段现在除 JSON bool 和 `true`/
 
 M6 补充：remote history pagination cursor/id 字段现在接受 JSON number 并原样转成字符串，覆盖 `next_cursor` 等 page 字段和 `edges[].cursor` 的数字形态。
 
+M6 补充：remote history pagination 现在接受 `nextPageToken`/`nextToken`/`pageToken`/`continuationToken` 及 snake_case 形式，响应字段和 link URL query 参数都会归一到续抓 before-id。
+
 M6 补充：contract `ID` JSON 读取现在接受 JSON number/null，remote history event/message/session/parent ID alias 可继承数字 ID 兼容面并在 transcript materialization 中保留为字符串。
 
 M6 补充：remote history response parser 现在会递归解包 `data.session.events`、`data.projectSession.eventConnection`、`conversation`、`remoteHistory` 等 GraphQL/session wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。

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

@@ -193,6 +193,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：remote history connection/pageInfo 解析接受 `hasPrevious`/`hasPreviousPage`、`hasOlder`/`more` 继续分页标记，以及 `previousCursor`/`prevCursor`/`beforeCursor`/`olderCursor` before-id cursor 别名，覆盖 GraphQL 向更旧事件翻页的响应形态。
 - 本轮补充：remote history pagination bool 字段除 JSON bool 和 `true`/`false` 字符串外，也接受 `1`/`0`、`yes`/`no`、`on`/`off` 等数值/字符串布尔形态，避免 wrapper/pageInfo 中的非严格布尔值中断分页。
 - 本轮补充：remote history pagination cursor/id 字段现在接受 JSON number 并原样转成字符串，覆盖 `next_cursor` 等 page 字段和 `edges[].cursor` 的数字形态。
+- 本轮补充：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` 等 GraphQL/session wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。
 - 本轮补充：transcript resume 的嵌套 content block 接受 `toolUseId`/`toolUseID`、`isError`、`cacheControl`、`cacheReference` 字段别名，并保留 cache edit 的 `cacheReference`。

docs/first-second-parity-audit.md

@@ -147,6 +147,7 @@ M6 progress now includes:
 - `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 pagination now accepts token aliases such as `nextPageToken`, `nextToken`, `pageToken`, and `continuationToken` in response fields and link query parameters.
 - `internal/contracts`: ID JSON decoding now accepts JSON numbers/null so remote-history event, message, session, and parent ID aliases can preserve numeric IDs as strings during transcript materialization.
 - `internal/session`: remote-history response parsing now recursively unwraps GraphQL/session containers such as `data.session.events`, `data.projectSession.eventConnection`, `conversation`, and `remoteHistory` before applying `nodes`/`edges[].node` event-list and `pageInfo` pagination parsing.
 - `internal/session`: remote-history link pagination now accepts `links.next`/`links.previous`/`links.prev`/`links.older` string URLs or `{href,url,uri,link}` objects and extracts before/cursor query parameters for continuation.

internal/session/remote_history.go

@@ -239,6 +239,14 @@ func (r *sessionEventsResponse) mergeScalarFields(raw map[string]json.RawMessage
 		{name: "nextBeforeId", target: &r.NextBeforeIDCamel},
 		{name: "next_cursor", target: &r.NextCursor},
 		{name: "nextCursor", target: &r.NextCursorCamel},
+		{name: "next_page_token", target: &r.NextCursor},
+		{name: "nextPageToken", target: &r.NextCursorCamel},
+		{name: "next_token", target: &r.NextCursor},
+		{name: "nextToken", target: &r.NextCursorCamel},
+		{name: "page_token", target: &r.Cursor},
+		{name: "pageToken", target: &r.CursorCamel},
+		{name: "continuation_token", target: &r.Cursor},
+		{name: "continuationToken", target: &r.CursorCamel},
 		{name: "end_cursor", target: &r.EndCursor},
 		{name: "endCursor", target: &r.EndCursorCamel},
 		{name: "start_cursor", target: &r.StartCursor},
@@ -927,6 +935,14 @@ func remoteHistoryLinkCursor(link string) string {
 			query.Get("nextBeforeId"),
 			query.Get("cursor"),
 			query.Get("pageCursor"),
+			query.Get("next_page_token"),
+			query.Get("nextPageToken"),
+			query.Get("next_token"),
+			query.Get("nextToken"),
+			query.Get("page_token"),
+			query.Get("pageToken"),
+			query.Get("continuation_token"),
+			query.Get("continuationToken"),
 			query.Get("previous_cursor"),
 			query.Get("previousCursor"),
 			query.Get("prev_cursor"),

internal/session/remote_history_test.go

@@ -266,6 +266,40 @@ func TestFetchRemoteHistoryAcceptsNumericCursorFields(t *testing.T) {
 	}
 }
 
+func TestFetchRemoteHistoryAcceptsPaginationTokenAliases(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":[{"type":"status","session_id":"s","status":"latest"}],"hasNext":true,"nextPageToken":"evt_token"}`))
+		case "evt_token":
+			_, _ = w.Write([]byte(`{"data":[{"type":"status","session_id":"s","status":"older"}],"links":{"older":"/v1/sessions/s/events?continuationToken=evt_continuation"}}`))
+		case "evt_continuation":
+			_, _ = w.Write([]byte(`{"data":[{"type":"status","session_id":"s","status":"oldest"}],"has_more":false,"pageToken":"ignored_when_complete"}`))
+		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].Status != "latest" || events.Events[1].Status != "older" || events.Events[2].Status != "oldest" {
+		t.Fatalf("events = %#v", events.Events)
+	}
+	if len(seen) != 3 || seen[1].Get("before_id") != "evt_token" || seen[2].Get("before_id") != "evt_continuation" {
+		t.Fatalf("queries = %#v", seen)
+	}
+}
+
 func TestFetchRemoteHistoryAcceptsWrappedDataPageFields(t *testing.T) {
 	var seen []url.Values
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {