fix: prune stale assets

Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>

.github/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

cli/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

cli/package.json

@@ -68,6 +68,6 @@
     "micromatch": "^4.0.8"
   },
   "volta": {
-    "node": "22.19.0"
+    "node": "22.20.0"
   }
 }

docs/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

docs/package.json

@@ -57,6 +57,6 @@
     "node": ">=20"
   },
   "volta": {
-    "node": "22.19.0"
+    "node": "22.20.0"
   }
 }

e2e/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

e2e/package.json

@@ -52,6 +52,6 @@
     "vitest": "^3.0.0"
   },
   "volta": {
-    "node": "22.19.0"
+    "node": "22.20.0"
   }
 }

mise.toml

@@ -1,5 +1,5 @@
 [tools]
-node = "22.19.0"
+node = "22.20.0"
 flutter = "3.35.4"
 pnpm = "10.15.1"
 

mobile/lib/domain/services/sync_stream.service.dart

@@ -130,9 +130,9 @@ class SyncStreamService {
       // to acknowledge that the client has processed all the backfill events
       case SyncEntityType.syncAckV1:
         return;
-      // No-op. SyncCompleteV1 is used to signal the completion of the sync process
+      // SyncCompleteV1 is used to signal the completion of the sync process. Cleanup stale assets and signal completion
       case SyncEntityType.syncCompleteV1:
-        return;
+        return _syncStreamRepository.pruneAssets();
       // Request to reset the client state. Clear everything related to remote entities
       case SyncEntityType.syncResetV1:
         return _syncStreamRepository.reset();

mobile/lib/infrastructure/repositories/sync_stream.repository.dart

@@ -591,6 +591,40 @@ class SyncStreamRepository extends DriftDatabaseRepository {
       rethrow;
     }
   }
+
+  Future<void> pruneAssets() async {
+    try {
+      await _db.transaction(() async {
+        final authQuery = _db.authUserEntity.selectOnly()
+          ..addColumns([_db.authUserEntity.id])
+          ..limit(1);
+        final currentUserId = await authQuery.map((row) => row.read(_db.authUserEntity.id)).getSingleOrNull();
+        if (currentUserId == null) {
+          _logger.warning('No authenticated user found during pruneAssets. Skipping asset pruning.');
+          return;
+        }
+
+        final partnerQuery = _db.partnerEntity.selectOnly()
+          ..addColumns([_db.partnerEntity.sharedById])
+          ..where(_db.partnerEntity.sharedWithId.equals(currentUserId));
+        final partnerIds = await partnerQuery.map((row) => row.read(_db.partnerEntity.sharedById)).get();
+
+        final validUsers = {currentUserId, ...partnerIds.nonNulls};
+
+        // Asset is not owned by the current user or any of their partners and is not part of any (shared) album
+        // Likely a stale asset that was previously shared but has been removed
+        await _db.remoteAssetEntity.deleteWhere((asset) {
+          return asset.ownerId.isNotIn(validUsers) &
+              asset.id.isNotInQuery(
+                _db.remoteAlbumAssetEntity.selectOnly()..addColumns([_db.remoteAlbumAssetEntity.assetId]),
+              );
+        });
+      });
+    } catch (error, stack) {
+      _logger.severe('Error: pruneAssets', error, stack);
+      // We do not rethrow here as this is a client-only cleanup and should not affect the sync process
+    }
+  }
 }
 
 extension on AssetTypeEnum {

open-api/typescript-sdk/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

open-api/typescript-sdk/package.json

@@ -28,6 +28,6 @@
     "directory": "open-api/typescript-sdk"
   },
   "volta": {
-    "node": "22.19.0"
+    "node": "22.20.0"
   }
 }

server/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

server/package.json

@@ -161,7 +161,7 @@
     "vitest": "^3.0.0"
   },
   "volta": {
-    "node": "22.19.0"
+    "node": "22.20.0"
   },
   "overrides": {
     "sharp": "^0.34.3"

web/.nvmrc

@@ -1 +1 @@
-22.19.0
+22.20.0

web/package.json

@@ -107,6 +107,6 @@
     "vitest": "^3.0.0"
   },
   "volta": {
-    "node": "22.19.0"
+    "node": "22.20.0"
   }
 }