helpy4/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich synced 2025-10-17 18:19:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: refactor life cycle events (#21781)

Browse source
This commit is contained in:
Alex 2025-09-10 11:50:31 -05:00 • committed by GitHub
parent 027dab1487
commit 9a5a3c0a1d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 24 additions and 46 deletions
Download patch file Download diff file Expand all files Collapse all files

70
mobile/lib/providers/app_life_cycle.provider.dart
View file

@ -125,6 +125,18 @@ class AppLifeCycleNotifier extends StateNotifier<AppLifeCycleEnum> {
} }
} }
Future<void> _safeRun(Future<void> action, String debugName) async {
if (!_shouldContinueOperation()) {
return;
}
try {
await action;
} catch (e, stackTrace) {
_log.warning("Error during $debugName operation", e, stackTrace);
}
}
Future<void> _handleBetaTimelineResume() async { Future<void> _handleBetaTimelineResume() async {
_ref.read(backupProvider.notifier).cancelBackup(); _ref.read(backupProvider.notifier).cancelBackup();
final lockManager = _ref.read(isolateLockManagerProvider(kIsolateLockManagerPort)); final lockManager = _ref.read(isolateLockManagerProvider(kIsolateLockManagerPort));
@ -150,57 +162,23 @@ class AppLifeCycleNotifier extends StateNotifier<AppLifeCycleEnum> {
final backgroundManager = _ref.read(backgroundSyncProvider); final backgroundManager = _ref.read(backgroundSyncProvider);
final isAlbumLinkedSyncEnable = _ref.read(appSettingsServiceProvider).getSetting(AppSettingsEnum.syncAlbums); final isAlbumLinkedSyncEnable = _ref.read(appSettingsServiceProvider).getSetting(AppSettingsEnum.syncAlbums);
final isEnableBackup = _ref.read(appSettingsServiceProvider).getSetting(AppSettingsEnum.enableBackup);
try { try {
// Run operations sequentially with state checks and error handling for each // Run operations sequentially with state checks and error handling for each
if (_shouldContinueOperation()) { _safeRun(backgroundManager.syncLocal(), "syncLocal");
try { _safeRun(backgroundManager.hashAssets(), "hashAssets");
await backgroundManager.syncLocal(); _safeRun(backgroundManager.syncRemote(), "syncRemote").then((_) {
} catch (e, stackTrace) { if (isAlbumLinkedSyncEnable) {
_log.warning("Failed syncLocal: $e", e, stackTrace); _safeRun(backgroundManager.syncLinkedAlbum(), "syncLinkedAlbum");
} }
} });
// Check if app is still active before hashing
if (_shouldContinueOperation()) {
try {
await backgroundManager.hashAssets();
} catch (e, stackTrace) {
_log.warning("Failed hashAssets: $e", e, stackTrace);
}
}
// Check if app is still active before remote sync
if (_shouldContinueOperation()) {
try {
await backgroundManager.syncRemote();
} catch (e, stackTrace) {
_log.warning("Failed syncRemote: $e", e, stackTrace);
}
if (isAlbumLinkedSyncEnable && _shouldContinueOperation()) {
try {
await backgroundManager.syncLinkedAlbum();
} catch (e, stackTrace) {
_log.warning("Failed syncLinkedAlbum: $e", e, stackTrace);
}
}
}
// Handle backup resume only if still active // Handle backup resume only if still active
if (_shouldContinueOperation()) { if (isEnableBackup) {
final isEnableBackup = _ref.read(appSettingsServiceProvider).getSetting(AppSettingsEnum.enableBackup); final currentUser = _ref.read(currentUserProvider);
if (currentUser != null) {
if (isEnableBackup) { _safeRun(_ref.read(driftBackupProvider.notifier).handleBackupResume(currentUser.id), "handleBackupResume");
final currentUser = _ref.read(currentUserProvider);
if (currentUser != null) {
try {
await _ref.read(driftBackupProvider.notifier).handleBackupResume(currentUser.id);
_log.fine("Completed backup resume");
} catch (e, stackTrace) {
_log.warning("Failed backup resume: $e", e, stackTrace);
}
}
} }
} }
} catch (e, stackTrace) { } catch (e, stackTrace) {
@ -209,7 +187,7 @@ class AppLifeCycleNotifier extends StateNotifier<AppLifeCycleEnum> {
// Ensure lock is released even if operations fail // Ensure lock is released even if operations fail
try { try {
lockManager.releaseLock(); lockManager.releaseLock();
_log.fine("Lock released after background sync operations"); _log.info("Lock released after background sync operations");
} catch (lockError) { } catch (lockError) {
_log.warning("Failed to release lock after error: $lockError"); _log.warning("Failed to release lock after error: $lockError");
} }