Invalidate cache entries for accounts after successfully adding devices

signalapp · Dec 7, 2023 · 1fb8827 · 1fb8827
1 parent a843780
commit 1fb8827
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AccountsManager.java
@@ -292,6 +292,8 @@ private CompletableFuture<Pair<Account, Device>> addDevice(final UUID accountIde
               .thenCompose(ignored -> accounts.updateTransactionallyAsync(account, additionalWriteItems))
               .thenApply(ignored -> new Pair<>(account, account.getDevice(nextDeviceId).orElseThrow()));
         })
+        .thenCompose(updatedAccountAndDevice -> redisDeleteAsync(updatedAccountAndDevice.first())
+            .thenApply(ignored -> updatedAccountAndDevice))
         .exceptionallyCompose(throwable -> {
           if (ExceptionUtils.unwrap(throwable) instanceof ContestedOptimisticLockException && retries > 0) {
             return addDevice(accountIdentifier, deviceSpec, retries - 1);