luulam/AFFiNE
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
EYHN
2025-02-24 10:22:33 +00:00
parent 378bb3795d
commit 59a791fe1f
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/common/nbstore/src/sync/doc/peer.ts
View File

@@ -680,6 +680,7 @@ export class DocSyncPeer {
const cachedClocks = await this.syncMetadata.getPeerRemoteClocks( const cachedClocks = await this.syncMetadata.getPeerRemoteClocks(
this.peerId this.peerId
); );
this.status.remoteClocks.clear();
throwIfAborted(signal); throwIfAborted(signal);
for (const [id, v] of Object.entries(cachedClocks)) { for (const [id, v] of Object.entries(cachedClocks)) {
this.status.remoteClocks.set(id, v); this.status.remoteClocks.set(id, v);
@@ -690,8 +691,9 @@ export class DocSyncPeer {
const maxClockValue = this.status.remoteClocks.max; const maxClockValue = this.status.remoteClocks.max;
const newClocks = await this.remote.getDocTimestamps(maxClockValue); const newClocks = await this.remote.getDocTimestamps(maxClockValue);
for (const [id, v] of Object.entries(newClocks)) { 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)) { for (const [id, v] of Object.entries(newClocks)) {
await this.syncMetadata.setPeerRemoteClock(this.peerId, { await this.syncMetadata.setPeerRemoteClock(this.peerId, {