dont apply updates if y-indexeddb is already destroyed - replaces #27 …

…- related to #25
yjs · Mar 30, 2023 · 9a9112b · 9a9112b
1 parent 217fd6d
commit 9a9112b
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/y-indexeddb.js b/src/y-indexeddb.js
@@ -14,10 +14,12 @@ export const PREFERRED_TRIM_SIZE = 500
 export const fetchUpdates = (idbPersistence, beforeApplyUpdatesCallback = () => {}) => {
   const [updatesStore] = idb.transact(/** @type {IDBDatabase} */ (idbPersistence.db), [updatesStoreName]) // , 'readonly')
   return idb.getAll(updatesStore, idb.createIDBKeyRangeLowerBound(idbPersistence._dbref, false)).then(updates => {
-    beforeApplyUpdatesCallback(updatesStore)
-    Y.transact(idbPersistence.doc, () => {
-      updates.forEach(val => Y.applyUpdate(idbPersistence.doc, val))
-    }, idbPersistence, false)
+    if (!idbPersistence._destroyed) {
+      beforeApplyUpdatesCallback(updatesStore)
+      Y.transact(idbPersistence.doc, () => {
+        updates.forEach(val => Y.applyUpdate(idbPersistence.doc, val))
+      }, idbPersistence, false)
+    }
   })
     .then(() => idb.getLastKey(updatesStore).then(lastKey => { idbPersistence._dbref = lastKey + 1 }))
     .then(() => idb.count(updatesStore).then(cnt => { idbPersistence._dbsize = cnt }))