diff --git a/lib/events/sync_status_update_event.dart b/lib/events/sync_status_update_event.dart index a93132dc7..53ae728e8 100644 --- a/lib/events/sync_status_update_event.dart +++ b/lib/events/sync_status_update_event.dart @@ -30,7 +30,6 @@ enum SyncStatus { startedFirstGalleryImport, completedFirstGalleryImport, applyingRemoteDiff, - diffSynced, preparingForUpload, inProgress, paused, diff --git a/lib/services/remote_sync_service.dart b/lib/services/remote_sync_service.dart index b896953a7..7270ab52d 100644 --- a/lib/services/remote_sync_service.dart +++ b/lib/services/remote_sync_service.dart @@ -212,7 +212,6 @@ class RemoteSyncService { final remoteUpdateTime = idsToRemoteUpdationTimeMap[cid]; await _collectionsService.setCollectionSyncTime(cid, remoteUpdateTime); } - Bus.instance.fire(SyncStatusUpdate(SyncStatus.diffSynced)); _logger.info("All updated collections synced"); } diff --git a/lib/services/semantic_search/semantic_search_service.dart b/lib/services/semantic_search/semantic_search_service.dart index 0c99064dc..57171132d 100644 --- a/lib/services/semantic_search/semantic_search_service.dart +++ b/lib/services/semantic_search/semantic_search_service.dart @@ -48,7 +48,8 @@ class SemanticSearchService { await ModelLoader.instance.init(_computer); _setupCachedEmbeddings(); Bus.instance.on().listen((event) async { - if (event.status == SyncStatus.diffSynced) { + if (event.status == SyncStatus.preparingForUpload) { + // Diff sync is complete, we can now pull embeddings from remote sync(); } }); diff --git a/lib/ui/home/status_bar_widget.dart b/lib/ui/home/status_bar_widget.dart index 47277c3a5..fce14edb3 100644 --- a/lib/ui/home/status_bar_widget.dart +++ b/lib/ui/home/status_bar_widget.dart @@ -37,7 +37,7 @@ class _StatusBarWidgetState extends State { @override void initState() { _subscription = Bus.instance.on().listen((event) { - _logger.info("Received event " + event.toString()); + _logger.info("Received event " + event.status.toString()); if (event.status == SyncStatus.error) { setState(() { _syncError = event.error; @@ -164,8 +164,7 @@ class _SyncStatusWidgetState extends State { if (_event == null || isNotOutdatedEvent || //sync error cases are handled in StatusBarWidget - _event!.status == SyncStatus.error || - _event!.status == SyncStatus.diffSynced) { + _event!.status == SyncStatus.error) { return const SizedBox.shrink(); } if (_event!.status == SyncStatus.completedBackup) {