fix(nbstore): fix doc sync logic (#10400)

toeverything · Feb 24, 2025 · 59a791f · 59a791f
1 parent 378bb37
commit 59a791f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/common/nbstore/src/sync/doc/peer.ts b/packages/common/nbstore/src/sync/doc/peer.ts
@@ -680,6 +680,7 @@ export class DocSyncPeer {
       const cachedClocks = await this.syncMetadata.getPeerRemoteClocks(
         this.peerId
       );
+      this.status.remoteClocks.clear();
       throwIfAborted(signal);
       for (const [id, v] of Object.entries(cachedClocks)) {
         this.status.remoteClocks.set(id, v);
@@ -690,8 +691,9 @@ export class DocSyncPeer {
       const maxClockValue = this.status.remoteClocks.max;
       const newClocks = await this.remote.getDocTimestamps(maxClockValue);
       for (const [id, v] of Object.entries(newClocks)) {
-        this.actions.updateRemoteClock(id, v);
+        this.status.remoteClocks.set(id, v);
       }
+      this.statusUpdatedSubject$.next(true);
 
       for (const [id, v] of Object.entries(newClocks)) {
         await this.syncMetadata.setPeerRemoteClock(this.peerId, {