persistence/com.wire.kalium.persistence.dao.client/ClientDAOImpl

ClientDAOImpl

internal class ClientDAOImpl(clientsQueries: ClientsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher, mapper: ClientMapper = ClientMapper) : ClientDAO

Constructors

ClientDAOImpl

internal constructor(clientsQueries: ClientsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher, mapper: ClientMapper = ClientMapper)

Functions

conversationRecipient

open suspend override fun conversationRecipient(ids: QualifiedIDEntity): Map<QualifiedIDEntity, List<Client>>

deleteClient

open suspend override fun deleteClient(userId: QualifiedIDEntity, clientId: String)

deleteClientsOfUserByQualifiedID

open suspend override fun deleteClientsOfUserByQualifiedID(qualifiedID: QualifiedIDEntity)

getClientsOfConversation

open suspend override fun getClientsOfConversation(id: QualifiedIDEntity): Map<QualifiedIDEntity, List<Client>>

getClientsOfUserByQualifiedID

open suspend override fun getClientsOfUserByQualifiedID(qualifiedID: QualifiedIDEntity): List<Client>

getClientsOfUserByQualifiedIDFlow

open override fun getClientsOfUserByQualifiedIDFlow(qualifiedID: QualifiedIDEntity): Flow<List<Client>>

getClientsOfUsersByQualifiedIDs

open suspend override fun getClientsOfUsersByQualifiedIDs(ids: List<QualifiedIDEntity>): Map<QualifiedIDEntity, List<Client>>

insertClient

open suspend override fun insertClient(client: InsertClientParam)

Inserts a client into the database. the isValid status is always true when inserting a client but if the client already exists then any new value will be ignored.

insertClients

open suspend override fun insertClients(clients: List<InsertClientParam>)

insertClientsAndRemoveRedundant

open suspend override fun insertClientsAndRemoveRedundant(clients: List<InsertClientParam>)

isMLSCapable

open suspend override fun isMLSCapable(userId: QualifiedIDEntity, clientId: String): Boolean?

observeClient

open override fun observeClient(userId: QualifiedIDEntity, clientId: String): Flow<Client?>

observeClientsByUserId

open override fun observeClientsByUserId(qualifiedID: QualifiedIDEntity): Flow<List<Client>>

recipientsIfTheyArePartOfConversation

open suspend override fun recipientsIfTheyArePartOfConversation(conversationId: ConversationIDEntity, userIds: Set<QualifiedIDEntity>): Map<QualifiedIDEntity, List<Client>>

Returns a map of users and their clients. the result include only users that are in the conversation

removeClientsAndReturnUsersWithNoClients

open suspend override fun removeClientsAndReturnUsersWithNoClients(redundantClientsOfUsers: Map<UserIDEntity, List<String>>): List<QualifiedIDEntity>

selectAllClients

open suspend override fun selectAllClients(): Map<QualifiedIDEntity, List<Client>>

tryMarkInvalid

open suspend override fun tryMarkInvalid(invalidClientsList: List<Pair<QualifiedIDEntity, List<String>>>)

tryMarkValid

open suspend override fun tryMarkValid(validClientsList: List<Pair<QualifiedIDEntity, List<String>>>)

updateClientProteusVerificationStatus

open suspend override fun updateClientProteusVerificationStatus(userId: QualifiedIDEntity, clientId: String, verified: Boolean)