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

refactor code (minor nitpicks)

Browse source
This commit is contained in:
Peter Ombodi 2025-08-28 12:43:38 +03:00
parent 1682766ccb
commit b79371b0e0
2 changed files with 23 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

2
mobile/lib/domain/services/sync_stream.service.dart
View file

@ -120,7 +120,7 @@ class SyncStreamService {
case SyncEntityType.assetV1:
final remoteSyncAssets = data.cast<SyncAssetV1>();
await _trashSyncService.handleRemoteChanges(
remoteSyncAssets.map((e) => (checksum: e.checksum, deletedAt: e.deletedAt)),
remoteSyncAssets.map<TrashSyncItem>((e) => (checksum: e.checksum, deletedAt: e.deletedAt)),
);
return _syncStreamRepository.updateAssetsV1(remoteSyncAssets);
case SyncEntityType.assetDeleteV1:

35
mobile/lib/domain/services/trash_sync.service.dart
View file

@ -6,6 +6,8 @@ import 'package:immich_mobile/services/app_settings.service.dart';
import 'package:logging/logging.dart';
import 'package:platform/platform.dart';
typedef TrashSyncItem = ({String checksum, DateTime? deletedAt});
class TrashSyncService {
final AppSettingsService _appSettingsService;
final RemoteAssetRepository _remoteAssetRepository;
@ -28,22 +30,27 @@ class TrashSyncService {
_storageRepository = storageRepository,
_platform = const LocalPlatform();
Future<void> handleRemoteChanges(Iterable<({String checksum, DateTime? deletedAt})> syncItems) async {
Future<void> handleRemoteChanges(Iterable<TrashSyncItem> syncItems) async {
if (!_platform.isAndroid || !_appSettingsService.getSetting<bool>(AppSettingsEnum.manageLocalMediaAndroid)) {
return Future.value();
}
final trashedAssetsChecksums = syncItems
.where((item) => item.deletedAt != null)
.map((syncItem) => syncItem.checksum);
await applyRemoteTrashToLocal(trashedAssetsChecksums);
final modifiedAssetsChecksums = syncItems
.where((item) => item.deletedAt == null)
.map((syncItem) => syncItem.checksum);
await applyRemoteRestoreToLocal(modifiedAssetsChecksums);
final trashedAssetsChecksums = <String>[];
final modifiedAssetsChecksums = <String>[];
for (var syncItem in syncItems) {
if (syncItem.deletedAt != null) {
trashedAssetsChecksums.add(syncItem.checksum);
} else {
modifiedAssetsChecksums.add(syncItem.checksum);
}
}
await _applyRemoteTrashToLocal(trashedAssetsChecksums);
await _applyRemoteRestoreToLocal(modifiedAssetsChecksums);
}
Future<void> applyRemoteTrashToLocal(Iterable<String> trashedAssetsChecksums) async {
if (trashedAssetsChecksums.isNotEmpty) {
Future<void> _applyRemoteTrashToLocal(Iterable<String> trashedAssetsChecksums) async {
if (trashedAssetsChecksums.isEmpty) {
return Future.value();
} else {
final localAssetsToTrash = await _localAssetRepository.getByChecksums(trashedAssetsChecksums);
if (localAssetsToTrash.isNotEmpty) {
final mediaUrls = await Future.wait(
@ -57,8 +64,10 @@ class TrashSyncService {
}
}
Future<void> applyRemoteRestoreToLocal(Iterable<String> modifiedAssetsChecksums) async {
if (modifiedAssetsChecksums.isNotEmpty) {
Future<void> _applyRemoteRestoreToLocal(Iterable<String> modifiedAssetsChecksums) async {
if (modifiedAssetsChecksums.isEmpty) {
return Future.value();
} else {
final remoteAssetsToRestore = await _remoteAssetRepository.getByChecksums(
modifiedAssetsChecksums,
isTrashed: true,