preliminary auto-login

mobile-v2/lib/domain/services/sync.service.dart

@@ -1,4 +1,5 @@
-import 'package:drift/isolate.dart';
+import 'dart:async';
+
 import 'package:immich_mobile/domain/interfaces/asset.interface.dart';
 import 'package:immich_mobile/domain/models/asset.model.dart';
 import 'package:immich_mobile/domain/models/user.model.dart';
@@ -12,56 +13,51 @@ import 'package:logging/logging.dart';
 import 'package:openapi/api.dart';
 
 class SyncService with LogContext {
-  final DriftDatabaseRepository _db;
-
-  SyncService(this._db);
+  SyncService();
 
   Future<bool> doFullSyncForUserDrift(
     User user, {
     DateTime? updatedUtil,
     int? limit,
   }) async {
-    final helper = IsolateHelper()..preIsolateHandling();
-    try {
-      await _db.computeWithDatabase(
-        connect: (connection) => DriftDatabaseRepository(connection),
-        computation: (database) async {
-          helper.postIsolateHandling(database: database);
-          final logger = Logger("SyncService <Isolate>");
-          final syncClient = di<ImmichApiClient>().getSyncApi();
+    return await IsolateHelper.run(() async {
+      try {
+        final logger = Logger("SyncService <Isolate>");
+        final syncClient = di<ImmichApiClient>().getSyncApi();
 
-          final chunkSize = limit ?? kFullSyncChunkSize;
-          final updatedTill = updatedUtil ?? DateTime.now().toUtc();
-          updatedUtil ??= DateTime.now().toUtc();
-          String? lastAssetId;
+        final chunkSize = limit ?? kFullSyncChunkSize;
+        final updatedTill = updatedUtil ?? DateTime.now().toUtc();
+        updatedUtil ??= DateTime.now().toUtc();
+        String? lastAssetId;
 
-          while (true) {
-            logger.info(
-              "Requesting more chunks from lastId - ${lastAssetId ?? "<initial_fetch>"}",
-            );
+        while (true) {
+          logger.info(
+            "Requesting more chunks from lastId - ${lastAssetId ?? "<initial_fetch>"}",
+          );
 
-            final assets = await syncClient.getFullSyncForUser(AssetFullSyncDto(
-              limit: chunkSize,
-              updatedUntil: updatedTill,
-              lastId: lastAssetId,
-              userId: user.id,
-            ));
-            if (assets == null) {
-              break;
-            }
-
-            await di<IAssetRepository>().addAll(assets.map(Asset.remote));
-
-            lastAssetId = assets.lastOrNull?.id;
-            if (assets.length != chunkSize) break;
+          final assets = await syncClient.getFullSyncForUser(AssetFullSyncDto(
+            limit: chunkSize,
+            updatedUntil: updatedTill,
+            lastId: lastAssetId,
+            userId: user.id,
+          ));
+          if (assets == null) {
+            break;
           }
 
-          return true;
-        },
-      );
-    } catch (e, s) {
-      log.severe("Error performing full sync for user - ${user.name}", e, s);
-    }
-    return false;
+          await di<IAssetRepository>().addAll(assets.map(Asset.remote));
+
+          lastAssetId = assets.lastOrNull?.id;
+          if (assets.length != chunkSize) break;
+        }
+
+        return true;
+      } catch (e, s) {
+        log.severe("Error performing full sync for user - ${user.name}", e, s);
+      } finally {
+        await di<DriftDatabaseRepository>().close();
+      }
+      return false;
+    });
   }
 }