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

UserDAOImpl

class UserDAOImpl(userQueries: UsersQueries, userCache: FlowCache<UserIDEntity, UserDetailsEntity?>, queriesContext: <Error class: unknown class>) : UserDAO

Constructors

UserDAOImpl

internal constructor(userQueries: UsersQueries, userCache: FlowCache<UserIDEntity, UserDetailsEntity?>, queriesContext: <Error class: unknown class>)

Properties

mapper

val mapper: UserMapper

Functions

allOtherUsersId

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

deleteUserByQualifiedID

open suspend override fun deleteUserByQualifiedID(qualifiedID: QualifiedIDEntity): <Error class: unknown class>

getAllUsersDetails

open suspend override fun getAllUsersDetails(): <Error class: unknown class><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?

getUserDetailsByHandleAndConnectionStates

open suspend override fun getUserDetailsByHandleAndConnectionStates(handle: String, connectionStates: List<ConnectionEntity.State>): <Error class: unknown class>

getUserDetailsByNameOrHandleOrEmailAndConnectionStates

open suspend override fun getUserDetailsByNameOrHandleOrEmailAndConnectionStates(searchQuery: String, connectionStates: List<ConnectionEntity.State>): <Error class: unknown class><List<UserDetailsEntity>>

getUserDetailsWithTeamByQualifiedID

open suspend override fun getUserDetailsWithTeamByQualifiedID(qualifiedID: QualifiedIDEntity): <Error class: unknown class><<Error class: unknown class><UserDetailsEntity, TeamEntity?>?>

getUserMinimizedByQualifiedID

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

getUsersDetailsByQualifiedIDList

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

getUsersDetailsNotInConversationByHandle

open suspend override fun getUsersDetailsNotInConversationByHandle(conversationId: QualifiedIDEntity, handle: String): <Error class: unknown class><List<UserDetailsEntity>>

getUsersDetailsNotInConversationByNameOrHandleOrEmail

open suspend override fun getUsersDetailsNotInConversationByNameOrHandleOrEmail(conversationId: QualifiedIDEntity, searchQuery: String): <Error class: unknown class><List<UserDetailsEntity>>

getUsersDetailsWithoutMetadata

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

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>): <Error class: unknown class>

insertOrIgnoreUsers

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

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 suspend override fun observeAllUsersDetailsByConnectionStatus(connectionState: ConnectionEntity.State): <Error class: unknown class><List<UserDetailsEntity>>

observeUserDetailsByQualifiedID

open suspend override fun observeUserDetailsByQualifiedID(qualifiedID: QualifiedIDEntity): <Error class: unknown class><UserDetailsEntity?>

observeUsersDetailsNotInConversation

open override fun observeUsersDetailsNotInConversation(conversationId: QualifiedIDEntity): <Error class: unknown class><List<UserDetailsEntity>>

removeUserAsset

open suspend override fun removeUserAsset(assetId: QualifiedIDEntity)

updateActiveOneOnOneConversation

open suspend override fun updateActiveOneOnOneConversation(userId: QualifiedIDEntity, conversationId: QualifiedIDEntity): <Error class: unknown class>

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): <Error class: unknown class>

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

updateUser

open suspend override fun updateUser(update: PartialUserEntity): <Error class: unknown class>

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>): <Error class: unknown class>

updateUserAvailabilityStatus

open suspend override fun updateUserAvailabilityStatus(qualifiedID: QualifiedIDEntity, status: UserAvailabilityStatusEntity): <Error class: unknown class>

updateUserDisplayName

open suspend override fun updateUserDisplayName(selfUserId: QualifiedIDEntity, displayName: String): <Error class: unknown class>

updateUserHandle

open suspend override fun updateUserHandle(qualifiedID: QualifiedIDEntity, handle: String): <Error class: unknown class>

updateUserSupportedProtocols

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

upsertConnectionStatuses

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

upsertTeamMemberUserTypes

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

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>): <Error class: unknown class>

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