logic/com.wire.kalium.logic.sync.receiver.conversation.message/AppMLSReceiveRecovery

AppMLSReceiveRecovery

internal class AppMLSReceiveRecovery(recovery: MLSReceiveRecovery, conversations: ConversationRepository, mlsConversations: MLSConversationRepository, persistMessage: PersistMessageUseCase, selfUserId: UserId, selfTeamId: SelfTeamIdProvider) : EventBatchRecovery

Main-app effects for the recovery coordinator shared with the notification extension.

Constructors

AppMLSReceiveRecovery

constructor(recovery: MLSReceiveRecovery, conversations: ConversationRepository, mlsConversations: MLSConversationRepository, persistMessage: PersistMessageUseCase, selfUserId: UserId, selfTeamId: SelfTeamIdProvider)

Functions

open suspend override fun acknowledge(eventIds: List<String>)

suspend fun handle(context: CryptoTransactionContext, event: Event.Conversation.NewMLSMessage, wrongEpoch: Boolean): Boolean

recordProcessed

open suspend override fun recordProcessed(context: CryptoTransactionContext, events: List<EventEnvelope>)

wereEffectsProcessed

open suspend override fun wereEffectsProcessed(context: CryptoTransactionContext, envelope: EventEnvelope): Boolean