logic/com.wire.kalium.logic.data.message/MessageRepository

MessageRepository

internal interface MessageRepository

Inheritors

MessageDataSource

Properties

extensions

abstract val extensions: MessageRepositoryExtensions

Functions

broadcastEnvelope

abstract suspend fun broadcastEnvelope(envelope: <Error class: unknown class>, messageOption: BroadcastMessageOption): Either<CoreFailure, <Error class: unknown class>>

Send a Proteus MessageEnvelope.

deleteMessage

abstract suspend fun deleteMessage(messageUuid: String, conversationId: <Error class: unknown class>): Either<CoreFailure, Unit>

getAllAlreadyEndedEphemeralMessages

abstract suspend fun getAllAlreadyEndedEphemeralMessages(): Either<CoreFailure, List<<Error class: unknown class>>>

getAllPendingEphemeralMessages

abstract suspend fun getAllPendingEphemeralMessages(): Either<CoreFailure, List<<Error class: unknown class>>>

getAllPendingMessagesFromUser

abstract suspend fun getAllPendingMessagesFromUser(senderUserId: <Error class: unknown class>): Either<CoreFailure, List<<Error class: unknown class>>>

getImageAssetMessagesByConversationId

abstract suspend fun getImageAssetMessagesByConversationId(conversationId: <Error class: unknown class>, limit: Int, offset: Int): List<<Error class: unknown class>>

getLastMessagesForConversationIds

abstract suspend fun getLastMessagesForConversationIds(conversationIdList: List<<Error class: unknown class>>): Either<StorageFailure, Map<<Error class: unknown class>, <Error class: unknown class>>>

getMessageAssetTransferStatus

abstract suspend fun getMessageAssetTransferStatus(messageId: String, conversationId: <Error class: unknown class>): Either<StorageFailure, <Error class: unknown class>>

getMessageById

abstract suspend fun getMessageById(conversationId: <Error class: unknown class>, messageUuid: String): Either<StorageFailure, <Error class: unknown class>>

getMessagesByConversationIdAndVisibility

abstract suspend fun getMessagesByConversationIdAndVisibility(conversationId: <Error class: unknown class>, limit: Int, offset: Int, visibility: List<<Error class: unknown class>> = Message.Visibility.entries): <Error class: unknown class><List<<Error class: unknown class>>>

getMessagesByConversationIdAndVisibilityAfterDate

abstract suspend fun getMessagesByConversationIdAndVisibilityAfterDate(conversationId: <Error class: unknown class>, date: String, visibility: List<<Error class: unknown class>> = Message.Visibility.entries): <Error class: unknown class><List<<Error class: unknown class>>>

getNotificationMessage

abstract suspend fun getNotificationMessage(messageSizePerConversation: Int = 10): Either<CoreFailure, List<<Error class: unknown class>>>

getPendingConfirmationMessagesByConversationAfterDate

abstract suspend fun getPendingConfirmationMessagesByConversationAfterDate(conversationId: <Error class: unknown class>, afterDateTime: <Error class: unknown class>, untilDateTime: <Error class: unknown class>, visibility: List<<Error class: unknown class>> = Message.Visibility.entries): Either<CoreFailure, List<String>>

getReceiptModeFromGroupConversationByQualifiedID

abstract suspend fun getReceiptModeFromGroupConversationByQualifiedID(conversationId: <Error class: unknown class>): Either<CoreFailure, <Error class: unknown class>?>

getSearchedConversationMessagePosition

abstract suspend fun getSearchedConversationMessagePosition(conversationId: <Error class: unknown class>, messageId: String): Either<StorageFailure, Int>

markMessageAsDeleted

abstract suspend fun markMessageAsDeleted(messageUuid: String, conversationId: <Error class: unknown class>): Either<StorageFailure, Unit>

markMessagesAsDecryptionResolved

abstract suspend fun markMessagesAsDecryptionResolved(conversationId: <Error class: unknown class>, userId: <Error class: unknown class>, clientId: <Error class: unknown class>): Either<CoreFailure, Unit>

markSelfDeletionEndDate

abstract suspend fun markSelfDeletionEndDate(conversationId: <Error class: unknown class>, messageUuid: String, deletionEndDate: <Error class: unknown class>): Either<CoreFailure, Unit>

moveMessagesToAnotherConversation

abstract suspend fun moveMessagesToAnotherConversation(originalConversation: <Error class: unknown class>, targetConversation: <Error class: unknown class>): Either<StorageFailure, Unit>

observeAssetStatuses

abstract suspend fun observeAssetStatuses(conversationId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, List<<Error class: unknown class>>>>

observeMessageVisibility

abstract suspend fun observeMessageVisibility(messageUuid: String, conversationId: <Error class: unknown class>): <Error class: unknown class><Either<StorageFailure, <Error class: unknown class>>>

persistMessage

abstract suspend fun persistMessage(message: <Error class: unknown class>, updateConversationModifiedDate: Boolean = false): Either<CoreFailure, <Error class: unknown class>>

this fun should never be used directly, use PersistMessageUseCase() instead

persistNoClientsToDeliverFailure

abstract suspend fun persistNoClientsToDeliverFailure(conversationId: <Error class: unknown class>, messageUuid: String, usersWithFailedDeliveryList: List<<Error class: unknown class>>): Either<CoreFailure, Unit>

persistRecipientsDeliveryFailure

abstract suspend fun persistRecipientsDeliveryFailure(conversationId: <Error class: unknown class>, messageUuid: String, usersWithFailedDeliveryList: List<<Error class: unknown class>>): Either<CoreFailure, Unit>

persistSystemMessageToAllConversations

abstract suspend fun persistSystemMessageToAllConversations(message: <Error class: unknown class>): Either<CoreFailure, Unit>

promoteMessageToSentUpdatingServerTime

abstract suspend fun promoteMessageToSentUpdatingServerTime(conversationId: <Error class: unknown class>, messageUuid: String, serverDate: <Error class: unknown class>?, millis: Long): Either<CoreFailure, Unit>

updates the message status to MessageEntity.Status.SENT and optionally sets the message creation date to serverDate if not null, also marks other pending messages and adds millis to their date

resetAssetTransferStatus

abstract suspend fun resetAssetTransferStatus()

sendEnvelope

abstract suspend fun sendEnvelope(conversationId: <Error class: unknown class>, envelope: <Error class: unknown class>, messageTarget: MessageTarget): Either<CoreFailure, MessageSent>

Send a Proteus MessageEnvelope to the given conversationId.

sendMLSMessage

abstract suspend fun sendMLSMessage(conversationId: <Error class: unknown class>, message: <Error class: unknown class>): Either<CoreFailure, MessageSent>

updateAssetMessageTransferStatus

abstract suspend fun updateAssetMessageTransferStatus(transferStatus: <Error class: unknown class>, conversationId: <Error class: unknown class>, messageUuid: String): Either<CoreFailure, Unit>

updateLegalHoldMessageMembers

abstract suspend fun updateLegalHoldMessageMembers(messageId: String, conversationId: <Error class: unknown class>, newMembers: List<<Error class: unknown class>>): Either<CoreFailure, Unit>

updateMessagesStatus

abstract suspend fun updateMessagesStatus(messageStatus: <Error class: unknown class>, conversationId: <Error class: unknown class>, messageUuids: List<String>): Either<CoreFailure, Unit>

updateMessageStatus

abstract suspend fun updateMessageStatus(messageStatus: <Error class: unknown class>, conversationId: <Error class: unknown class>, messageUuid: String): Either<CoreFailure, Unit>

updateTextMessage

abstract suspend fun updateTextMessage(conversationId: <Error class: unknown class>, messageContent: <Error class: unknown class>, newMessageId: String, editInstant: <Error class: unknown class>): Either<CoreFailure, Unit>