fix: resolve SyncManager.dispose() race condition

Set isDisposed = true eagerly (before awaiting internal collection disposal) and
add isDisposed guards in collection event handlers and async continuations so
in-flight operations bail out instead of touching already-disposed collections.

Fixes #2545

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: 2 people

packages/base/core/CHANGELOG.md

@@ -7,8 +7,14 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+
 * Introduced the `transformAll` option when creating a `Collection`. This allows you to define a function that transform items after they are retrieved from persistence, enabling the integration of data from other collections or external sources (thanks @signalize!)
 
+### Fixed
+
+* Fixed a race condition in SyncManager.dispose() that could cause unhandled "Collection is disposed" errors during organization/context switches while sync operations were still in flight (thanks @shajan-journal!)
+
 ## [1.7.2] - 2026-01-07
 
 ### Changed

packages/base/sync/src/SyncManager.ts

@@ -191,6 +191,7 @@ export default class SyncManager<
    * Clears all internal data structures
    */
   public async dispose() {
+    this.isDisposed = true
     this.collections.clear()
     this.syncQueues.clear()
     this.remoteChanges.splice(0)
@@ -199,7 +200,6 @@ export default class SyncManager<
       this.snapshots.dispose(),
       this.syncOperations.dispose(),
     ])
-    this.isDisposed = true
   }
 
   /**
@@ -271,6 +271,7 @@ export default class SyncManager<
     }
 
     collection.on('added', (item) => {
+      if (this.isDisposed) return
       // skip the change if it was a remote change
       if (hasRemoteChange({ collectionName: options.name, type: 'insert', data: item })) {
         removeRemoteChanges(options.name, item.id)
@@ -287,6 +288,7 @@ export default class SyncManager<
       this.schedulePush(options.name)
     })
     collection.on('changed', ({ id }, modifier) => {
+      if (this.isDisposed) return
       const data = { id, modifier }
       // skip the change if it was a remote change
       if (hasRemoteChange({ collectionName: options.name, type: 'update', data })) {
@@ -304,6 +306,7 @@ export default class SyncManager<
       this.schedulePush(options.name)
     })
     collection.on('removed', ({ id }) => {
+      if (this.isDisposed) return
       // skip the change if it was a remote change
       if (hasRemoteChange({ collectionName: options.name, type: 'remove', data: id })) {
         removeRemoteChanges(options.name, id)
@@ -365,6 +368,7 @@ export default class SyncManager<
       ? await this.options.registerRemoteChange(
         collectionParameters.options,
         async (data) => {
+          if (this.isDisposed) return
           if (data == null) {
             await this.sync(name)
           } else {
@@ -377,6 +381,7 @@ export default class SyncManager<
             })
             await this.syncWithData(name, data)
               .then(() => {
+                if (this.isDisposed) return
                 // clean up old sync operations
                 this.syncOperations.removeMany({
                   id: { $ne: syncId },
@@ -577,6 +582,7 @@ export default class SyncManager<
     name: string,
     data: LoadResponse<ItemType>,
   ) {
+    if (this.isDisposed) return
     const { collection, options: collectionOptions } = this.getCollectionProperties(name)
 
     const syncTime = Date.now()
@@ -665,6 +671,8 @@ export default class SyncManager<
       },
     })
       .then(async (snapshot) => {
+        if (this.isDisposed) return
+
         // clean up old snapshots
         this.snapshots.removeMany({
           collectionName: name,