Remove extra sync event

This commit is contained in:
vishnukvmd 2023-11-15 01:36:14 +05:30
parent 688b43c75a
commit a28219807b
4 changed files with 4 additions and 6 deletions

View file

@ -30,7 +30,6 @@ enum SyncStatus {
startedFirstGalleryImport,
completedFirstGalleryImport,
applyingRemoteDiff,
diffSynced,
preparingForUpload,
inProgress,
paused,

View file

@ -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");
}

View file

@ -48,7 +48,8 @@ class SemanticSearchService {
await ModelLoader.instance.init(_computer);
_setupCachedEmbeddings();
Bus.instance.on<SyncStatusUpdate>().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();
}
});

View file

@ -37,7 +37,7 @@ class _StatusBarWidgetState extends State<StatusBarWidget> {
@override
void initState() {
_subscription = Bus.instance.on<SyncStatusUpdate>().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<SyncStatusWidget> {
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) {