diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java b/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java index 44b819dc4..d064fc819 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/limits/RateLimiter.java @@ -67,7 +67,7 @@ public interface RateLimiter { /** * If the wrapped {@code validate()} call throws a {@link RateLimitExceededException}, it will adapt it to ensure that - * {@link RateLimitExceededException#isLegacy()} returns {@code true} + * {@link RateLimitExceededException#isLegacy()} returns {@code false} */ static void adaptLegacyException(final RateLimitValidator validator) throws RateLimitExceededException { try { diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationRecoveryPasswords.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationRecoveryPasswords.java index f25dbc744..3d51a4e17 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationRecoveryPasswords.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationRecoveryPasswords.java @@ -60,9 +60,9 @@ public class RegistrationRecoveryPasswords extends AbstractDynamoDbStore { public CompletableFuture> lookup(final String number) { return asyncClient.getItem(GetItemRequest.builder() - .tableName(tableName) - .key(Map.of( - KEY_E164, AttributeValues.fromString(number))) + .tableName(tableName) + .key(Map.of(KEY_E164, AttributeValues.fromString(number))) + .consistentRead(true) .build()) .thenApply(getItemResponse -> { final Map item = getItemResponse.item();