Infrastructure/immich
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2025-01-21 00:52:43 -05:00
Code Issues Activity

fix(mobile): verbose logging of full sync asset loading

Browse source
This commit is contained in:
Fynn Petersen-Frey 2024-06-04 14:14:34 +02:00
parent 88d4338348
commit de4b5b09ef
1 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
mobile/lib/services/asset.service.dart
View file

@ -99,6 +99,8 @@ class AssetService {
/// Returns `null` if the server state did not change, else list of assets /// Returns `null` if the server state did not change, else list of assets
Future<List<Asset>?> _getRemoteAssets(User user, DateTime until) async { Future<List<Asset>?> _getRemoteAssets(User user, DateTime until) async {
const int chunkSize = 10000; const int chunkSize = 10000;
int chunkNumber = 0;
int miniChunkCount = 0;
try { try {
final List<Asset> allAssets = []; final List<Asset> allAssets = [];
DateTime? lastCreationDate; DateTime? lastCreationDate;
@ -112,17 +114,35 @@ class AssetService {
lastCreationDate: lastCreationDate, lastCreationDate: lastCreationDate,
userId: user.id, userId: user.id,
); );
log.fine('Requesting assets older than ($lastCreationDate,$lastId)');
final List<AssetResponseDto>? assets = final List<AssetResponseDto>? assets =
await _apiService.syncApi.getFullSyncForUser(dto); await _apiService.syncApi.getFullSyncForUser(dto);
if (assets == null) return null; if (assets == null) return null;
allAssets.addAll(assets.map(Asset.remote)); allAssets.addAll(assets.map(Asset.remote));
if (assets.isEmpty) break; if (assets.isEmpty) break;
log.fine(
'Received ${assets.length} assets ranging from (${assets.first.fileCreatedAt},${assets.first.id}) to (${assets.last.fileCreatedAt},${assets.last.id})',
);
if (assets.length < 100) {
miniChunkCount++;
if (miniChunkCount > 50) {
log.severe(
'getRemoteAssets received too many almost empty chunks, stopping. Not all remote assets could be fetched from the server for user ${user.name}.',
);
break;
}
}
lastCreationDate = assets.last.fileCreatedAt; lastCreationDate = assets.last.fileCreatedAt;
lastId = assets.last.id; lastId = assets.last.id;
chunkNumber++;
} }
return allAssets; return allAssets;
} catch (error, stack) { } catch (error, stack) {
log.severe('Error while getting remote assets', error, stack); log.severe(
'Error while getting remote assets chunk $chunkNumber',
error,
stack,
);
return null; return null;
} }
} }