logic/com.wire.kalium.logic.data.client/ClientDataSource

ClientDataSource

class ClientDataSource(clientRemoteRepository: ClientRemoteRepository, clientRegistrationStorage: <Error class: unknown class>, clientDAO: <Error class: unknown class>, newClientDAO: <Error class: unknown class>, selfUserID: <Error class: unknown class>, clientApi: <Error class: unknown class>, clientMapper: ClientMapper = MapperProvider.clientMapper()) : ClientRepository

Constructors

ClientDataSource

constructor(clientRemoteRepository: ClientRemoteRepository, clientRegistrationStorage: <Error class: unknown class>, clientDAO: <Error class: unknown class>, newClientDAO: <Error class: unknown class>, selfUserID: <Error class: unknown class>, clientApi: <Error class: unknown class>, clientMapper: ClientMapper = MapperProvider.clientMapper())

Functions

clearClientRegistrationBlockedByE2EI

open suspend override fun clearClientRegistrationBlockedByE2EI(): Either<CoreFailure, Unit>

clearCurrentClientId

open suspend override fun clearCurrentClientId(): Either<CoreFailure, Unit>

clearHasRegisteredMLSClient

open suspend override fun clearHasRegisteredMLSClient(): Either<CoreFailure, Unit>

clearNewClients

open suspend override fun clearNewClients()

clearRetainedClientId

open suspend override fun clearRetainedClientId(): Either<CoreFailure, Unit>

currentClientId

open suspend override fun currentClientId(): Either<CoreFailure, <Error class: unknown class>>

deleteClient

open suspend override fun deleteClient(param: <Error class: unknown class>): Either<NetworkFailure, Unit>

deregisterToken

open suspend override fun deregisterToken(token: String): Either<NetworkFailure, Unit>

getClientsByConversationId

open suspend override fun getClientsByConversationId(conversationId: <Error class: unknown class>): Either<StorageFailure, Map<<Error class: unknown class>, List<<Error class: unknown class>>>>

getClientsByUserId

open suspend override fun getClientsByUserId(userId: <Error class: unknown class>): Either<StorageFailure, List<<Error class: unknown class>>>

hasRegisteredMLSClient

open suspend override fun hasRegisteredMLSClient(): Either<CoreFailure, Boolean>

isClientRegistrationBlockedByE2EI

open suspend override fun isClientRegistrationBlockedByE2EI(): Either<CoreFailure, Boolean>

observeClientsByUserId

open suspend override fun observeClientsByUserId(userId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, List<<Error class: unknown class>>>>

observeClientsByUserIdAndClientId

open suspend override fun observeClientsByUserIdAndClientId(userId: <Error class: unknown class>, clientId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, <Error class: unknown class>>>

observeCurrentClientId

open suspend override fun observeCurrentClientId(): <Error class: unknown class><<Error class: unknown class>?>

observeIsClientRegistrationBlockedByE2EI

open suspend override fun observeIsClientRegistrationBlockedByE2EI(): <Error class: unknown class><Boolean>

observeNewClients

open suspend override fun observeNewClients(): <Error class: unknown class><Either<StorageFailure, List<<Error class: unknown class>>>>

persistClientId

open suspend override fun persistClientId(clientId: <Error class: unknown class>): Either<CoreFailure, Unit>

persistRetainedClientId

open suspend override fun persistRetainedClientId(clientId: <Error class: unknown class>): Either<CoreFailure, Unit>

registerClient

open suspend override fun registerClient(param: RegisterClientParam): Either<NetworkFailure, <Error class: unknown class>>

registerMLSClient

open suspend override fun registerMLSClient(clientId: <Error class: unknown class>, publicKey: ByteArray, cipherSuite: <Error class: unknown class>): Either<CoreFailure, Unit>

registerToken

open suspend override fun registerToken(senderId: String, client: String, token: String, transport: String): Either<NetworkFailure, Unit>

removeClientsAndReturnUsersWithNoClients

open suspend override fun removeClientsAndReturnUsersWithNoClients(redundantClientsOfUsers: Map<<Error class: unknown class>, List<<Error class: unknown class>>>): Either<StorageFailure, List<<Error class: unknown class>>>

retainedClientId

open suspend override fun retainedClientId(): Either<CoreFailure, <Error class: unknown class>>

saveNewClientEvent

open suspend override fun saveNewClientEvent(newClientEvent: Event.User.NewClient): Either<CoreFailure, Unit>

selfListOfClients

open suspend override fun selfListOfClients(): Either<NetworkFailure, List<<Error class: unknown class>>>

fetches the clients from the backend and stores them in the database

setClientRegistrationBlockedByE2EI

open suspend override fun setClientRegistrationBlockedByE2EI(): Either<CoreFailure, Unit>

storeMapOfUserToClientId

open suspend override fun storeMapOfUserToClientId(userToClientMap: Map<<Error class: unknown class>, List<<Error class: unknown class>>>): Either<StorageFailure, Unit>

storeUserClientIdList

open suspend override fun storeUserClientIdList(userId: <Error class: unknown class>, clients: List<<Error class: unknown class>>): Either<StorageFailure, Unit>

storeUserClientListAndRemoveRedundantClients

open suspend override fun storeUserClientListAndRemoveRedundantClients(clients: List<<Error class: unknown class>>): Either<StorageFailure, Unit>

updateClientProteusVerificationStatus

open suspend override fun updateClientProteusVerificationStatus(userId: <Error class: unknown class>, clientId: <Error class: unknown class>, verified: Boolean): Either<StorageFailure, Unit>