logic/com.wire.kalium.logic.data.user/UserDataSource

UserDataSource

internal class UserDataSource(userDAO: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, clientDAO: <Error class: unknown class>, selfApi: <Error class: unknown class>, userDetailsApi: <Error class: unknown class>, teamsApi: <Error class: unknown class>, sessionRepository: SessionRepository, selfUserId: <Error class: unknown class>, selfTeamIdProvider: SelfTeamIdProvider, legalHoldHandler: LegalHoldHandler, idMapper: IdMapper = MapperProvider.idMapper(), userMapper: UserMapper = MapperProvider.userMapper(), teamMapper: TeamMapper = MapperProvider.teamMapper(), availabilityStatusMapper: AvailabilityStatusMapper = MapperProvider.availabilityStatusMapper(), userTypeEntityMapper: UserEntityTypeMapper = MapperProvider.userTypeEntityMapper(), memberMapper: MemberMapper = MapperProvider.memberMapper()) : UserRepository

Constructors

UserDataSource

internal constructor(userDAO: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, clientDAO: <Error class: unknown class>, selfApi: <Error class: unknown class>, userDetailsApi: <Error class: unknown class>, teamsApi: <Error class: unknown class>, sessionRepository: SessionRepository, selfUserId: <Error class: unknown class>, selfTeamIdProvider: SelfTeamIdProvider, legalHoldHandler: LegalHoldHandler, idMapper: IdMapper = MapperProvider.idMapper(), userMapper: UserMapper = MapperProvider.userMapper(), teamMapper: TeamMapper = MapperProvider.teamMapper(), availabilityStatusMapper: AvailabilityStatusMapper = MapperProvider.availabilityStatusMapper(), userTypeEntityMapper: UserEntityTypeMapper = MapperProvider.userTypeEntityMapper(), memberMapper: MemberMapper = MapperProvider.memberMapper())

Types

Companion

object Companion

Functions

defederateUser

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

Marks federated user as defederated in order to hold conversation history when backends stops federating.

fetchAllOtherUsers

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

Fetches user information for all of users id stored in the DB

fetchSelfUser

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

fetchUserInfo

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

fetchUsersByIds

open suspend override fun fetchUsersByIds(qualifiedUserIdList: Set<<Error class: unknown class>>): Either<CoreFailure, Unit>

fetchUsersIfUnknownByIds

open suspend override fun fetchUsersIfUnknownByIds(ids: Set<<Error class: unknown class>>): Either<CoreFailure, Unit>

fetchUsersLegalHoldConsent

open suspend override fun fetchUsersLegalHoldConsent(userIds: Set<<Error class: unknown class>>): Either<CoreFailure, <Error class: unknown class>>

getAllRecipients

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

getKnownUser

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

getKnownUserMinimized

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

getNameAndHandle

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

getOneOnOnConversationId

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

getSelfUser

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

getUsersMinimizedByQualifiedIDs

open suspend override fun getUsersMinimizedByQualifiedIDs(userIds: List<<Error class: unknown class>>): <Error class: unknown class>

getUsersSummaryByIds

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

Gets users summary by their ids.

getUsersWithOneOnOneConversation

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

insertOrIgnoreIncompleteUsers

open suspend override fun insertOrIgnoreIncompleteUsers(userIds: List<<Error class: unknown class>>): <Error class: unknown class>

insertUsersIfUnknown

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

isAtLeastOneUserATeamMember

open suspend override fun isAtLeastOneUserATeamMember(userId: List<<Error class: unknown class>>, teamId: <Error class: unknown class>): <Error class: unknown class>

markAsDeleted

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

markUserAsDeletedAndRemoveFromGroupConversations

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

observeAllKnownUsers

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

observeAllKnownUsersNotInConversation

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

observeSelfUser

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

observeSelfUserWithTeam

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

observeUser

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

removeUserBrokenAsset

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

Removes broken user asset to avoid fetching it until next sync.

syncUsersWithoutMetadata

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

Updates users without metadata from the server.

updateActiveOneOnOneConversation

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

updateActiveOneOnOneConversationIfNotSet

open suspend override fun updateActiveOneOnOneConversationIfNotSet(userId: <Error class: unknown class>, conversationId: <Error class: unknown class>): Either<CoreFailure, Unit>

updateOtherUserAvailabilityStatus

open suspend override fun updateOtherUserAvailabilityStatus(userId: <Error class: unknown class>, status: <Error class: unknown class>)

updateSelfUser

open suspend override fun ~~updateSelfUser~~(newName: String?, newAccent: Int?, newAssetId: String?): Either<CoreFailure, Unit>

updateSupportedProtocols

open suspend override fun updateSupportedProtocols(protocols: Set<<Error class: unknown class>>): Either<CoreFailure, Unit>

updateUserFromEvent

open suspend override fun updateUserFromEvent(event: Event.User.Update): Either<CoreFailure, Unit>

userById

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