From ca633d930260ddaa7d34be84e57d2301e8c8cf4e Mon Sep 17 00:00:00 2001 From: Claude Date: Thu, 4 Jun 2026 10:14:20 +0000 Subject: [PATCH] agent: fix UpsertPeerSyncState call broken by the #80/#87 merge MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit main stopped compiling (agent test package) once #76 (PR #80) and #77 (PR #87) both landed: #87 added the allowRewind parameter to UpsertPeerSyncState and updated every call site it could see, but #76 introduced agent/sync_test.go on a branch #87 never contained, so its call kept the old 4-arg signature. Git merged both cleanly (different files), but the integrated result doesn't build. Pass false (a first-contact watermark seed — no prior value to rewind from). https://claude.ai/code/session_01GV1qgPE2YcUnuoLvy566kj --- agent/sync_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/agent/sync_test.go b/agent/sync_test.go index 23a920d..9f01dcd 100644 --- a/agent/sync_test.go +++ b/agent/sync_test.go @@ -64,7 +64,7 @@ func newPreStageFixture(t *testing.T) *preStageFixture { } // Watermark at/above the prior run's correlated id so the supersede // branch of dispositionForExisting fires for peer-sourced rows. - if err := srv.store.UpsertPeerSyncState(ctx, v.ID, peer.ID, correlated); err != nil { + if err := srv.store.UpsertPeerSyncState(ctx, v.ID, peer.ID, correlated, false); err != nil { t.Fatalf("UpsertPeerSyncState: %v", err) } recvRun, err := srv.store.BeginPeerSyncRun(ctx, v.ID, peer.ID, correlated+1, "peerA")