persistence/com.wire.kalium.persistence.dao.conversation/ConversationDAO

ConversationDAO

interface ConversationDAO

Inheritors

ConversationDAOImpl

Properties

platformExtensions

abstract val platformExtensions: ConversationExtensions

Functions

abstract suspend fun clearContent(conversationId: QualifiedIDEntity)

clearProposalTimer

abstract suspend fun clearProposalTimer(groupID: String)

deleteConversationByQualifiedID

abstract suspend fun deleteConversationByQualifiedID(qualifiedID: QualifiedIDEntity): Boolean

deleteGuestRoomLink

abstract suspend fun deleteGuestRoomLink(conversationId: QualifiedIDEntity)

getAllConversationDetails

abstract fun getAllConversationDetails(fromArchive: Boolean, filter: ConversationFilterEntity, strictMLSFilter: Boolean = true): Flow<List<ConversationViewEntity>>

getAllConversationDetailsWithEvents

abstract fun getAllConversationDetailsWithEvents(fromArchive: Boolean = false, onlyInteractionEnabled: Boolean = false, newActivitiesOnTop: Boolean = false, ongoingCallConversationIds: List<QualifiedIDEntity> = emptyList(), strictMLSFilter: Boolean = true): Flow<List<ConversationDetailsWithEventsEntity>>

getAllConversations

abstract fun getAllConversations(): Flow<List<ConversationEntity>>

getAllConversationsWithOtherUserName

abstract fun getAllConversationsWithOtherUserName(selfUserId: QualifiedIDEntity): Flow<List<ConversationWithOtherUserNameEntity>>

getCellGroupConversations

abstract suspend fun getCellGroupConversations(): List<ConversationEntity>

getCellGroupConversationsPaged

abstract suspend fun getCellGroupConversationsPaged(limit: Int, offset: Int, query: String = ""): List<ConversationEntity>

abstract suspend fun getCellName(conversationId: QualifiedIDEntity): String?

getConversationByGroupID

abstract suspend fun getConversationByGroupID(groupID: String): ConversationEntity?

getConversationById

abstract suspend fun getConversationById(qualifiedID: QualifiedIDEntity): ConversationEntity?

getConversationDetailsById

abstract suspend fun getConversationDetailsById(qualifiedID: QualifiedIDEntity): ConversationViewEntity?

getConversationIdByGroupID

abstract suspend fun getConversationIdByGroupID(groupID: String): QualifiedIDEntity?

getConversationIds

abstract suspend fun getConversationIds(type: ConversationEntity.Type, protocol: ConversationEntity.Protocol, teamId: String? = null): List<QualifiedIDEntity>

getConversationLastReadDate

abstract suspend fun getConversationLastReadDate(qualifiedID: QualifiedIDEntity): Instant?

getConversationProtocolInfo

abstract suspend fun getConversationProtocolInfo(qualifiedID: QualifiedIDEntity): ConversationEntity.ProtocolInfo?

getConversationsByGroupState

abstract suspend fun getConversationsByGroupState(groupState: ConversationEntity.GroupState): List<ConversationEntity>

getConversationsByIds

abstract suspend fun getConversationsByIds(qualifiedIDs: List<QualifiedIDEntity>): List<ConversationEntity>

getConversationsByKeyingMaterialUpdate

abstract suspend fun getConversationsByKeyingMaterialUpdate(threshold: Duration): List<String>

getConversationsByUserId

abstract suspend fun getConversationsByUserId(userId: UserIDEntity): List<ConversationEntity>

getConversationsWithoutMetadata

abstract suspend fun getConversationsWithoutMetadata(): List<QualifiedIDEntity>

getE2EIConversationClientInfoByClientId

abstract suspend fun getE2EIConversationClientInfoByClientId(clientId: String): E2EIConversationClientInfoEntity?

getEstablishedSelfMLSGroupId

abstract suspend fun getEstablishedSelfMLSGroupId(): String?

getMLSConversationsByDomain

abstract suspend fun getMLSConversationsByDomain(domain: String): List<ConversationEntity>

getMLSGroupIdByConversationId

abstract suspend fun getMLSGroupIdByConversationId(conversationId: QualifiedIDEntity): String?

getMLSGroupIdByUserId

abstract suspend fun getMLSGroupIdByUserId(userId: UserIDEntity): String?

getNonDeletedConversationById

abstract suspend fun getNonDeletedConversationById(qualifiedID: QualifiedIDEntity): ConversationEntity?

getOneOnOneConversationIdsWithOtherUser

abstract suspend fun getOneOnOneConversationIdsWithOtherUser(userId: UserIDEntity, protocol: ConversationEntity.Protocol): List<QualifiedIDEntity>

getProposalTimers

abstract fun getProposalTimers(): Flow<List<ProposalTimerEntity>>

getSelfConversationId

abstract suspend fun getSelfConversationId(protocol: ConversationEntity.Protocol): QualifiedIDEntity?

getTeamConversationIdsReadyToCompleteMigration

abstract suspend fun getTeamConversationIdsReadyToCompleteMigration(teamId: String): List<QualifiedIDEntity>

hasConversationWithCell

abstract suspend fun hasConversationWithCell(): Boolean

insertAdminlessGroupDelete

abstract suspend fun insertAdminlessGroupDelete(conversationId: QualifiedIDEntity, deletionTimestamp: Instant)

insertConversation

abstract suspend fun insertConversation(conversationEntity: ConversationEntity)

insertConversations

abstract suspend fun insertConversations(conversationEntities: List<ConversationEntity>)

insertOrUpdateLastModified

abstract suspend fun insertOrUpdateLastModified(conversationEntities: List<ConversationEntity>)

observeConversationById

abstract suspend fun observeConversationById(qualifiedID: QualifiedIDEntity): Flow<ConversationEntity?>

observeConversationDetailsById

abstract suspend fun observeConversationDetailsById(conversationId: QualifiedIDEntity): Flow<ConversationViewEntity?>

observeDegradedConversationNotified

abstract fun observeDegradedConversationNotified(conversationId: QualifiedIDEntity): Flow<Boolean>

observeGuestRoomLinkByConversationId

abstract fun observeGuestRoomLinkByConversationId(conversationId: QualifiedIDEntity): Flow<ConversationGuestLinkEntity?>

observeHasConversationWithCell

abstract suspend fun observeHasConversationWithCell(): Flow<Boolean>

observeLegalHoldStatus

abstract fun observeLegalHoldStatus(conversationId: QualifiedIDEntity): Flow<ConversationEntity.LegalHoldStatus>

observeLegalHoldStatusChangeNotified

abstract fun observeLegalHoldStatusChangeNotified(conversationId: QualifiedIDEntity): Flow<Boolean>

observeOneOnOneConversationDetailsWithOtherUser

abstract fun observeOneOnOneConversationDetailsWithOtherUser(userId: UserIDEntity): Flow<ConversationViewEntity?>

observeOneOnOneConversationWithOtherUser

abstract fun observeOneOnOneConversationWithOtherUser(userId: UserIDEntity): Flow<ConversationEntity?>

observeUnreadArchivedConversationsCount

abstract fun observeUnreadArchivedConversationsCount(): Flow<Long>

selectGroupStatusMembersNamesAndHandles

abstract suspend fun selectGroupStatusMembersNamesAndHandles(groupID: String): EpochChangesDataEntity?

setConversationDeletedLocally

abstract suspend fun setConversationDeletedLocally(qualifiedID: QualifiedIDEntity, deletedLocally: Boolean)

setProposalTimer

abstract suspend fun setProposalTimer(proposalTimer: ProposalTimerEntity)

abstract suspend fun updateAccess(conversationID: QualifiedIDEntity, accessList: List<ConversationEntity.Access>, accessRoleList: List<ConversationEntity.AccessRole>)

updateAllConversationsNotificationDate

abstract suspend fun updateAllConversationsNotificationDate()

updateChannelAddPermission

abstract suspend fun updateChannelAddPermission(conversationId: QualifiedIDEntity, channelAddPermission: ConversationEntity.ChannelAddPermission)

updateConversation

abstract suspend fun updateConversation(conversationEntity: ConversationEntity)

updateConversationArchivedStatus

abstract suspend fun updateConversationArchivedStatus(conversationId: QualifiedIDEntity, isArchived: Boolean, archivedStatusTimestamp: Instant)

updateConversationGroupState

abstract suspend fun updateConversationGroupState(groupState: ConversationEntity.GroupState, groupId: String)

updateConversationGroupStateByConversationId

abstract suspend fun updateConversationGroupStateByConversationId(groupState: ConversationEntity.GroupState, conversationId: QualifiedIDEntity)

updateConversationModifiedDate

abstract suspend fun updateConversationModifiedDate(qualifiedID: QualifiedIDEntity, date: Instant)

updateConversationModifiedDateToMaxOfSources

abstract suspend fun updateConversationModifiedDateToMaxOfSources(targetId: QualifiedIDEntity, sourceIds: Collection<QualifiedIDEntity>)

updateConversationMutedStatus

abstract suspend fun updateConversationMutedStatus(conversationId: QualifiedIDEntity, mutedStatus: ConversationEntity.MutedStatus, mutedStatusTimestamp: Instant)

updateConversationName

abstract suspend fun updateConversationName(conversationId: QualifiedIDEntity, conversationName: String, dateTime: Instant)

updateConversationNotificationDate

abstract suspend fun updateConversationNotificationDate(qualifiedID: QualifiedIDEntity, date: Instant? = null)

updateConversationProtocolAndCipherSuite

abstract suspend fun updateConversationProtocolAndCipherSuite(conversationId: QualifiedIDEntity, groupID: String?, protocol: ConversationEntity.Protocol, cipherSuite: ConversationEntity.CipherSuite): Boolean

updateConversationReadAndModifiedDates

abstract suspend fun updateConversationReadAndModifiedDates(readDates: Map<QualifiedIDEntity, Instant>, modifiedDates: Map<QualifiedIDEntity, Instant>)

updateConversationReadDate

abstract suspend fun updateConversationReadDate(conversationID: QualifiedIDEntity, date: Instant)

updateConversationReadDates

abstract suspend fun updateConversationReadDates(conversationDates: Map<QualifiedIDEntity, Instant>): Int

updateConversationReceiptMode

abstract suspend fun updateConversationReceiptMode(conversationID: QualifiedIDEntity, receiptMode: ConversationEntity.ReceiptMode)

updateConversationType

abstract suspend fun updateConversationType(conversationID: QualifiedIDEntity, type: ConversationEntity.Type)

updateDegradedConversationNotifiedFlag

abstract suspend fun updateDegradedConversationNotifiedFlag(conversationId: QualifiedIDEntity, updateFlag: Boolean)

updateGuestRoomLink

abstract suspend fun updateGuestRoomLink(conversationId: QualifiedIDEntity, link: String, isPasswordProtected: Boolean)

updateKeyingMaterial

abstract suspend fun updateKeyingMaterial(groupId: String, timestamp: Instant)

updateLegalHoldStatus

abstract suspend fun updateLegalHoldStatus(conversationId: QualifiedIDEntity, legalHoldStatus: ConversationEntity.LegalHoldStatus): Boolean

updateLegalHoldStatusChangeNotified

abstract suspend fun updateLegalHoldStatusChangeNotified(conversationId: QualifiedIDEntity, notified: Boolean): Boolean

updateMessageTimer

abstract suspend fun updateMessageTimer(conversationId: QualifiedIDEntity, messageTimer: Long?)

updateMLSGroupIdAndState

abstract suspend fun updateMLSGroupIdAndState(conversationId: QualifiedIDEntity, newGroupId: String, newEpoch: Long, groupState: ConversationEntity.GroupState)

updateMlsGroupStateAndCipherSuite

abstract suspend fun updateMlsGroupStateAndCipherSuite(groupState: ConversationEntity.GroupState, cipherSuite: ConversationEntity.CipherSuite, groupId: String)

updateMlsVerificationStatus

abstract suspend fun updateMlsVerificationStatus(verificationStatus: ConversationEntity.VerificationStatus, conversationId: QualifiedIDEntity)

updateReadDateAndGetHasUnreadEvents

abstract suspend fun updateReadDateAndGetHasUnreadEvents(conversationID: QualifiedIDEntity, date: Instant): Boolean

updateReadDatesAndGetHasUnreadEvents

abstract suspend fun updateReadDatesAndGetHasUnreadEvents(conversationDates: Map<QualifiedIDEntity, Instant>): Map<QualifiedIDEntity, Boolean>

updateUserMessageTimer

abstract suspend fun updateUserMessageTimer(conversationId: QualifiedIDEntity, messageTimer: Long?)

whoDeletedMeInConversation

abstract suspend fun whoDeletedMeInConversation(conversationId: QualifiedIDEntity, selfUserIdString: String): UserIDEntity?