fix: ignore MLS error and use concurrent map in the sub conversation

logic/src/commonJvmAndroid/kotlin/com/wire/kalium/logic/CoreCryptoExceptionMapper.kt

@@ -31,6 +31,7 @@ actual fun mapMLSException(exception: Exception): MLSFailure =
                 is CryptoError.StaleProposal -> MLSFailure.StaleProposal
                 is CryptoError.StaleCommit -> MLSFailure.StaleCommit
                 is CryptoError.ConversationAlreadyExists -> MLSFailure.ConversationAlreadyExists
+                is CryptoError.MessageEpochTooOld -> MLSFailure.MessageEpochTooOld
                 else -> MLSFailure.Generic(exception)
             }
         } else {

logic/src/commonMain/kotlin/com/wire/kalium/logic/CoreFailure.kt

@@ -194,7 +194,7 @@ interface MLSFailure : CoreFailure {
     data object UnmergedPendingGroup : MLSFailure
 
     data object ConversationAlreadyExists : MLSFailure
-
+    data object MessageEpochTooOld : MLSFailure
     data object ConversationDoesNotSupportMLS : MLSFailure
     data object StaleProposal : MLSFailure
     data object StaleCommit : MLSFailure

logic/src/commonMain/kotlin/com/wire/kalium/logic/data/conversation/SubconversationRepository.kt

@@ -20,6 +20,7 @@ package com.wire.kalium.logic.data.conversation
 import com.wire.kalium.logic.data.id.ConversationId
 import com.wire.kalium.logic.data.id.GroupID
 import com.wire.kalium.logic.data.id.SubconversationId
+import io.ktor.util.collections.ConcurrentMap
 import kotlinx.coroutines.sync.Mutex
 import kotlinx.coroutines.sync.withLock
 
@@ -35,7 +36,7 @@ interface SubconversationRepository {
 class SubconversationRepositoryImpl : SubconversationRepository {
 
     private val mutex = Mutex()
-    private val subconversations = mutableMapOf<Pair<ConversationId, SubconversationId>, GroupID>()
+    private val subconversations = ConcurrentMap<Pair<ConversationId, SubconversationId>, GroupID>()
 
     override suspend fun insertSubconversation(conversationId: ConversationId, subconversationId: SubconversationId, groupId: GroupID) {
         mutex.withLock {

logic/src/commonMain/kotlin/com/wire/kalium/logic/data/event/EventMapper.kt

@@ -284,12 +284,12 @@ class EventMapper(
         id: String,
         eventContentDTO: EventContentDTO.Conversation.NewMLSMessageDTO,
     ) = Event.Conversation.NewMLSMessage(
-        id,
-        eventContentDTO.qualifiedConversation.toModel(),
-        eventContentDTO.subconversation?.let { SubconversationId(it) },
-        eventContentDTO.qualifiedFrom.toModel(),
-        eventContentDTO.time,
-        eventContentDTO.message
+        id = id,
+        conversationId = eventContentDTO.qualifiedConversation.toModel(),
+        subconversationId = eventContentDTO.subconversation?.let { SubconversationId(it) },
+        senderUserId = eventContentDTO.qualifiedFrom.toModel(),
+        timestampIso = eventContentDTO.time,
+        content = eventContentDTO.message
     )
 
     private fun connectionUpdate(

logic/src/commonMain/kotlin/com/wire/kalium/logic/sync/receiver/conversation/message/MLSMessageFailureHandler.kt

@@ -41,6 +41,7 @@ internal object MLSMessageFailureHandler {
             is MLSFailure.UnmergedPendingGroup -> MLSMessageFailureResolution.Ignore
             is MLSFailure.StaleProposal -> MLSMessageFailureResolution.Ignore
             is MLSFailure.StaleCommit -> MLSMessageFailureResolution.Ignore
+            is MLSFailure.MessageEpochTooOld -> MLSMessageFailureResolution.Ignore
             else -> MLSMessageFailureResolution.InformUser
         }
     }