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

Sync periodically if app is in foreground

Browse source
This commit is contained in:
Vishnu Mohandas 2021-05-08 23:23:17 +05:30
parent 9ccd3de9ec
commit 04f20ab505
1 changed files with 16 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lib/main.dart
View file

@ -28,6 +28,7 @@ Completer<void> _initializationStatus;
const kLastBGTaskHeartBeatTime = "bg_task_hb_time";
const kLastFGTaskHeartBeatTime = "fg_task_hb_time";
const kHeartBeatFrequency = Duration(seconds: 1);
const kFGSyncFrequency = Duration(minutes: 5);
const kFGTaskDeathTimeoutInMicroseconds = 5000000;
final themeData = ThemeData(
@ -61,7 +62,7 @@ Future<void> _runInForeground() async {
return await _runWithLogs(() async {
_logger.info("Starting app in foreground");
await _init(false);
_sync();
_scheduleFGSync();
runApp(AppLock(
builder: (args) => EnteApp(),
lockScreen: LockScreen(),
@ -157,16 +158,15 @@ Future<void> _scheduleHeartBeat(bool isBackground) async {
isBackground ? kLastBGTaskHeartBeatTime : kLastFGTaskHeartBeatTime,
DateTime.now().microsecondsSinceEpoch);
Future.delayed(kHeartBeatFrequency, () async {
await _scheduleHeartBeat(isBackground);
_scheduleHeartBeat(isBackground);
});
}
Future<bool> _isRunningInForeground() async {
final prefs = await SharedPreferences.getInstance();
await prefs.reload();
final currentTime = DateTime.now().microsecondsSinceEpoch;
return (prefs.getInt(kLastFGTaskHeartBeatTime) ?? 0) >
(currentTime - kFGTaskDeathTimeoutInMicroseconds);
Future<void> _scheduleFGSync() async {
await _sync();
Future.delayed(kFGSyncFrequency, () async {
_scheduleFGSync();
});
}
void _scheduleBGTaskKill(String taskId) async {
@ -180,6 +180,14 @@ void _scheduleBGTaskKill(String taskId) async {
});
}
Future<bool> _isRunningInForeground() async {
final prefs = await SharedPreferences.getInstance();
await prefs.reload();
final currentTime = DateTime.now().microsecondsSinceEpoch;
return (prefs.getInt(kLastFGTaskHeartBeatTime) ?? 0) >
(currentTime - kFGTaskDeathTimeoutInMicroseconds);
}
Future<void> _killBGTask(String taskId) async {
await UploadLocksDB.instance.releaseLocksAcquiredByOwnerBefore(
ProcessType.background.toString(), DateTime.now().microsecondsSinceEpoch);