TerribleDev/ente
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove recursion

Browse Source
This commit is contained in:
Neeraj Gupta
2025-03-03 11:21:11 +05:30
parent 3ef8ece8c0
commit 679c12bb90
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
mobile/lib/services/remote_pull/remote_pull.dart
View File

@@ -63,23 +63,26 @@ class RemoteDiffService {
}
final Uint8List collectionKey =
_collectionsService.getCollectionKey(collectionID);
final diff = await collectionFiles.getCollectionItemsDiff(
collectionID,
sinceTime,
collectionKey,
);
await remoteDB.deleteCollectionFilesDiff(diff.deletedItems);
await remoteDB.insertCollectionFilesDiff(diff.updatedItems);
await _collectionsService.setCollectionSyncTime(
collectionID,
max(diff.maxUpdatedAtTime, sinceTime),
);
_logger.fine("[Collection-$collectionID] synced $diff");
if (diff.hasMore) {
return await _syncCollectionFiles(
int currentSinceTime = sinceTime;
bool hasMore = true;
while (hasMore) {
final diff = await collectionFiles.getCollectionItemsDiff(
collectionID,
_collectionsService.getCollectionSyncTime(collectionID),
currentSinceTime,
collectionKey,
);
await remoteDB.deleteCollectionFilesDiff(diff.deletedItems);
await remoteDB.insertCollectionFilesDiff(diff.updatedItems);
final int nextSyncFrom = max(diff.maxUpdatedAtTime, currentSinceTime);
await _collectionsService.setCollectionSyncTime(
collectionID,
nextSyncFrom,
);
_logger.fine("[Collection-$collectionID] synced $diff");
hasMore = diff.hasMore;
if (hasMore) {
currentSinceTime = nextSyncFrom;
}
}
}
}