logic/com.wire.kalium.logic.feature.message/ProteusRecipientsDataSource

ProteusRecipientsDataSource

internal class ProteusRecipientsDataSource(userRepository: UserRepository, clientRepository: ClientRepository, clientRemoteRepository: ClientRemoteRepository, fetchConversationUseCase: FetchConversationUseCase, clientMapper: ClientMapper = MapperProvider.clientMapper()) : ProteusRecipients

Constructors

ProteusRecipientsDataSource

constructor(userRepository: UserRepository, clientRepository: ClientRepository, clientRemoteRepository: ClientRemoteRepository, fetchConversationUseCase: FetchConversationUseCase, clientMapper: ClientMapper = MapperProvider.clientMapper())

Functions

open suspend override fun fetchClients(userIds: List<UserId>): Either<CoreFailure, Unit>

fetchConversation

open suspend override fun fetchConversation(transactionContext: CryptoTransactionContext, conversationId: ConversationId): Either<CoreFailure, Unit>

open suspend override fun fetchUsers(userIds: Set<UserId>): Either<CoreFailure, Unit>

markClientsAsValid

open suspend override fun markClientsAsValid(clients: Map<UserId, List<ClientId>>): Either<StorageFailure, Unit>

open suspend override fun removeClients(clients: Map<UserId, List<ClientId>>): Either<StorageFailure, List<UserId>>