persistence/com.wire.kalium.persistence.dao/UserDAOImpl

UserDAOImpl

class UserDAOImpl(userQueries: UsersQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher) : UserDAO

Constructors

UserDAOImpl

internal constructor(userQueries: UsersQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

Properties

mapper

val mapper: UserMapper

Functions

allOtherUsersId

open suspend override fun allOtherUsersId(): List<UserIDEntity>

countContactsAmount

open suspend override fun countContactsAmount(selfUserId: QualifiedIDEntity): Int

countTeamMembersAmount

open suspend override fun countTeamMembersAmount(teamId: String): Int

deleteUserByQualifiedID

open suspend override fun deleteUserByQualifiedID(qualifiedID: QualifiedIDEntity)

getAllUsersDetails

open override fun getAllUsersDetails(): Flow<List<UserDetailsEntity>>

getAllUsersDetailsByTeam

open suspend override fun getAllUsersDetailsByTeam(teamId: String): List<UserDetailsEntity>

getNameAndHandle

open suspend override fun getNameAndHandle(userId: UserIDEntity): NameAndHandleEntity?

getOneOnOnConversationId

open suspend override fun getOneOnOnConversationId(userId: UserIDEntity): QualifiedIDEntity?

getTeamIdByQualifiedID

open suspend override fun getTeamIdByQualifiedID(qualifiedID: QualifiedIDEntity): String?

getUserDetailsByHandleAndConnectionStates

open override fun getUserDetailsByHandleAndConnectionStates(handle: String, connectionStates: List<ConnectionEntity.State>): Flow<List<UserDetailsEntity>>

getUserDetailsByNameOrHandleOrEmailAndConnectionStates

open override fun getUserDetailsByNameOrHandleOrEmailAndConnectionStates(searchQuery: String, connectionStates: List<ConnectionEntity.State>): Flow<List<UserDetailsEntity>>

getUserDetailsByQualifiedID

open suspend override fun getUserDetailsByQualifiedID(qualifiedID: QualifiedIDEntity): UserDetailsEntity?

getUserDetailsWithTeamByQualifiedID

open override fun getUserDetailsWithTeamByQualifiedID(qualifiedID: QualifiedIDEntity): Flow<Pair<UserDetailsEntity, TeamEntity?>?>

getUserMinimizedByQualifiedID

open suspend override fun getUserMinimizedByQualifiedID(qualifiedID: QualifiedIDEntity): UserEntityMinimized?

getUsersDetailsByQualifiedIDList

open suspend override fun getUsersDetailsByQualifiedIDList(qualifiedIDList: List<QualifiedIDEntity>): List<UserDetailsEntity>

getUsersDetailsNotInConversationByHandle

open override fun getUsersDetailsNotInConversationByHandle(conversationId: QualifiedIDEntity, handle: String): Flow<List<UserDetailsEntity>>

getUsersDetailsNotInConversationByNameOrHandleOrEmail

open override fun getUsersDetailsNotInConversationByNameOrHandleOrEmail(conversationId: QualifiedIDEntity, searchQuery: String): Flow<List<UserDetailsEntity>>

getUsersDetailsWithoutMetadata

open suspend override fun getUsersDetailsWithoutMetadata(): List<UserDetailsEntity>

getUsersMinimizedByQualifiedIDs

open suspend override fun getUsersMinimizedByQualifiedIDs(qualifiedIDs: List<QualifiedIDEntity>): List<UserEntityMinimized>

getUsersWithOneOnOneConversation

open suspend override fun getUsersWithOneOnOneConversation(): List<UserEntity>

insertOrIgnoreIncompleteUsers

open suspend override fun insertOrIgnoreIncompleteUsers(userIds: List<QualifiedIDEntity>)

insertOrIgnoreIncompleteUserWithOnlyEmail

open suspend override fun insertOrIgnoreIncompleteUserWithOnlyEmail(userId: QualifiedIDEntity, email: String)

insertOrIgnoreUsers

open suspend override fun insertOrIgnoreUsers(users: List<UserEntity>)

Inserts each user into the local storage or ignores if already exists

isAtLeastOneUserATeamMember

open suspend override fun isAtLeastOneUserATeamMember(userId: List<UserIDEntity>, teamId: String): Boolean

markAsDeleted

open suspend override fun markAsDeleted(userId: List<UserIDEntity>)

markUserAsDefederated

open suspend override fun markUserAsDefederated(qualifiedID: QualifiedIDEntity)

markUserAsDeletedAndRemoveFromGroupConv

open suspend override fun markUserAsDeletedAndRemoveFromGroupConv(qualifiedID: QualifiedIDEntity): List<ConversationIDEntity>

observeAllUsersDetailsByConnectionStatus

open override fun observeAllUsersDetailsByConnectionStatus(connectionState: ConnectionEntity.State): Flow<List<UserDetailsEntity>>

observeUserDetailsByQualifiedID

open suspend override fun observeUserDetailsByQualifiedID(qualifiedID: QualifiedIDEntity): Flow<UserDetailsEntity?>

observeUsersDetailsNotInConversation

open override fun observeUsersDetailsNotInConversation(conversationId: QualifiedIDEntity): Flow<List<UserDetailsEntity>>

removeUserAsset

open suspend override fun removeUserAsset(assetId: QualifiedIDEntity)

updateActiveOneOnOneConversation

open suspend override fun updateActiveOneOnOneConversation(userId: QualifiedIDEntity, conversationId: QualifiedIDEntity)

Update which 1-1 conversation is the currently active one. If multiple encryption protocols are enabled there can be multiple co-existing 1-1 conversations.

updateActiveOneOnOneConversationIfNotSet

open suspend override fun updateActiveOneOnOneConversationIfNotSet(userId: QualifiedIDEntity, conversationId: QualifiedIDEntity)

Update which 1-1 conversation iff it was not set before.

updateTeamId

open suspend override fun updateTeamId(userId: UserIDEntity, teamId: String)

updateUser

open suspend override fun updateUser(update: PartialUserEntity)

Perform a partial update of an existing user. Only non-null values will be updated otherwise the existing value is kept.

open suspend override fun updateUser(users: List<PartialUserEntity>)

updateUserAccentColor

open suspend override fun updateUserAccentColor(selfUserId: QualifiedIDEntity, accentId: Int)

updateUserAvailabilityStatus

open suspend override fun updateUserAvailabilityStatus(qualifiedID: QualifiedIDEntity, status: UserAvailabilityStatusEntity)

updateUserDisplayName

open suspend override fun updateUserDisplayName(selfUserId: QualifiedIDEntity, displayName: String)

updateUserHandle

open suspend override fun updateUserHandle(qualifiedID: QualifiedIDEntity, handle: String)

updateUserSupportedProtocols

open suspend override fun updateUserSupportedProtocols(selfUserId: QualifiedIDEntity, supportedProtocols: Set<SupportedProtocolEntity>)

upsertConnectionStatuses

open suspend override fun upsertConnectionStatuses(userStatuses: Map<QualifiedIDEntity, ConnectionEntity.State>)

upsertTeamMemberUserTypes

open suspend override fun upsertTeamMemberUserTypes(users: Map<QualifiedIDEntity, UserTypeEntity>)

This will update UserEntity.team, UserEntity.userType, UserEntity.connectionStatus to ConnectionEntity.State.ACCEPTED or insert a new record.

upsertUser

open suspend override fun upsertUser(user: UserEntity)

This will update all columns (or insert a new record), except:

upsertUsers

open suspend override fun upsertUsers(users: List<UserEntity>)

This will update all columns (or insert a new record), except: