fix: lost synchronization after socket reconnection

teableio · Sep 4, 2024 · 6b26ecc · 6b26ecc
1 parent f0c9bd8
commit 6b26ecc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/packages/sdk/src/context/use-instances/opListener.ts b/packages/sdk/src/context/use-instances/opListener.ts
@@ -10,7 +10,7 @@ export class OpListenersManager<T> {
 
   add(doc: Doc<T>, handler: (op: unknown[]) => void) {
     if (this.opListeners.has(doc.id)) {
-      this.remove(doc);
+      return;
     }
     doc.on('op batch', handler);
     this.opListeners.set(doc.id, () => {

diff --git a/packages/sdk/src/context/use-instances/useInstances.ts b/packages/sdk/src/context/use-instances/useInstances.ts
@@ -24,7 +24,7 @@ const queryDestroy = (query: Query | undefined, cb?: () => void) => {
   query.once('ready', () => {
     query.destroy(() => {
       query.removeAllListeners();
-      query.results?.forEach((doc) => doc.listenerCount('op') === 0 && doc.destroy());
+      query.results?.forEach((doc) => doc.listenerCount('op batch') === 0 && doc.destroy());
       cb?.();
     });
   });