misc fixes

Author: shenlong-tanwen

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

@@ -9,6 +9,15 @@ import 'package:logging/logging.dart';
 import 'package:openapi/api.dart';
 import 'package:worker_manager/worker_manager.dart';
 
+const _kSyncTypeOrder = [
+  SyncEntityType.userV1,
+  SyncEntityType.partnerV1,
+  SyncEntityType.assetV1,
+  SyncEntityType.assetExifV1,
+  SyncEntityType.partnerAssetV1,
+  SyncEntityType.partnerAssetExifV1,
+];
+
 class SyncStreamService {
   final Logger _logger = Logger('SyncStreamService');
 
@@ -102,7 +111,12 @@ class SyncStreamService {
             final eventsMap = events.groupListsBy((event) => event.type);
             final Map<SyncEntityType, String> acks = {};
 
-            for (final entry in eventsMap.entries) {
+            for (final type in _kSyncTypeOrder) {
+              final data = eventsMap[type];
+              if (data == null) {
+                continue;
+              }
+
               if (_cancelChecker?.call() ?? false) {
                 _logger.info("Sync cancelled, stopping stream");
                 mutex?.complete();
@@ -117,9 +131,6 @@ class SyncStreamService {
                 return;
               }
 
-              final type = entry.key;
-              final data = entry.value;
-
               if (data.isEmpty) {
                 _logger.warning("Received empty sync events for $type");
                 continue;

mobile/lib/domain/utils/background_sync.dart

@@ -11,9 +11,14 @@ class BackgroundSyncManager {
 
   BackgroundSyncManager();
 
-  void cancel() {
+  Future<void> cancel() {
+    final futures = <Future>[];
+    if (_userSyncTask != null) {
+      futures.add(_userSyncTask!.future);
+    }
     _userSyncTask?.cancel();
     _userSyncTask = null;
+    return Future.wait(futures);
   }
 
   Future<void> syncUsers() async {

mobile/lib/services/auth.service.dart

@@ -120,9 +120,10 @@ class AuthService {
   /// - Asset ETag
   ///
   /// All deletions are executed in parallel using [Future.wait].
-  Future<void> clearLocalData() {
-    _backgroundSyncManager.cancel();
-    return Future.wait([
+  Future<void> clearLocalData() async {
+    // Cancel any ongoing background sync operations before clearing data
+    await _backgroundSyncManager.cancel();
+    await Future.wait([
       _authRepository.clearLocalData(),
       Store.delete(StoreKey.currentUser),
       Store.delete(StoreKey.accessToken),