Accept empty remote history pages

Author: SqlRush

docs/cc-100-roadmap.md

@@ -72,6 +72,8 @@ M6 补充：remote history pagination 现在接受 `nextPageToken`/`nextToken`/`
 
 M6 补充：remote history pagination 现在也接受 OData next-link 字段 `@odata.nextLink`、`odata.nextLink` 和 `__next`，并从 `$skiptoken`/`skipToken` link query 参数提取续抓 cursor。
 
+M6 补充：remote history fetch 现在把 HTTP 204 和 200 空 body 视为空的终止页，避免空历史响应被标成 incomplete 或触发 JSON EOF。
+
 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`、`_embedded` 等 GraphQL/session/HAL wrapper，继续复用 `nodes`/`edges[].node` 和 `pageInfo` pagination 解析。

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

@@ -195,6 +195,7 @@ test/parity/                 # golden tests against TS/official behavior
 - 本轮补充：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。
 - 本轮补充：remote history pagination 现在也接受 OData next-link 字段 `@odata.nextLink`、`odata.nextLink` 和 `__next`，并从 `$skiptoken`/`skipToken` link query 参数提取续抓 cursor。
+- 本轮补充：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`、`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 风格响应。

docs/first-second-parity-audit.md

@@ -151,6 +151,7 @@ M6 progress now includes:
 - `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/session`: remote-history pagination now also accepts OData next-link fields such as `@odata.nextLink`, `odata.nextLink`, and `__next`, extracting `$skiptoken`/`skipToken` link query values as continuation cursors.
+- `internal/session`: remote-history fetch now treats HTTP 204 and 200 responses with empty bodies as empty terminal pages instead of incomplete fetches or JSON EOF errors.
 - `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/HAL containers such as `data.session.events`, `data.projectSession.eventConnection`, `conversation`, `remoteHistory`, and `_embedded` before applying `nodes`/`edges[].node` event-list and `pageInfo` pagination parsing.
 - `internal/session`: remote-history link pagination now accepts `links`/`_links` `next`/`previous`/`prev`/`older` string URLs or `{href,url,uri,link}` objects and extracts before/cursor query parameters for continuation.

internal/session/remote_history.go

@@ -5,6 +5,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"io"
 	"net/http"
 	"net/url"
 	"strconv"
@@ -857,11 +858,17 @@ func fetchRemoteHistoryPageStatus(ctx context.Context, client *http.Client, auth
 		return nil, 0, nil
 	}
 	defer resp.Body.Close()
+	if resp.StatusCode == http.StatusNoContent {
+		return &RemoteHistoryPage{Events: []contracts.SDKEvent{}}, resp.StatusCode, nil
+	}
 	if resp.StatusCode != http.StatusOK {
 		return nil, resp.StatusCode, nil
 	}
 	var decoded sessionEventsResponse
 	if err := json.NewDecoder(resp.Body).Decode(&decoded); err != nil {
+		if err == io.EOF {
+			return &RemoteHistoryPage{Events: []contracts.SDKEvent{}}, resp.StatusCode, nil
+		}
 		return nil, resp.StatusCode, err
 	}
 	events := responseEventList(decoded)

internal/session/remote_history_test.go

@@ -108,6 +108,36 @@ func TestFetchRemoteHistoryNonOKReturnsNil(t *testing.T) {
 	}
 }
 
+func TestFetchRemoteHistoryAcceptsEmptyTerminalPages(t *testing.T) {
+	for _, tc := range []struct {
+		name  string
+		serve func(http.ResponseWriter)
+	}{
+		{name: "no-content", serve: func(w http.ResponseWriter) {
+			w.WriteHeader(http.StatusNoContent)
+		}},
+		{name: "empty-ok", serve: func(w http.ResponseWriter) {
+			w.Header().Set("Content-Type", "application/json")
+		}},
+	} {
+		t.Run(tc.name, func(t *testing.T) {
+			server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+				tc.serve(w)
+			}))
+			defer server.Close()
+
+			authCtx := NewRemoteHistoryAuthContext("s", "", "", auth.OAuthConfig{BaseAPIURL: server.URL})
+			events, err := FetchRemoteHistory(context.Background(), server.Client(), authCtx, RemoteHistoryFetchOptions{Limit: 1})
+			if err != nil {
+				t.Fatal(err)
+			}
+			if !events.Complete || events.Pages != 1 || len(events.Events) != 0 || events.NextBeforeID != "" {
+				t.Fatalf("events = %#v", events)
+			}
+		})
+	}
+}
+
 func TestFetchRemoteHistoryRefreshesTokenOnUnauthorized(t *testing.T) {
 	var tokens []string
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {