Cutlery/immich
1
0
Fork 1
mirror of https://github.com/immich-app/immich.git synced 2025-06-04 22:24:26 -04:00
Code Issues Packages Projects Releases Wiki Activity

send all acks at once

Browse Source
This commit is contained in:
Alex 2025-03-18 11:52:41 -05:00
parent 0ae879e597
commit fde95120ec
No known key found for this signature in database
GPG Key ID: 53CD082B3A5E1082
3 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mobile/lib/domain/interfaces/sync_api.interface.dart
View File

@ -1,7 +1,7 @@
import 'package:immich_mobile/domain/models/sync/sync_event.model.dart'; import 'package:immich_mobile/domain/models/sync/sync_event.model.dart';
abstract interface class ISyncApiRepository { abstract interface class ISyncApiRepository {
Future<void> ack(String data); Future<void> ack(List<String> data);
Stream<List<SyncEvent>> watchUserSyncEvent(); Stream<List<SyncEvent>> watchUserSyncEvent();

12
mobile/lib/domain/services/sync_stream.service.dart
View File

@ -40,9 +40,7 @@ class SyncStreamService {
} }
} }
for (final ack in acks.values) { await _syncApiRepository.ack(acks.values.toList());
await _syncApiRepository.ack(ack);
}
}, },
onDone: () { onDone: () {
_isUserSyncing = false; _isUserSyncing = false;
@ -78,9 +76,7 @@ class SyncStreamService {
} }
} }
for (final ack in acks.values) { await _syncApiRepository.ack(acks.values.toList());
await _syncApiRepository.ack(ack);
}
}, },
onDone: () { onDone: () {
_isAssetSyncing = false; _isAssetSyncing = false;
@ -113,9 +109,7 @@ class SyncStreamService {
} }
} }
for (final ack in acks.values) { await _syncApiRepository.ack(acks.values.toList());
await _syncApiRepository.ack(ack);
}
}, },
onDone: () { onDone: () {
_isExifSyncing = false; _isExifSyncing = false;

4
mobile/lib/infrastructure/repositories/sync_api.repository.dart
View File

@ -44,8 +44,8 @@ class SyncApiRepository implements ISyncApiRepository {
} }
@override @override
Future<void> ack(String data) { Future<void> ack(List<String> data) {
return _api.syncApi.sendSyncAck(SyncAckSetDto(acks: [data])); return _api.syncApi.sendSyncAck(SyncAckSetDto(acks: data));
} }
Stream<List<SyncEvent>> _getSyncStream( Stream<List<SyncEvent>> _getSyncStream(