fix: fail re-try if verifying epoch fails

wireapp · Sep 22, 2023 · 31307a4 · 31307a4
1 parent dd22d3c
commit 31307a4
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/logic/src/commonMain/kotlin/com/wire/kalium/logic/feature/message/MessageSender.kt b/logic/src/commonMain/kotlin/com/wire/kalium/logic/feature/message/MessageSender.kt
@@ -319,10 +319,12 @@ internal class MessageSenderImpl internal constructor(
                     if (it is NetworkFailure.ServerMiscommunication && it.kaliumException is KaliumException.InvalidRequestError) {
                         if (it.kaliumException.isMlsStaleMessage()) {
                             logger.w("Encrypted MLS message for stale epoch '${message.id}', re-trying..")
-                            staleEpochVerifier.verifyEpoch(message.conversationId)
-                            return syncManager.waitUntilLiveOrFailure().flatMap {
-                                attemptToSend(message)
-                            }
+                            return staleEpochVerifier.verifyEpoch(message.conversationId)
+                                .flatMap {
+                                    syncManager.waitUntilLiveOrFailure().flatMap {
+                                        attemptToSend(message)
+                                    }
+                                }
                         }
                     }
                     Either.Left(it)