test(drive): cover paginated push reconciliation

xapids · xapids · commit e69828a9bf9f · 2026-07-16T15:37:08.000+02:00
diff --git a/internal/cmd/drive_sync_test.go b/internal/cmd/drive_sync_test.go
@@ -228,6 +228,49 @@ func TestDriveSyncPushRejectsSymlinksBeforeAuthentication(t *testing.T) {
 	}
 }
 
+func TestDriveSyncPushFindsExistingFileOnLaterPage(t *testing.T) {
+	root := t.TempDir()
+	if err := os.WriteFile(filepath.Join(root, "session.jsonl"), []byte("same"), 0o600); err != nil {
+		t.Fatal(err)
+	}
+
+	mutations := 0
+	pages := 0
+	svc, closeServer := newDriveTestService(t, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		switch {
+		case r.Method == http.MethodGet && strings.HasSuffix(r.URL.Path, "/files/destination"):
+			_ = json.NewEncoder(w).Encode(map[string]any{"id": "destination", "mimeType": driveMimeFolder})
+		case r.Method == http.MethodGet && strings.HasSuffix(r.URL.Path, "/files"):
+			requireSupportsAllDrives(t, r)
+			pages++
+			if r.URL.Query().Get("pageToken") == "page-2" {
+				_ = json.NewEncoder(w).Encode(map[string]any{"files": []map[string]any{
+					{"id": "session-id", "name": "session.jsonl", "mimeType": "application/json", "size": "4", "md5Checksum": "51037a4a37730f52c8732586d3aaa316"},
+				}})
+				return
+			}
+			_ = json.NewEncoder(w).Encode(map[string]any{"files": []any{}, "nextPageToken": "page-2"})
+		default:
+			mutations++
+			http.Error(w, "unexpected mutation", http.StatusInternalServerError)
+		}
+	}))
+	defer closeServer()
+
+	result := executeWithDriveTestService(t, []string{
+		"--json", "--account", "a@b.com", "drive", "sync", "push", root, "--parent", "destination",
+	}, svc)
+	if result.err != nil {
+		t.Fatalf("drive sync push: %v", result.err)
+	}
+	if pages != 2 || mutations != 0 {
+		t.Fatalf("expected two read pages and no mutations, pages=%d mutations=%d", pages, mutations)
+	}
+	if !strings.Contains(result.stdout, `"skipped": 1`) {
+		t.Fatalf("unexpected result: %s", result.stdout)
+	}
+}
+
 func TestDriveSyncPushStressPlansLargeTreeDeterministically(t *testing.T) {
 	root := t.TempDir()
 	const folders = 20
