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

Safeguard against multiple syncs

Browse source
This commit is contained in:
Vishnu Mohandas 2021-02-26 19:39:45 +05:30
parent b9ea4be9a7
commit f8da6378f7
1 changed files with 25 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
lib/main.dart
View file

@ -18,8 +18,7 @@ import 'package:super_logging/super_logging.dart';
import 'package:logging/logging.dart';
final _logger = Logger("main");
bool _isInitialized = false;
bool _isInitializing = false;
AppInitState _state = AppInitState.pending;
void main() async {
WidgetsFlutterBinding.ensureInitialized();
@ -35,10 +34,14 @@ void _main() async {
_sendErrorToSentry(sentry, details.exception, details.stack);
};
await _init();
_sync();
runZoned(
() async {
if (_state == AppInitState.pending) {
await _init();
}
if (_state == AppInitState.initialized) {
_sync();
}
runApp(MyApp());
BackgroundFetch.registerHeadlessTask(_onBackgroundTaskReceived);
},
@ -49,8 +52,8 @@ void _main() async {
}
Future _init() async {
_isInitializing = true;
_logger.info("Initializing...");
_state = AppInitState.initialzing;
_logger.info("Initializing...", Error(), StackTrace.current);
InAppPurchaseConnection.enablePendingPurchases();
CryptoUtil.init();
await Configuration.instance.init();
@ -58,15 +61,17 @@ Future _init() async {
await CollectionsService.instance.init();
await SyncService.instance.init();
await MemoriesService.instance.init();
_isInitialized = true;
_state = AppInitState.initialized;
_logger.info("Initialization done");
_isInitializing = false;
}
Future<void> _sync({bool isAppInBackground = false}) async {
if (SyncService.instance.isSyncInProgress()) {
return;
}
if (isAppInBackground) {
_logger.info("Syncing in background");
}
try {
await SyncService.instance.sync(isAppInBackground: isAppInBackground);
} catch (e, s) {
@ -75,15 +80,17 @@ Future<void> _sync({bool isAppInBackground = false}) async {
}
Future _onBackgroundTaskReceived(String taskId) async {
_logger.info("[BackgroundFetch] Event received: $taskId");
if (!_isInitialized && !_isInitializing) {
if (_state == AppInitState.pending) {
await _runWithLogs(() async {
_logger.info("[BackgroundFetch] Event received: $taskId");
await _init();
await _sync(isAppInBackground: true);
});
} else {
_logger.info("Skipping initialization");
} else if (_state == AppInitState.initialized) {
_logger.info("[BackgroundFetch] Skipping init");
await _sync(isAppInBackground: true);
} else {
_logger.info("[BackgroundFetch] Skipping init and sync");
}
BackgroundFetch.finish(taskId);
}
@ -172,3 +179,9 @@ class MyApp extends StatelessWidget with WidgetsBindingObserver {
}
}
}
enum AppInitState {
pending,
initialzing,
initialized,
}