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

UserDataSource

internal class UserDataSource(userDAO: UserDAO, clientDAO: ClientDAO, memberDAO: MemberDAO, appDAO: AppDAO, selfApi: SelfApi, userDetailsApi: UserDetailsApi, upgradePersonalToTeamApi: UpgradePersonalToTeamApi, teamsApi: TeamsApi, sessionRepository: SessionRepository, selfUserId: UserId, 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(), appMapper: AppMapper = MapperProvider.appMapper()) : UserRepository

Constructors

UserDataSource

internal constructor(userDAO: UserDAO, clientDAO: ClientDAO, memberDAO: MemberDAO, appDAO: AppDAO, selfApi: SelfApi, userDetailsApi: UserDetailsApi, upgradePersonalToTeamApi: UpgradePersonalToTeamApi, teamsApi: TeamsApi, sessionRepository: SessionRepository, selfUserId: UserId, 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(), appMapper: AppMapper = MapperProvider.appMapper())

Types

Companion

object Companion

Functions

defederateUser

open suspend override fun defederateUser(userId: UserId): 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: UserId): Either<CoreFailure, Unit>

fetchUsersByIds

open suspend override fun fetchUsersByIds(qualifiedUserIdList: Set<UserId>): Either<CoreFailure, Boolean>

fetchUsersIfUnknownByIds

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

fetchUsersLegalHoldConsent

open suspend override fun fetchUsersLegalHoldConsent(userIds: Set<UserId>): Either<CoreFailure, ListUsersLegalHoldConsent>

getAllRecipients

open suspend override fun getAllRecipients(): Either<CoreFailure, Pair<List<Recipient>, List<Recipient>>>

getKnownUser

open suspend override fun getKnownUser(userId: UserId): Flow<OtherUser?>

getKnownUserMinimized

open suspend override fun getKnownUserMinimized(userId: UserId): Either<StorageFailure, OtherUserMinimized>

getNameAndHandle

open suspend override fun getNameAndHandle(userId: UserId): Either<StorageFailure, NameAndHandle>

getOneOnOnConversationId

open suspend override fun getOneOnOnConversationId(userId: QualifiedID): Either<StorageFailure, ConversationId>

getSelfUser

open suspend override fun getSelfUser(): Either<StorageFailure, SelfUser>

getUsersMinimizedByQualifiedIDs

open suspend override fun getUsersMinimizedByQualifiedIDs(userIds: List<UserId>): Either<StorageFailure, List<OtherUserMinimized>>

getUsersSummaryByIds

open suspend override fun getUsersSummaryByIds(userIds: List<QualifiedID>): Either<StorageFailure, List<UserSummary>>

Gets users summary by their ids.

getUsersWithOneOnOneConversation

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

insertOrIgnoreIncompleteUsers

open suspend override fun insertOrIgnoreIncompleteUsers(userIds: List<QualifiedID>): Either<StorageFailure, Unit>

insertSelfIncompleteUserWithOnlyEmail

open suspend override fun insertSelfIncompleteUserWithOnlyEmail(email: String): Either<CoreFailure, Unit>

insertUsersIfUnknown

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

isAtLeastOneUserATeamMember

open suspend override fun isAtLeastOneUserATeamMember(userId: List<UserId>, teamId: TeamId): Either<StorageFailure, Boolean>

isClientMlsCapable

open suspend override fun isClientMlsCapable(userId: UserId, clientId: ClientId): Either<StorageFailure, Boolean>

markAsDeleted

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

markUserAsDeletedAndRemoveFromGroupConversations

open suspend override fun markUserAsDeletedAndRemoveFromGroupConversations(userId: UserId): Either<CoreFailure, List<ConversationId>>

migrateUserToTeam

open suspend override fun migrateUserToTeam(teamName: String): Either<CoreFailure, CreateUserTeam>

observeAllKnownUsers

open suspend override fun observeAllKnownUsers(): Flow<Either<StorageFailure, List<OtherUser>>>

observeAllKnownUsersNotInConversation

open override fun observeAllKnownUsersNotInConversation(conversationId: ConversationId): Flow<Either<StorageFailure, List<OtherUser>>>

observeSelfUser

open suspend override fun observeSelfUser(): Flow<SelfUser>

observeSelfUserWithTeam

open suspend override fun observeSelfUserWithTeam(): Flow<Pair<SelfUser, Team?>>

observeUser

open suspend override fun observeUser(userId: UserId): Flow<User?>

removeUserBrokenAsset

open suspend override fun removeUserBrokenAsset(qualifiedID: QualifiedID): Either<StorageFailure, Unit>

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: UserId, conversationId: ConversationId): Either<CoreFailure, Unit>

updateActiveOneOnOneConversationIfNotSet

open suspend override fun updateActiveOneOnOneConversationIfNotSet(userId: UserId, conversationId: ConversationId): Either<CoreFailure, Unit>

updateOtherUserAvailabilityStatus

open suspend override fun updateOtherUserAvailabilityStatus(userId: UserId, status: UserAvailabilityStatus)

updateSelfUser

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

updateSupportedProtocols

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

updateTeamId

open suspend override fun updateTeamId(userId: UserId, teamId: TeamId): Either<StorageFailure, Unit>

updateUserFromEvent

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

userById

open suspend override fun userById(userId: UserId): Either<CoreFailure, OtherUser>