kenmirrors/ente
1
0
Fork 0
mirror of https://github.com/ente-io/ente.git synced 2025-08-08 15:30:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

[mob] Clean up stale upload files inside uploader

Browse Source
This commit is contained in:
Neeraj Gupta 2024-05-08 11:12:32 +05:30
parent 7487b76b9d
commit 220e80e467
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
mobile/lib/core/configuration.dart
View File

@ -155,7 +155,8 @@ class Configuration {
} }
await _preferences.setInt(lastTempFolderClearTimeKey, currentTime); await _preferences.setInt(lastTempFolderClearTimeKey, currentTime);
_logger.info( _logger.info(
"Cleared temp folder except $skippedTempUploadFiles upload files"); "Cleared temp folder except $skippedTempUploadFiles upload files",
);
} else { } else {
_logger.info("Skipping temp folder clear"); _logger.info("Skipping temp folder clear");
} }

6
mobile/lib/utils/file_uploader.dart
View File

@ -52,6 +52,7 @@ class FileUploader {
static const kBlockedUploadsPollFrequency = Duration(seconds: 2); static const kBlockedUploadsPollFrequency = Duration(seconds: 2);
static const kFileUploadTimeout = Duration(minutes: 50); static const kFileUploadTimeout = Duration(minutes: 50);
static const k20MBStorageBuffer = 20 * 1024 * 1024; static const k20MBStorageBuffer = 20 * 1024 * 1024;
static const _lastStaleFileCleanupTime = "lastStaleFileCleanupTime";
final _logger = Logger("FileUploader"); final _logger = Logger("FileUploader");
final _dio = NetworkClient.instance.getDio(); final _dio = NetworkClient.instance.getDio();
@ -121,6 +122,11 @@ class FileUploader {
UploadLocksDB.instance, UploadLocksDB.instance,
flagService, flagService,
); );
if (currentTime - (_prefs.getInt(_lastStaleFileCleanupTime) ?? 0) >
tempDirCleanUpInterval) {
await removeStaleFiles();
await _prefs.setInt(_lastStaleFileCleanupTime, currentTime);
}
Bus.instance.on<LocalPhotosUpdatedEvent>().listen((event) { Bus.instance.on<LocalPhotosUpdatedEvent>().listen((event) {
if (event.type == EventType.deletedFromDevice || if (event.type == EventType.deletedFromDevice ||
event.type == EventType.deletedFromEverywhere) { event.type == EventType.deletedFromEverywhere) {