Cutlery/immich
1
0
Fork 1
mirror of https://github.com/immich-app/immich.git synced 2025-08-11 09:16:31 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore: log resume backup process (#20768)

Browse Source
This commit is contained in:
Alex 2025-08-07 15:44:49 -05:00 committed by GitHub
parent cfbc24579d
commit b1aacfdbd9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mobile/lib/providers/backup/drift_backup.provider.dart
View File

@ -9,6 +9,7 @@ import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:immich_mobile/constants/constants.dart'; import 'package:immich_mobile/constants/constants.dart';
import 'package:immich_mobile/services/upload.service.dart'; import 'package:immich_mobile/services/upload.service.dart';
import 'package:logging/logging.dart';
class EnqueueStatus { class EnqueueStatus {
final int enqueueCount; final int enqueueCount;
@ -213,6 +214,7 @@ class DriftBackupNotifier extends StateNotifier<DriftBackupState> {
final UploadService _uploadService; final UploadService _uploadService;
StreamSubscription<TaskStatusUpdate>? _statusSubscription; StreamSubscription<TaskStatusUpdate>? _statusSubscription;
StreamSubscription<TaskProgressUpdate>? _progressSubscription; StreamSubscription<TaskProgressUpdate>? _progressSubscription;
final _logger = Logger("DriftBackupNotifier");
/// Remove upload item from state /// Remove upload item from state
void _removeUploadItem(String taskId) { void _removeUploadItem(String taskId) {
@ -333,17 +335,17 @@ class DriftBackupNotifier extends StateNotifier<DriftBackupState> {
} }
Future<void> handleBackupResume(String userId) async { Future<void> handleBackupResume(String userId) async {
debugPrint("handleBackupResume"); _logger.info("Resuming backup tasks...");
final tasks = await _uploadService.getActiveTasks(kBackupGroup); final tasks = await _uploadService.getActiveTasks(kBackupGroup);
debugPrint("Found ${tasks.length} tasks"); _logger.info("Found ${tasks.length} tasks");
if (tasks.isEmpty) { if (tasks.isEmpty) {
// Start a new backup queue // Start a new backup queue
debugPrint("Start a new backup queue"); _logger.info("Start a new backup queue");
await startBackup(userId); await startBackup(userId);
} }
debugPrint("Tasks to resume: ${tasks.length}"); _logger.info("Tasks to resume: ${tasks.length}");
await _uploadService.resumeBackup(); await _uploadService.resumeBackup();
} }