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

ConversationDAOImpl

internal class ConversationDAOImpl(conversationQueries: ConversationsQueries, conversationDetailsQueries: ConversationDetailsQueries, conversationDetailsWithEventsQueries: ConversationDetailsWithEventsQueries, conversationDetailsWithMembersQueries: ConversationDetailsWithMembersQueries, memberQueries: MembersQueries, unreadEventsQueries: UnreadEventsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher) : ConversationDAO

Constructors

Link copied to clipboard
internal constructor(conversationQueries: ConversationsQueries, conversationDetailsQueries: ConversationDetailsQueries, conversationDetailsWithEventsQueries: ConversationDetailsWithEventsQueries, conversationDetailsWithMembersQueries: ConversationDetailsWithMembersQueries, memberQueries: MembersQueries, unreadEventsQueries: UnreadEventsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun clearContent(conversationId: QualifiedIDEntity)
Link copied to clipboard
open suspend override fun clearProposalTimer(groupID: String)
Link copied to clipboard
open suspend override fun deleteConversationByQualifiedID(qualifiedID: QualifiedIDEntity): Boolean
Link copied to clipboard
open suspend override fun deleteGuestRoomLink(conversationId: QualifiedIDEntity)
Link copied to clipboard
open override fun getAllConversationDetails(fromArchive: Boolean, filter: ConversationFilterEntity, strictMLSFilter: Boolean = true): Flow<List<ConversationViewEntity>>
Link copied to clipboard
open override fun getAllConversationDetailsWithEvents(fromArchive: Boolean = false, onlyInteractionEnabled: Boolean = false, newActivitiesOnTop: Boolean = false, ongoingCallConversationIds: List<QualifiedIDEntity> = emptyList(), strictMLSFilter: Boolean = true): Flow<List<ConversationDetailsWithEventsEntity>>
Link copied to clipboard
open override fun getAllConversations(): Flow<List<ConversationEntity>>
Link copied to clipboard
Link copied to clipboard
open suspend override fun getCellGroupConversations(): List<ConversationEntity>
Link copied to clipboard
open suspend override fun getCellGroupConversationsPaged(limit: Int, offset: Int, query: String = ""): List<ConversationEntity>
Link copied to clipboard
open suspend override fun getCellName(conversationId: QualifiedIDEntity): String?
Link copied to clipboard
open suspend override fun getConversationByGroupID(groupID: String): ConversationEntity?
Link copied to clipboard
open suspend override fun getConversationById(qualifiedID: QualifiedIDEntity): ConversationEntity?
Link copied to clipboard
open suspend override fun getConversationDetailsById(qualifiedID: QualifiedIDEntity): ConversationViewEntity?
Link copied to clipboard
open suspend override fun getConversationIdByGroupID(groupID: String): QualifiedIDEntity?
Link copied to clipboard
open suspend override fun getConversationIds(type: ConversationEntity.Type, protocol: ConversationEntity.Protocol, teamId: String? = null): List<QualifiedIDEntity>
Link copied to clipboard
open suspend override fun getConversationLastReadDate(qualifiedID: QualifiedIDEntity): Instant?
Link copied to clipboard
Link copied to clipboard
open suspend override fun getConversationsByGroupState(groupState: ConversationEntity.GroupState): List<ConversationEntity>
Link copied to clipboard
open suspend override fun getConversationsByIds(qualifiedIDs: List<QualifiedIDEntity>): List<ConversationEntity>
Link copied to clipboard
open suspend override fun getConversationsByKeyingMaterialUpdate(threshold: Duration): List<String>
Link copied to clipboard
open suspend override fun getConversationsByUserId(userId: UserIDEntity): List<ConversationEntity>
Link copied to clipboard
open suspend override fun getConversationsWithoutMetadata(): List<QualifiedIDEntity>
Link copied to clipboard
open suspend override fun getE2EIConversationClientInfoByClientId(clientId: String): E2EIConversationClientInfoEntity?
Link copied to clipboard
open suspend override fun getEstablishedSelfMLSGroupId(): String?
Link copied to clipboard
open suspend override fun getMLSConversationsByDomain(domain: String): List<ConversationEntity>
Link copied to clipboard
open suspend override fun getMLSGroupIdByConversationId(conversationId: QualifiedIDEntity): String?
Link copied to clipboard
open suspend override fun getMLSGroupIdByUserId(userId: UserIDEntity): String?
Link copied to clipboard
open suspend override fun getNonDeletedConversationById(qualifiedID: QualifiedIDEntity): ConversationEntity?
Link copied to clipboard
Link copied to clipboard
open override fun getProposalTimers(): Flow<List<ProposalTimerEntity>>
Link copied to clipboard
open suspend override fun getTeamConversationIdsReadyToCompleteMigration(teamId: String): List<QualifiedIDEntity>
Link copied to clipboard
open suspend override fun hasConversationWithCell(): Boolean
Link copied to clipboard
open suspend override fun insertAdminlessGroupDelete(conversationId: QualifiedIDEntity, deletionTimestamp: Instant)
Link copied to clipboard
open suspend override fun insertConversation(conversationEntity: ConversationEntity)
Link copied to clipboard
open suspend override fun insertConversations(conversationEntities: List<ConversationEntity>)
Link copied to clipboard
open suspend override fun insertOrUpdateLastModified(conversationEntities: List<ConversationEntity>)
Link copied to clipboard
open suspend override fun observeConversationById(qualifiedID: QualifiedIDEntity): Flow<ConversationEntity?>
Link copied to clipboard
open suspend override fun observeConversationDetailsById(conversationId: QualifiedIDEntity): Flow<ConversationViewEntity?>
Link copied to clipboard
open override fun observeDegradedConversationNotified(conversationId: QualifiedIDEntity): Flow<Boolean>
Link copied to clipboard
Link copied to clipboard
open suspend override fun observeHasConversationWithCell(): Flow<Boolean>
Link copied to clipboard
Link copied to clipboard
open override fun observeLegalHoldStatusChangeNotified(conversationId: QualifiedIDEntity): Flow<Boolean>
Link copied to clipboard
Link copied to clipboard
open override fun observeUnreadArchivedConversationsCount(): Flow<Long>
Link copied to clipboard
open suspend override fun selectGroupStatusMembersNamesAndHandles(groupID: String): EpochChangesDataEntity?
Link copied to clipboard
open suspend override fun setConversationDeletedLocally(qualifiedID: QualifiedIDEntity, deletedLocally: Boolean)
Link copied to clipboard
open suspend override fun setProposalTimer(proposalTimer: ProposalTimerEntity)
Link copied to clipboard
open suspend override fun updateAccess(conversationID: QualifiedIDEntity, accessList: List<ConversationEntity.Access>, accessRoleList: List<ConversationEntity.AccessRole>)
Link copied to clipboard
open suspend override fun updateAllConversationsNotificationDate()
Link copied to clipboard
open suspend override fun updateChannelAddPermission(conversationId: QualifiedIDEntity, channelAddPermission: ConversationEntity.ChannelAddPermission)
Link copied to clipboard
open suspend override fun updateConversation(conversationEntity: ConversationEntity)
Link copied to clipboard
open suspend override fun updateConversationArchivedStatus(conversationId: QualifiedIDEntity, isArchived: Boolean, archivedStatusTimestamp: Instant)
Link copied to clipboard
open suspend override fun updateConversationGroupState(groupState: ConversationEntity.GroupState, groupId: String)
open suspend override fun updateConversationGroupStateByConversationId(groupState: ConversationEntity.GroupState, conversationId: QualifiedIDEntity)
Link copied to clipboard
open suspend override fun updateConversationModifiedDate(qualifiedID: QualifiedIDEntity, date: Instant)
open suspend override fun updateConversationModifiedDateToMaxOfSources(targetId: QualifiedIDEntity, sourceIds: Collection<QualifiedIDEntity>)
Link copied to clipboard
open suspend override fun updateConversationMutedStatus(conversationId: QualifiedIDEntity, mutedStatus: ConversationEntity.MutedStatus, mutedStatusTimestamp: Instant)
Link copied to clipboard
open suspend override fun updateConversationName(conversationId: QualifiedIDEntity, conversationName: String, dateTime: Instant)
Link copied to clipboard
open suspend override fun updateConversationNotificationDate(qualifiedID: QualifiedIDEntity, date: Instant? = null)
Link copied to clipboard
open suspend override fun updateConversationProtocolAndCipherSuite(conversationId: QualifiedIDEntity, groupID: String?, protocol: ConversationEntity.Protocol, cipherSuite: ConversationEntity.CipherSuite): Boolean
Link copied to clipboard
open suspend override fun updateConversationReadAndModifiedDates(readDates: Map<QualifiedIDEntity, Instant>, modifiedDates: Map<QualifiedIDEntity, Instant>)
Link copied to clipboard
open suspend override fun updateConversationReadDate(conversationID: QualifiedIDEntity, date: Instant)
Link copied to clipboard
open suspend override fun updateConversationReadDates(conversationDates: Map<QualifiedIDEntity, Instant>): Int
Link copied to clipboard
open suspend override fun updateConversationReceiptMode(conversationID: QualifiedIDEntity, receiptMode: ConversationEntity.ReceiptMode)
Link copied to clipboard
open suspend override fun updateConversationType(conversationID: QualifiedIDEntity, type: ConversationEntity.Type)
Link copied to clipboard
open suspend override fun updateDegradedConversationNotifiedFlag(conversationId: QualifiedIDEntity, updateFlag: Boolean)
Link copied to clipboard
open suspend override fun updateGuestRoomLink(conversationId: QualifiedIDEntity, link: String, isPasswordProtected: Boolean)
Link copied to clipboard
open suspend override fun updateKeyingMaterial(groupId: String, timestamp: Instant)
Link copied to clipboard
open suspend override fun updateLegalHoldStatus(conversationId: QualifiedIDEntity, legalHoldStatus: ConversationEntity.LegalHoldStatus): Boolean
Link copied to clipboard
open suspend override fun updateLegalHoldStatusChangeNotified(conversationId: QualifiedIDEntity, notified: Boolean): Boolean
Link copied to clipboard
open suspend override fun updateMessageTimer(conversationId: QualifiedIDEntity, messageTimer: Long?)
Link copied to clipboard
open suspend override fun updateMLSGroupIdAndState(conversationId: QualifiedIDEntity, newGroupId: String, newEpoch: Long, groupState: ConversationEntity.GroupState)
Link copied to clipboard
open suspend override fun updateMlsGroupStateAndCipherSuite(groupState: ConversationEntity.GroupState, cipherSuite: ConversationEntity.CipherSuite, groupId: String)
Link copied to clipboard
open suspend override fun updateMlsVerificationStatus(verificationStatus: ConversationEntity.VerificationStatus, conversationId: QualifiedIDEntity)
Link copied to clipboard
open suspend override fun updateReadDateAndGetHasUnreadEvents(conversationID: QualifiedIDEntity, date: Instant): Boolean
Link copied to clipboard
open suspend override fun updateReadDatesAndGetHasUnreadEvents(conversationDates: Map<QualifiedIDEntity, Instant>): Map<QualifiedIDEntity, Boolean>
Link copied to clipboard
open suspend override fun updateUserMessageTimer(conversationId: QualifiedIDEntity, messageTimer: Long?)
Link copied to clipboard
open suspend override fun whoDeletedMeInConversation(conversationId: QualifiedIDEntity, selfUserIdString: String): UserIDEntity?
Generated by Dokka
© 2026 Copyright