Fix case where we delete unknown remote records.
This commit is contained in:
parent
a829165f2d
commit
d2e19c5129
1 changed files with 2 additions and 2 deletions
|
@ -331,9 +331,9 @@ public class StorageSyncJob extends BaseJob {
|
||||||
Log.i(TAG, "Removed " + removedUnregistered + " recipients from storage service that have been unregistered for longer than 30 days.");
|
Log.i(TAG, "Removed " + removedUnregistered + " recipients from storage service that have been unregistered for longer than 30 days.");
|
||||||
}
|
}
|
||||||
|
|
||||||
List<StorageId> localStorageIds = getAllLocalStorageIds(self).stream().filter(it -> !it.isUnknown()).collect(Collectors.toList());
|
List<StorageId> localStorageIds = getAllLocalStorageIds(self);
|
||||||
IdDifferenceResult idDifference = StorageSyncHelper.findIdDifference(remoteManifest.getStorageIds(), localStorageIds);
|
IdDifferenceResult idDifference = StorageSyncHelper.findIdDifference(remoteManifest.getStorageIds(), localStorageIds);
|
||||||
List<SignalStorageRecord> remoteInserts = buildLocalStorageRecords(context, self, idDifference.getLocalOnlyIds());
|
List<SignalStorageRecord> remoteInserts = buildLocalStorageRecords(context, self, idDifference.getLocalOnlyIds().stream().filter(it -> !it.isUnknown()).collect(Collectors.toList()));
|
||||||
List<byte[]> remoteDeletes = Stream.of(idDifference.getRemoteOnlyIds()).map(StorageId::getRaw).toList();
|
List<byte[]> remoteDeletes = Stream.of(idDifference.getRemoteOnlyIds()).map(StorageId::getRaw).toList();
|
||||||
|
|
||||||
Log.i(TAG, "ID Difference :: " + idDifference);
|
Log.i(TAG, "ID Difference :: " + idDifference);
|
||||||
|
|
Loading…
Add table
Reference in a new issue