beenull/ente
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Fire an event when first import is successful

Browse source
This commit is contained in:
Vishnu Mohandas 2021-04-25 17:22:07 +05:30
parent 5b1eb11f39
commit 15f009add3
2 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/events/first_import_succeeded_event.dart Normal file
View file

@ -0,0 +1,3 @@
import 'package:photos/events/event.dart';
class FirstImportSucceededEvent extends Event {}

8
lib/services/sync_service.dart
View file

@ -8,6 +8,7 @@ import 'package:photos/core/event_bus.dart';
import 'package:photos/core/network.dart';
import 'package:photos/db/files_db.dart';
import 'package:photos/events/collection_updated_event.dart';
import 'package:photos/events/first_import_succeeded_event.dart';
import 'package:photos/events/local_photos_updated_event.dart';
import 'package:photos/events/permission_granted_event.dart';
import 'package:photos/events/sync_status_update_event.dart';
@ -263,7 +264,11 @@ class SyncService {
_logger.info("Inserted " + files.length.toString() + " files.");
Bus.instance.fire(LocalPhotosUpdatedEvent(allFiles));
}
bool isFirstImport = !_prefs.containsKey(kDbUpdationTimeKey);
await _prefs.setInt(kDbUpdationTimeKey, toTime);
if (isFirstImport) {
Bus.instance.fire(FirstImportSucceededEvent());
}
}
Future<void> syncWithRemote({bool silently = false}) async {
@ -302,7 +307,8 @@ class SyncService {
" files in collection " +
collectionID.toString());
Bus.instance.fire(LocalPhotosUpdatedEvent(diff.updatedFiles));
Bus.instance.fire(CollectionUpdatedEvent(collectionID, diff.updatedFiles));
Bus.instance
.fire(CollectionUpdatedEvent(collectionID, diff.updatedFiles));
if (diff.fetchCount == kDiffLimit) {
return await _syncCollectionDiff(collectionID);
}