helpy4/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich synced 2025-11-14 17:36:12 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove albumIds from getTrashedAssets params

Browse source 
fix upsert in trashed local asset repo
refactor code
This commit is contained in:
Peter Ombodi 2025-10-14 15:30:22 +03:00
parent 0c25ee811b
commit 6448b3da50
11 changed files with 27 additions and 55 deletions
Download patch file Download diff file Expand all files Collapse all files

18
mobile/lib/infrastructure/repositories/trashed_local_asset.repository.dart
View file

@ -82,7 +82,7 @@ class DriftTrashedLocalAssetRepository extends DriftDatabaseRepository {
final companion = TrashedLocalAssetEntityCompanion.insert(
id: item.asset.id,
albumId: item.albumId,
checksum: effectiveChecksum == null ? const Value.absent() : Value(effectiveChecksum),
checksum: Value(effectiveChecksum),
name: item.asset.name,
type: item.asset.type,
createdAt: Value(item.asset.createdAt),
@ -179,7 +179,7 @@ class DriftTrashedLocalAssetRepository extends DriftDatabaseRepository {
TrashedLocalAssetEntityCompanion(
id: Value(asset.id),
name: Value(asset.name),
// albumId: Value(entry.key),
albumId: Value(entry.key),
checksum: asset.checksum == null ? const Value.absent() : Value(asset.checksum),
type: Value(asset.type),
width: Value(asset.width),
@ -195,15 +195,13 @@ class DriftTrashedLocalAssetRepository extends DriftDatabaseRepository {
}
await _db.transaction(() async {
await _db.batch((batch) {
for (final slice in companions.slices(32000)) {
batch.insertAllOnConflictUpdate(_db.trashedLocalAssetEntity, slice);
}
for (final companion in companions) {
await _db.into(_db.trashedLocalAssetEntity).insertOnConflictUpdate(companion);
}
for (final id in idToDelete) {
batch.deleteWhere(_db.localAssetEntity, (row) => row.id.equals(id));
}
});
for (final id in idToDelete) {
await (_db.delete(_db.localAssetEntity)..where((row) => row.id.equals(id))).go();
}
});
}