logic/com.wire.kalium.logic.data.conversation/ConversationDataSource

ConversationDataSource

internal class ConversationDataSource(selfUserId: <Error class: unknown class>, mlsClientProvider: MLSClientProvider, selfTeamIdProvider: SelfTeamIdProvider, conversationDAO: <Error class: unknown class>, memberDAO: <Error class: unknown class>, conversationApi: <Error class: unknown class>, messageDAO: <Error class: unknown class>, messageDraftDAO: <Error class: unknown class>, clientDAO: <Error class: unknown class>, clientApi: <Error class: unknown class>, conversationMetaDataDAO: <Error class: unknown class>, idMapper: IdMapper = MapperProvider.idMapper(), conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), memberMapper: MemberMapper = MapperProvider.memberMapper(), conversationStatusMapper: ConversationStatusMapper = MapperProvider.conversationStatusMapper(), conversationRoleMapper: ConversationRoleMapper = MapperProvider.conversationRoleMapper(), protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper(), receiptModeMapper: ReceiptModeMapper = MapperProvider.receiptModeMapper()) : ConversationRepository

Constructors

internal constructor(selfUserId: <Error class: unknown class>, mlsClientProvider: MLSClientProvider, selfTeamIdProvider: SelfTeamIdProvider, conversationDAO: <Error class: unknown class>, memberDAO: <Error class: unknown class>, conversationApi: <Error class: unknown class>, messageDAO: <Error class: unknown class>, messageDraftDAO: <Error class: unknown class>, clientDAO: <Error class: unknown class>, clientApi: <Error class: unknown class>, conversationMetaDataDAO: <Error class: unknown class>, idMapper: IdMapper = MapperProvider.idMapper(), conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), memberMapper: MemberMapper = MapperProvider.memberMapper(), conversationStatusMapper: ConversationStatusMapper = MapperProvider.conversationStatusMapper(), conversationRoleMapper: ConversationRoleMapper = MapperProvider.conversationRoleMapper(), protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper(), receiptModeMapper: ReceiptModeMapper = MapperProvider.receiptModeMapper())

Types

Companion

object Companion

Properties

extensions

open override val extensions: ConversationRepositoryExtensions

Functions

changeConversationName

open suspend override fun changeConversationName(conversationId: <Error class: unknown class>, conversationName: String): Either<CoreFailure, <Error class: unknown class>>

clearContent

open suspend override fun clearContent(conversationId: <Error class: unknown class>): Either<StorageFailure, Unit>

Deletes all conversation messages

deleteConversation

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

fetchConversation

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

fetchConversationIfUnknown

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

fetchConversations

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

fetchMlsOneToOneConversation

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

fetchSentConnectionConversation

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

getConversationById

open suspend override fun getConversationById(conversationId: <Error class: unknown class>): Either<StorageFailure, <Error class: unknown class>>

getConversationDetailsByMLSGroupId

open suspend override fun getConversationDetailsByMLSGroupId(mlsGroupId: <Error class: unknown class>): Either<CoreFailure, <Error class: unknown class>>

getConversationIds

open suspend override fun getConversationIds(type: <Error class: unknown class>, protocol: <Error class: unknown class>, teamId: <Error class: unknown class>?): Either<StorageFailure, List<<Error class: unknown class>>>

getConversationList

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

getConversationMembers

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

Fetches a list of all members' IDs or a given conversation including self user

getConversationProtocolInfo

open suspend override fun getConversationProtocolInfo(conversationId: <Error class: unknown class>): Either<StorageFailure, <Error class: unknown class>>

getConversationRecipients

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

Fetches a list of all recipients for a given conversation including this very client

getConversationRecipientsForCalling

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

Fetches a list of all recipients for a given conversation including this very client

getConversationsByGroupState

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

getConversationsByUserId

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

getConversationTypeById

open suspend override fun getConversationTypeById(conversationId: <Error class: unknown class>): Either<StorageFailure, <Error class: unknown class>>

getConversationUnreadEventsCount

open suspend override fun getConversationUnreadEventsCount(conversationId: <Error class: unknown class>): Either<StorageFailure, Long>

getGroupConversationsWithMembersWithBothDomains

open suspend override fun getGroupConversationsWithMembersWithBothDomains(firstDomain: String, secondDomain: String): Either<CoreFailure, <Error class: unknown class>>

getGroupStatusMembersNamesAndHandles

open suspend override fun getGroupStatusMembersNamesAndHandles(groupID: <Error class: unknown class>): Either<StorageFailure, EpochChangesData>

getMLSSelfConversationId

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

getOneOnOneConversationsWithFederatedMembers

open suspend override fun getOneOnOneConversationsWithFederatedMembers(domain: String): Either<CoreFailure, <Error class: unknown class>>

getOneOnOneConversationsWithOtherUser

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

getProteusSelfConversationId

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

getRecipientById

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

getTeamConversationIdsReadyToCompleteMigration

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

insertConversations

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

isInformedAboutDegradedMLSVerification

open suspend override fun isInformedAboutDegradedMLSVerification(conversationId: <Error class: unknown class>): Either<StorageFailure, Boolean>

observeConversationById

open suspend override fun observeConversationById(conversationId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, <Error class: unknown class>>>

observeConversationDetailsById

open suspend override fun observeConversationDetailsById(conversationID: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, <Error class: unknown class>>>

observeConversationList

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

observeConversationListDetails

open suspend override fun observeConversationListDetails(fromArchive: Boolean, conversationFilter: <Error class: unknown class>): <Error class: unknown class><List<<Error class: unknown class>>>

observeConversationListDetailsWithEvents

open suspend override fun observeConversationListDetailsWithEvents(fromArchive: Boolean, conversationFilter: <Error class: unknown class>): <Error class: unknown class><List<<Error class: unknown class>>>

observeConversationMembers

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

observeDegradedConversationNotified

open suspend override fun observeDegradedConversationNotified(conversationId: <Error class: unknown class>): <Error class: unknown class><Boolean>

observeIsUserMember

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

observeLegalHoldStatus

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

observeLegalHoldStatusChangeNotified

open suspend override fun observeLegalHoldStatusChangeNotified(conversationId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, Boolean>>

observeOneToOneConversationWithOtherUser

open suspend override fun observeOneToOneConversationWithOtherUser(otherUserId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, <Error class: unknown class>>>

observeUnreadArchivedConversationsCount

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

persistConversation

open suspend override fun persistConversation(conversation: <Error class: unknown class>, selfUserTeamId: String?, originatedFromEvent: Boolean): Either<CoreFailure, Boolean>

Creates a conversation from a new event

persistConversations

open suspend override fun persistConversations(conversations: List<<Error class: unknown class>>, selfUserTeamId: <Error class: unknown class>?, originatedFromEvent: Boolean, invalidateMembers: Boolean): Either<StorageFailure, Unit>

persistMembers

open suspend override fun persistMembers(members: List<<Error class: unknown class>>, conversationID: <Error class: unknown class>): Either<CoreFailure, Unit>

selectMembersNameAndHandle

open suspend override fun selectMembersNameAndHandle(conversationId: <Error class: unknown class>): Either<StorageFailure, Map<<Error class: unknown class>, NameAndHandle>>

sendTypingIndicatorStatus

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

setDegradedConversationNotifiedFlag

open suspend override fun setDegradedConversationNotifiedFlag(conversationId: <Error class: unknown class>, value: Boolean): Either<CoreFailure, Unit>

setInformedAboutDegradedMLSVerificationFlag

open suspend override fun setInformedAboutDegradedMLSVerificationFlag(conversationId: <Error class: unknown class>, isInformed: Boolean): Either<StorageFailure, Unit>

setLegalHoldStatusChangeNotified

open suspend override fun setLegalHoldStatusChangeNotified(conversationId: <Error class: unknown class>): Either<CoreFailure, Boolean>

syncConversationsWithoutMetadata

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

updateAccessInfo

open suspend override fun updateAccessInfo(conversationID: <Error class: unknown class>, access: Set<<Error class: unknown class>>, accessRole: Set<<Error class: unknown class>>): Either<CoreFailure, Unit>

updateAllConversationsNotificationDate

open suspend override fun updateAllConversationsNotificationDate(): Either<StorageFailure, Unit>

updateArchivedStatusLocally

open suspend override fun updateArchivedStatusLocally(conversationId: <Error class: unknown class>, isArchived: Boolean, archivedStatusTimestamp: Long): Either<StorageFailure, Unit>

updateArchivedStatusRemotely

open suspend override fun updateArchivedStatusRemotely(conversationId: <Error class: unknown class>, isArchived: Boolean, archivedStatusTimestamp: Long): Either<NetworkFailure, Unit>

updateConversationGroupState

open suspend override fun updateConversationGroupState(groupID: <Error class: unknown class>, groupState: <Error class: unknown class>): Either<StorageFailure, Unit>

updateConversationMemberRole

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

Updates the conversation member role, both remotely and local

updateConversationModifiedDate

open suspend override fun updateConversationModifiedDate(qualifiedID: <Error class: unknown class>, date: <Error class: unknown class>): Either<StorageFailure, Unit>

updateConversationNotificationDate

open suspend override fun updateConversationNotificationDate(qualifiedID: <Error class: unknown class>): Either<StorageFailure, Unit>

updateConversationReadDate

open suspend override fun updateConversationReadDate(qualifiedID: <Error class: unknown class>, date: <Error class: unknown class>): Either<StorageFailure, Unit>

Update the conversation seen date, which is a date when the user sees the content of the conversation.

updateLegalHoldStatus

open suspend override fun updateLegalHoldStatus(conversationId: <Error class: unknown class>, legalHoldStatus: <Error class: unknown class>): Either<CoreFailure, Boolean>

updateMemberFromEvent

open suspend override fun updateMemberFromEvent(member: <Error class: unknown class>, conversationID: <Error class: unknown class>): Either<CoreFailure, Unit>

updateMlsVerificationStatus

open suspend override fun updateMlsVerificationStatus(verificationStatus: <Error class: unknown class>, conversationID: <Error class: unknown class>): Either<CoreFailure, Unit>

updateMutedStatusLocally

open suspend override fun updateMutedStatusLocally(conversationId: <Error class: unknown class>, mutedStatus: <Error class: unknown class>, mutedStatusTimestamp: Long): Either<StorageFailure, Unit>

updateMutedStatusRemotely

open suspend override fun updateMutedStatusRemotely(conversationId: <Error class: unknown class>, mutedStatus: <Error class: unknown class>, mutedStatusTimestamp: Long): Either<NetworkFailure, Unit>

updateProtocolLocally

open suspend override fun updateProtocolLocally(conversationId: <Error class: unknown class>, protocol: <Error class: unknown class>): Either<CoreFailure, Boolean>

Update a conversation's protocol locally.

updateProtocolRemotely

open suspend override fun updateProtocolRemotely(conversationId: <Error class: unknown class>, protocol: <Error class: unknown class>): Either<CoreFailure, Boolean>

Update a conversation's protocol remotely.

updateReceiptMode

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

updateUserSelfDeletionTimer

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

whoDeletedMe

open suspend override fun whoDeletedMe(conversationId: <Error class: unknown class>): Either<CoreFailure, <Error class: unknown class>?>