mirror
/
Signal-Android
kopia lustrzana https://github.com/ryukoposting/Signal-Android
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Only check remote registrationIds for active records.

fork-5.53.8
Greyson Parrelli 2021-08-31 09:46:37 -04:00
rodzic 50b4e137b4
commit 6bde55f73b
1 zmienionych plików z 11 dodań i 8 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

19
app/src/main/java/org/thoughtcrime/securesms/crypto/storage/TextSecureSessionStore.java
Wyświetl plik

@ -104,19 +104,22 @@ public class TextSecureSessionStore implements SignalServiceSessionStore {
@Override @Override
public Set<SignalProtocolAddress> getAllAddressesWithActiveSessions(List<String> addressNames) throws InvalidRegistrationIdException { public Set<SignalProtocolAddress> getAllAddressesWithActiveSessions(List<String> addressNames) throws InvalidRegistrationIdException {
synchronized (LOCK) { synchronized (LOCK) {
List<SessionDatabase.SessionRow> rows = DatabaseFactory.getSessionDatabase(context).getAllFor(addressNames); List<SessionDatabase.SessionRow> activeRows = DatabaseFactory.getSessionDatabase(context)
.getAllFor(addressNames)
.stream()
.filter(row -> isActive(row.getRecord()))
.collect(Collectors.toList());
boolean hasInvalidRegistrationId = rows.stream() boolean hasInvalidRegistrationId = activeRows.stream()
.map(SessionDatabase.SessionRow::getRecord) .map(SessionDatabase.SessionRow::getRecord)
.anyMatch(record -> !isValidRegistrationId(record.getRemoteRegistrationId())); .anyMatch(record -> !isValidRegistrationId(record.getRemoteRegistrationId()));
if (hasInvalidRegistrationId) { if (hasInvalidRegistrationId) {
throw new InvalidRegistrationIdException(); throw new InvalidRegistrationIdException();
} }
return rows.stream() return activeRows.stream()
.filter(row -> isActive(row.getRecord())) .map(row -> new SignalProtocolAddress(row.getAddress(), row.getDeviceId()))
.map(row -> new SignalProtocolAddress(row.getAddress(), row.getDeviceId())) .collect(Collectors.toSet());
.collect(Collectors.toSet());
} }
} }