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

MessageDAO

interface MessageDAO

Inheritors

Properties

Link copied to clipboard

Functions

Link copied to clipboard
abstract suspend fun countMessagesForBackup(contentTypes: Collection<MessageEntity.ContentType>): Long
Link copied to clipboard
abstract suspend fun deleteAllMessages()
Link copied to clipboard
abstract suspend fun deleteMessage(id: String, conversationsId: QualifiedIDEntity)
Link copied to clipboard
abstract suspend fun getAllAlreadyEndedEphemeralMessages(): List<MessageEntity>
Link copied to clipboard
abstract suspend fun getAllMessageAssetIdsForConversationId(conversationId: QualifiedIDEntity): List<String>
Link copied to clipboard
abstract suspend fun getAllPendingEphemeralMessages(): List<MessageEntity>
Link copied to clipboard
abstract suspend fun getAllPendingMessagesFromUser(userId: UserIDEntity): List<MessageEntity>
Link copied to clipboard
abstract suspend fun getConversationUnreadEventsCount(conversationId: QualifiedIDEntity): Long
Link copied to clipboard
abstract suspend fun getImageMessageAssets(conversationId: QualifiedIDEntity, mimeTypes: Set<String>, limit: Int, offset: Int): List<AssetMessageEntity>
Link copied to clipboard
abstract suspend fun getLastMessagesByConversations(conversationIds: List<QualifiedIDEntity>): Map<QualifiedIDEntity, MessageEntity>
Link copied to clipboard
abstract suspend fun getMessageAssetTransferStatus(messageId: String, conversationId: QualifiedIDEntity): AssetTransferStatusEntity
Link copied to clipboard
abstract suspend fun getMessageById(id: String, conversationId: QualifiedIDEntity): MessageEntity?
abstract suspend fun getMessageIdsThatExpectReadConfirmationWithinDates(conversationId: QualifiedIDEntity, afterDate: Instant, untilDate: Instant, visibility: List<MessageEntity.Visibility> = MessageEntity.Visibility.entries): List<String>
Link copied to clipboard
abstract fun getMessagesByConversationAndVisibility(conversationId: QualifiedIDEntity, limit: Int, offset: Int, visibility: List<MessageEntity.Visibility> = MessageEntity.Visibility.entries): Flow<List<MessageEntity>>
Link copied to clipboard
abstract suspend fun getNextAudioMessageInConversation(prevMessageId: String, conversationId: QualifiedIDEntity): String?
Link copied to clipboard
abstract suspend fun getNotificationMessage(maxNumberOfMessagesPerConversation: Int = 10): List<NotificationMessageEntity>
abstract suspend fun getOldestVisibleMessageTimestampByConversationId(conversationId: ConversationIDEntity): Long?
Link copied to clipboard
abstract fun getPagedMessagesFlow(contentTypes: Collection<MessageEntity.ContentType>, pageSize: Int): Flow<List<MessageEntity>>
Link copied to clipboard
abstract suspend fun getSearchedConversationMessagePosition(conversationId: QualifiedIDEntity, messageId: String): Int
Link copied to clipboard
abstract suspend fun getSenderNameById(id: String, conversationId: QualifiedIDEntity): String?
Link copied to clipboard
abstract suspend fun insertFailedRecipientDelivery(id: String, conversationsId: QualifiedIDEntity, recipientsFailed: List<QualifiedIDEntity>, recipientFailureTypeEntity: RecipientFailureTypeEntity)
Link copied to clipboard
abstract suspend 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.

Link copied to clipboard
abstract suspend 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.

Link copied to clipboard
abstract suspend fun markMessageAsDeleted(id: String, conversationsId: QualifiedIDEntity)
Link copied to clipboard
abstract suspend fun markProteusMessagesAsDecryptionResolved(userId: QualifiedIDEntity, clientId: String)
Link copied to clipboard
abstract suspend fun moveMessages(from: ConversationIDEntity, to: ConversationIDEntity)
Link copied to clipboard
abstract suspend fun needsToBeNotified(id: String, conversationId: QualifiedIDEntity): Boolean
Link copied to clipboard
abstract fun observeAssetStatuses(): Flow<List<MessageAssetTransferStatus>>
abstract fun observeAssetStatuses(conversationId: QualifiedIDEntity): Flow<List<MessageAssetStatusEntity>>
Link copied to clipboard
Link copied to clipboard
abstract fun observeLastMessages(): Flow<List<MessagePreviewEntity>>
Link copied to clipboard
abstract fun observeMessageById(id: String, conversationId: QualifiedIDEntity): Flow<MessageEntity?>
abstract fun observeMessagesByConversationAndVisibilityAfterDate(conversationId: QualifiedIDEntity, date: String, visibility: List<MessageEntity.Visibility> = MessageEntity.Visibility.entries): Flow<List<MessageEntity>>
Link copied to clipboard
abstract fun observeMessageVisibility(messageUuid: String, conversationId: QualifiedIDEntity): Flow<MessageEntity.Visibility?>
Link copied to clipboard
abstract fun observeUnreadEvents(): Flow<Map<ConversationIDEntity, List<UnreadEventEntity>>>
Link copied to clipboard
abstract fun observeUnreadMessageCounter(): Flow<Map<ConversationIDEntity, Int>>
Link copied to clipboard
Link copied to clipboard
abstract suspend fun promoteMessageToSentUpdatingServerTime(conversationId: ConversationIDEntity, messageUuid: String, serverDate: Instant?, millis: Long)
Link copied to clipboard
abstract suspend fun resetAssetTransferStatus()
Link copied to clipboard
abstract suspend fun searchMessagesByText(conversationId: QualifiedIDEntity, searchQuery: String, limit: Int, offset: Int): List<MessageEntity>

Search messages in a conversation by text content.

Link copied to clipboard
abstract suspend fun searchMessagesByTextGlobally(searchQuery: String, limit: Int, offset: Int): List<MessageEntity>

Search messages across all conversations by text content.

Link copied to clipboard
abstract suspend fun updateAssetTransferStatus(transferStatus: AssetTransferStatusEntity, id: String, conversationId: QualifiedIDEntity)
Link copied to clipboard
abstract suspend fun updateAudioMessageNormalizedLoudness(conversationId: QualifiedIDEntity, messageId: String, normalizedLoudness: ByteArray)
Link copied to clipboard
abstract suspend fun updateCompositeMessageContent(conversationId: QualifiedIDEntity, currentMessageId: String, editInstant: Instant, newCompositeContent: MessageEntityContent.Composite, newMessageId: String)
Link copied to clipboard
abstract suspend fun updateLegalHoldMessageMembers(conversationId: QualifiedIDEntity, messageId: String, newMembers: List<QualifiedIDEntity>)
Link copied to clipboard
abstract suspend fun updateLinkPreviewImageLocalPath(conversationId: QualifiedIDEntity, messageId: String, urlOffset: Int, localPath: String)
Link copied to clipboard
abstract suspend fun updateMessagesStatus(status: MessageEntity.Status, id: List<String>, conversationId: QualifiedIDEntity)
Link copied to clipboard
abstract suspend fun updateMessagesStatusIfNotRead(status: MessageEntity.Status, conversationId: QualifiedIDEntity, messageIds: List<String>)
Link copied to clipboard
abstract suspend fun updateMessageStatus(status: MessageEntity.Status, id: String, conversationId: QualifiedIDEntity)
Link copied to clipboard
abstract suspend fun updateSelfDeletionEndDate(conversationId: QualifiedIDEntity, messageId: String, selfDeletionEndDate: Instant)
Link copied to clipboard
abstract suspend fun updateTextMessageContent(conversationId: QualifiedIDEntity, messageId: String, textContent: MessageEntityContent.Text)
abstract suspend fun updateTextMessageContent(editInstant: Instant, conversationId: QualifiedIDEntity, currentMessageId: String, newTextContent: MessageEntityContent.Text, newMessageId: String)
Generated by Dokka
© 2026 Copyright