persistence/com.wire.kalium.persistence.dao.message/MessageDAOImpl

MessageDAOImpl

internal class MessageDAOImpl(queries: MessagesQueries, attachmentsQueries: MessageAttachmentsQueries, assetViewQueries: MessageAssetViewQueries, notificationQueries: NotificationQueries, conversationsQueries: ConversationsQueries, unreadEventsQueries: UnreadEventsQueries, messagePreviewQueries: MessagePreviewQueries, cellFilesQueries: CellFilesQueries, selfUserId: UserIDEntity, reactionsQueries: ReactionsQueries, userQueries: UsersQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher, assetStatusQueries: MessageAssetTransferStatusQueries, buttonContentQueries: ButtonContentQueries, pollContentQueries: PollContentQueries) : MessageDAO, MessageInsertExtension

Constructors

MessageDAOImpl

internal constructor(queries: MessagesQueries, attachmentsQueries: MessageAttachmentsQueries, assetViewQueries: MessageAssetViewQueries, notificationQueries: NotificationQueries, conversationsQueries: ConversationsQueries, unreadEventsQueries: UnreadEventsQueries, messagePreviewQueries: MessagePreviewQueries, cellFilesQueries: CellFilesQueries, selfUserId: UserIDEntity, reactionsQueries: ReactionsQueries, userQueries: UsersQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher, assetStatusQueries: MessageAssetTransferStatusQueries, buttonContentQueries: ButtonContentQueries, pollContentQueries: PollContentQueries)

Properties

platformExtensions

open override val platformExtensions: MessageExtensions

Functions

claimFailedMessageForRetry

open suspend override fun claimFailedMessageForRetry(id: String, conversationId: QualifiedIDEntity): Boolean

contentTypeOf

open override fun contentTypeOf(content: MessageEntityContent): MessageEntity.ContentType

countMessagesForBackup

open suspend override fun countMessagesForBackup(contentTypes: Collection<MessageEntity.ContentType>): Long

deleteAllMessages

open suspend override fun deleteAllMessages()

deleteClearedMessage

open suspend override fun deleteClearedMessage(conversationId: QualifiedIDEntity, messageId: String)

deleteMessage

open suspend override fun deleteMessage(id: String, conversationsId: QualifiedIDEntity)

getAllAlreadyEndedEphemeralMessages

open suspend override fun getAllAlreadyEndedEphemeralMessages(): List<MessageEntity>

getAllMessageAssetIdsForConversationId

open suspend override fun getAllMessageAssetIdsForConversationId(conversationId: QualifiedIDEntity): List<String>

getAllPendingEphemeralMessages

open suspend override fun getAllPendingEphemeralMessages(): List<MessageEntity>

getAllPendingMessagesFromUser

open suspend override fun getAllPendingMessagesFromUser(userId: UserIDEntity): List<MessageEntity>

getConversationIdsWithMessage

open suspend override fun getConversationIdsWithMessage(id: String): List<ConversationIDEntity>

getConversationUnreadEventsCount

open suspend override fun getConversationUnreadEventsCount(conversationId: QualifiedIDEntity): Long

getImageMessageAssets

open suspend override fun getImageMessageAssets(conversationId: QualifiedIDEntity, mimeTypes: Set<String>, limit: Int, offset: Int): List<AssetMessageEntity>

getLastMessagesByConversations

open suspend override fun getLastMessagesByConversations(conversationIds: List<QualifiedIDEntity>): Map<QualifiedIDEntity, MessageEntity>

getMessageAssetTransferStatus

open suspend override fun getMessageAssetTransferStatus(messageId: String, conversationId: QualifiedIDEntity): AssetTransferStatusEntity

getMessageById

open suspend override fun getMessageById(id: String, conversationId: QualifiedIDEntity): MessageEntity?

getMessageIdsThatExpectReadConfirmationWithinDates

open suspend override fun getMessageIdsThatExpectReadConfirmationWithinDates(conversationId: QualifiedIDEntity, afterDate: Instant, untilDate: Instant, visibility: List<MessageEntity.Visibility> = MessageEntity.Visibility.entries): Map<UserIDEntity, List<String>>

Returns the ids of messages expecting a read confirmation within the given dates, grouped by their sender.

getMessageIdsThrough

open suspend override fun getMessageIdsThrough(conversationId: QualifiedIDEntity, through: Instant, pageSize: Long): List<String>

getMessagesByConversationAndVisibility

open override fun getMessagesByConversationAndVisibility(conversationId: QualifiedIDEntity, limit: Int, offset: Int, visibility: List<MessageEntity.Visibility> = MessageEntity.Visibility.entries): Flow<List<MessageEntity>>

getNextAudioMessageInConversation

open suspend override fun getNextAudioMessageInConversation(prevMessageId: String, conversationId: QualifiedIDEntity): String?

getNotificationMessage

open suspend override fun getNotificationMessage(maxNumberOfMessagesPerConversation: Int = 10): List<NotificationMessageEntity>

getPagedMessagesFlow

open override fun getPagedMessagesFlow(contentTypes: Collection<MessageEntity.ContentType>, pageSize: Int): Flow<List<MessageEntity>>

getReceiptModeFromGroupConversationByQualifiedID

open suspend override fun getReceiptModeFromGroupConversationByQualifiedID(qualifiedID: QualifiedIDEntity): ConversationEntity.ReceiptMode?

getSearchedConversationMessagePosition

open suspend override fun getSearchedConversationMessagePosition(conversationId: QualifiedIDEntity, messageId: String): Int

getSenderNameById

open suspend override fun getSenderNameById(id: String, conversationId: QualifiedIDEntity): String?

insertFailedRecipientDelivery

open suspend override fun insertFailedRecipientDelivery(id: String, conversationsId: QualifiedIDEntity, recipientsFailed: List<QualifiedIDEntity>, recipientFailureTypeEntity: RecipientFailureTypeEntity)

insertMessageOrIgnore

open suspend override fun insertMessageOrIgnore(message: MessageEntity, withUnreadEvents: Boolean = true)

insertOrIgnoreMessage

open suspend override fun insertOrIgnoreMessage(message: MessageEntity, updateConversationModifiedDate: Boolean = false): InsertMessageResult

Inserts the message, or ignores if there's already a message with the same MessageEntity.id and MessageEntity.conversationId. There is only one exception where a second message with the same id will not be ignored, and it is when the first message is an asset preview message. In this case, the second message containing the valid encryption keys will be updating and completing the encryption keys and the visibility of the first one.

insertOrIgnoreMessages

open suspend override fun insertOrIgnoreMessages(messages: List<MessageEntity>, withUnreadEvents: Boolean = true, checkAssetUpdate: Boolean = true)

Inserts the messages, or ignores messages if there already exists a message with the same MessageEntity.id and MessageEntity.conversationId. There is only one exception where a second message with the same id will not be ignored, and it is when the first message is an asset preview message. In this case, the second message containing the valid encryption keys will be updating and completing the encryption keys and the visibility of the first one.

insertReceivedMessage

open suspend override fun insertReceivedMessage(message: MessageEntity.Regular, updateConversationOrder: Boolean)

Atomically insert a new message or complete an asset preview; canonical duplicates have no repeated effects.

markMessageAsDeleted

open suspend override fun markMessageAsDeleted(id: String, conversationsId: QualifiedIDEntity)

markProteusMessagesAsDecryptionResolved

open suspend override fun markProteusMessagesAsDecryptionResolved(userId: QualifiedIDEntity, clientId: String)

moveMessages

open suspend override fun moveMessages(from: ConversationIDEntity, to: ConversationIDEntity)

needsToBeNotified

open suspend override fun needsToBeNotified(id: String, conversationId: QualifiedIDEntity): Boolean

observeAssetStatuses

open override fun observeAssetStatuses(): Flow<List<MessageAssetTransferStatus>>

open override fun observeAssetStatuses(conversationId: QualifiedIDEntity): Flow<List<MessageAssetStatusEntity>>

observeConversationsUnreadEvents

open override fun observeConversationsUnreadEvents(): Flow<List<ConversationUnreadEventEntity>>

observeLastMessages

open override fun observeLastMessages(): Flow<List<MessagePreviewEntity>>

observeMessageById

open override fun observeMessageById(id: String, conversationId: QualifiedIDEntity): Flow<MessageEntity?>

observeMessagesByConversationAndVisibilityAfterDate

open override fun observeMessagesByConversationAndVisibilityAfterDate(conversationId: QualifiedIDEntity, date: String, visibility: List<MessageEntity.Visibility> = MessageEntity.Visibility.entries): Flow<List<MessageEntity>>

observeMessageVisibility

open override fun observeMessageVisibility(messageUuid: String, conversationId: QualifiedIDEntity): Flow<MessageEntity.Visibility?>

observeNotificationMessages

open override fun observeNotificationMessages(): Flow<List<NotificationMessageEntity>>

observeNotificationRemovalCandidates

open override fun observeNotificationRemovalCandidates(messageIds: List<String>): Flow<List<NotificationMessageKey>>

Canonical deletion/read state for existing delivered alerts; never infers expiry from missing rows.

observeUnreadEvents

open override fun observeUnreadEvents(): Flow<Map<ConversationIDEntity, List<UnreadEventEntity>>>

observeUnreadMessageCounter

open override fun observeUnreadMessageCounter(): Flow<Map<ConversationIDEntity, Int>>

persistSystemMessageToAllConversations

open suspend override fun persistSystemMessageToAllConversations(message: MessageEntity.System)

promoteMessageToSentUpdatingServerTime

open suspend override fun promoteMessageToSentUpdatingServerTime(conversationId: ConversationIDEntity, messageUuid: String, serverDate: Instant?, millis: Long)

rememberNotificationMessages

open suspend override fun rememberNotificationMessages(messages: List<NotificationMessageKey>)

resetAssetTransferStatus

open suspend override fun resetAssetTransferStatus()

resolveNotificationMessage

open suspend override fun resolveNotificationMessage(messageId: String, conversationId: QualifiedIDEntity): String?

Apple notification identities follow canonical message IDs through edits; Android does not register alerts here.

searchMessagesByText

open suspend override fun searchMessagesByText(conversationId: QualifiedIDEntity, searchQuery: String, limit: Int, offset: Int): List<MessageEntity>

Search messages in a conversation by text content.

searchMessagesByTextGlobally

open suspend override fun searchMessagesByTextGlobally(searchQuery: String, limit: Int, offset: Int): List<MessageEntity>

Search messages across all conversations by text content.

updateAssetMessageIfValid

open suspend override fun updateAssetMessageIfValid(message: MessageEntity): Boolean

Updates an existing asset from the same sender, returning whether a valid follow-up was applied.

updateAssetTransferStatus

open suspend override fun updateAssetTransferStatus(transferStatus: AssetTransferStatusEntity, id: String, conversationId: QualifiedIDEntity)

updateAudioMessageNormalizedLoudness

open suspend override fun updateAudioMessageNormalizedLoudness(conversationId: QualifiedIDEntity, messageId: String, normalizedLoudness: ByteArray)

updateCompositeMessageContent

open suspend override fun updateCompositeMessageContent(conversationId: QualifiedIDEntity, currentMessageId: String, editInstant: Instant, newCompositeContent: MessageEntityContent.Composite, newMessageId: String)

updateLegalHoldMessageMembers

open suspend override fun updateLegalHoldMessageMembers(conversationId: QualifiedIDEntity, messageId: String, newMembers: List<QualifiedIDEntity>)

updateLinkPreviewImageLocalPath

open suspend override fun updateLinkPreviewImageLocalPath(conversationId: QualifiedIDEntity, messageId: String, urlOffset: Int, localPath: String)

updateMessagesStatus

open suspend override fun updateMessagesStatus(status: MessageEntity.Status, id: List<String>, conversationId: QualifiedIDEntity)

updateMessagesStatusIfNotRead

open suspend override fun updateMessagesStatusIfNotRead(status: MessageEntity.Status, conversationId: QualifiedIDEntity, messageIds: List<String>)

updateMessageStatus

open suspend override fun updateMessageStatus(status: MessageEntity.Status, id: String, conversationId: QualifiedIDEntity)

updateMessageStatusIfNotAcknowledged

open suspend override fun updateMessageStatusIfNotAcknowledged(status: MessageEntity.Status, id: String, conversationId: QualifiedIDEntity)

Conditional cleanup: a receipt committed since the caller's read must not be downgraded.

updatePendingTextPolicy

open suspend override fun updatePendingTextPolicy(conversationId: QualifiedIDEntity, messageId: String, expireAfterMillis: Long?, expectsReadConfirmation: Boolean)

updateSelfDeletionEndDate

open suspend override fun updateSelfDeletionEndDate(conversationId: QualifiedIDEntity, messageId: String, selfDeletionEndDate: Instant)

updateTextMessageContent

open suspend override fun updateTextMessageContent(conversationId: QualifiedIDEntity, messageId: String, textContent: MessageEntityContent.Text)

open suspend override fun updateTextMessageContent(editInstant: Instant, conversationId: QualifiedIDEntity, currentMessageId: String, newTextContent: MessageEntityContent.Text, newMessageId: String, updateStatus: MessageEntity.Status? = null)