logic/com.wire.kalium.logic.feature.message

Package-level declarations

Types

AddSystemMessageToAllConversationsUseCase

internal interface AddSystemMessageToAllConversationsUseCase

persist a local system message to all conversations

AddSystemMessageToAllConversationsUseCaseImpl

internal class AddSystemMessageToAllConversationsUseCaseImpl(messageRepository: MessageRepository, selfUserId: UserId) : AddSystemMessageToAllConversationsUseCase

DeleteMessageUseCase

class DeleteMessageUseCase(messageRepository: MessageRepository, assetRepository: AssetRepository, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, selfUserId: UserId, currentClientIdProvider: CurrentClientIdProvider, selfConversationIdProvider: SelfConversationIdProvider, deleteAttachments: DeleteMessageAttachmentsUseCase, persistenceEventHookNotifier: PersistenceEventHookNotifier, dispatcher: KaliumDispatcher = KaliumDispatcherImpl)

Deletes a message from the conversation

EditMessageBuilder

internal object EditMessageBuilder

FetchOlderNomadMessagesByConversationUseCase

interface FetchOlderNomadMessagesByConversationUseCase

FetchOlderNomadMessagesByConversationUseCaseImpl

internal class FetchOlderNomadMessagesByConversationUseCaseImpl(dispatcher: KaliumDispatcher = KaliumDispatcherImpl, messageRepository: MessageRepository) : FetchOlderNomadMessagesByConversationUseCase

GetMessageByIdUseCase

class GetMessageByIdUseCase(messageRepository: MessageRepository, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Provides a way to get a full message using its ConversationId and message ID coordinates.

GetNextAudioMessageInConversationUseCase

class GetNextAudioMessageInConversationUseCase(messageRepository: MessageRepository, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Provides a way to get a messageId of next AudioMessage after messageId in ConversationId conversation.

GetNotificationsUseCase

interface GetNotificationsUseCase

Get notifications for the current user

GetNotificationsUseCaseImpl

internal class GetNotificationsUseCaseImpl(connectionRepository: ConnectionRepository, messageRepository: MessageRepository, notificationEventsManager: NotificationEventsManager, incrementalSyncRepository: IncrementalSyncRepository, localNotificationMessageMapper: LocalNotificationMessageMapper = MapperProvider.localNotificationMessageMapper()) : GetNotificationsUseCase

GetPaginatedFlowOfMessagesByConversationUseCase

class GetPaginatedFlowOfMessagesByConversationUseCase(dispatcher: KaliumDispatcher, messageRepository: MessageRepository)

This use case will observe and return a flow of paginated messages for a given conversation.

GetPaginatedFlowOfMessagesBySearchQueryAndConversationIdUseCase

class GetPaginatedFlowOfMessagesBySearchQueryAndConversationIdUseCase(dispatcher: KaliumDispatcher, messageRepository: MessageRepository)

This use case will observe and return a flow of paginated searched messages for a given conversation.

GetRecentMessagesUseCase

class GetRecentMessagesUseCase(messageRepository: MessageRepository, slowSyncRepository: SlowSyncRepository)

Gets the recent messages from the conversation

GetSearchedConversationMessagePositionUseCase

interface GetSearchedConversationMessagePositionUseCase

Gets the Selected Message Position from Search

GetSearchedConversationMessagePositionUseCaseImpl

internal class GetSearchedConversationMessagePositionUseCaseImpl(messageRepository: MessageRepository, dispatcher: KaliumDispatcher = KaliumDispatcherImpl) : GetSearchedConversationMessagePositionUseCase

GetSenderNameByMessageIdUseCase

class GetSenderNameByMessageIdUseCase(messageRepository: MessageRepository, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Provides a way to get a name of user that sent a message using its ConversationId and message ID coordinates.

MarkMessagesAsNotifiedUseCase

class MarkMessagesAsNotifiedUseCase(conversationRepository: ConversationRepository)

Marks conversations in one or all conversations as notified, so the notifications for these messages won't show up again.

MessageEnvelopeCreator

internal interface MessageEnvelopeCreator

MessageEnvelopeCreatorImpl

internal class MessageEnvelopeCreatorImpl(conversationRepository: ConversationRepository, legalHoldStatusMapper: LegalHoldStatusMapper, selfUserId: UserId, protoContentMapper: ProtoContentMapper = MapperProvider.protoContentMapper(selfUserId = selfUserId), idMapper: IdMapper = MapperProvider.idMapper()) : MessageEnvelopeCreator

MessageOperationResult

sealed class MessageOperationResult

Common result type for message operations (sending, editing, deleting) that return Unit on success. This provides a Swift-friendly API while maintaining backward compatibility with Either for internal use.

MessageScope

class MessageScope(notificationEventsManager: NotificationEventsManager, connectionRepository: ConnectionRepository, messageDraftRepository: MessageDraftRepository, selfUserId: QualifiedID, currentClientIdProvider: CurrentClientIdProvider, selfConversationIdProvider: SelfConversationIdProvider, val messageRepository: MessageRepository, conversationRepository: ConversationRepository, attachmentsRepository: Lazy<MessageAttachmentDraftRepository>, mlsConversationRepository: MLSConversationRepository, clientRepository: ClientRepository, clientRemoteRepository: ClientRemoteRepository, preKeyRepository: PreKeyRepository, userRepository: UserRepository, assetRepository: AssetRepository, reactionRepository: ReactionRepository, receiptRepository: ReceiptRepository, syncManager: SyncManager, slowSyncRepository: SlowSyncRepository, messageSendingScheduler: MessageSendingScheduler, audioNormalizedLoudnessScheduler: AudioNormalizedLoudnessScheduler, userPropertyRepository: UserPropertyRepository, incrementalSyncRepository: IncrementalSyncRepository, kaliumFileSystem: KaliumFileSystem, protoContentMapper: ProtoContentMapper, observeSelfDeletingMessages: ObserveSelfDeletionTimerSettingsForConversationUseCase, messageMetadataRepository: MessageMetadataRepository, staleEpochVerifier: StaleEpochVerifier, legalHoldHandler: LegalHoldHandler, observeFileSharingStatusUseCase: ObserveFileSharingStatusUseCase, getMessageAttachmentsUseCase: Lazy<GetMessageAttachmentsUseCase>, publishAttachmentsUseCase: Lazy<PublishAttachmentsUseCase>, removeAttachmentDraftsUseCase: Lazy<RemoveAttachmentDraftsUseCase>, deleteMessageAttachmentsUseCase: Lazy<DeleteMessageAttachmentsUseCase>, fetchConversationUseCase: FetchConversationUseCase, transactionProvider: CryptoTransactionProvider, compositeMessageRepository: CompositeMessageRepository, joinExistingConversationUseCaseProvider: () -> JoinExistingMLSConversationUseCase, audioNormalizedLoudnessBuilder: AudioNormalizedLoudnessBuilder, mlsMissingUsersMessageRejectionHandlerProvider: () -> MLSMissingUsersMessageRejectionHandler, persistenceEventHookNotifier: PersistenceEventHookNotifier, linkPreviewEnabled: Boolean, scope: CoroutineScope, kaliumConfigs: KaliumConfigs, kaliumLogger: KaliumLogger, val dispatcher: KaliumDispatcher, legalHoldStatusMapper: LegalHoldStatusMapper)

MessageSenderImpl

internal class MessageSenderImpl(messageRepository: MessageRepository, conversationRepository: ConversationRepository, syncManager: SyncManager, messageSendFailureHandler: MessageSendFailureHandler, legalHoldHandler: LegalHoldHandler, sessionEstablisher: SessionEstablisher, messageEnvelopeCreator: MessageEnvelopeCreator, mlsMessageCreator: MLSMessageCreator, messageSendingInterceptor: MessageSendingInterceptor, userRepository: UserRepository, staleEpochVerifier: StaleEpochVerifier, transactionProvider: CryptoTransactionProvider, mlsMissingUsersMessageRejectionHandler: MLSMissingUsersMessageRejectionHandler, enqueueSelfDeletion: (Message, Message.ExpirationData) -> Unit, scope: CoroutineScope) : MessageSender

MessageSendFailureHandler

internal interface MessageSendFailureHandler

MessageSendFailureHandlerImpl

internal class MessageSendFailureHandlerImpl(userRepository: UserRepository, clientRepository: ClientRepository, clientRemoteRepository: ClientRemoteRepository, messageRepository: MessageRepository, messageSendingScheduler: MessageSendingScheduler, fetchConversation: FetchConversationUseCase, clientMapper: ClientMapper = MapperProvider.clientMapper()) : MessageSendFailureHandler

MessageSendingInterceptor

internal interface MessageSendingInterceptor

MessageSendingInterceptorImpl

internal class MessageSendingInterceptorImpl(messageContentEncoder: MessageContentEncoder, messageRepository: MessageRepository) : MessageSendingInterceptor

MessageSendingScheduler

internal interface MessageSendingScheduler

Responsible for scheduleSendingOfPendingMessages.

MLSMessageCreator

internal interface MLSMessageCreator

MLSMessageCreatorImpl

internal class MLSMessageCreatorImpl(conversationRepository: ConversationRepository, legalHoldStatusMapper: LegalHoldStatusMapper, mlsConversationRepository: MLSConversationRepository, joinExistingConversationUseCase: JoinExistingMLSConversationUseCase, selfUserId: UserId, protoContentMapper: ProtoContentMapper = MapperProvider.protoContentMapper(selfUserId = selfUserId), idMapper: IdMapper = MapperProvider.idMapper()) : MLSMessageCreator

ObserveMessageByIdUseCase

class ObserveMessageByIdUseCase(messageRepository: MessageRepository, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

This use case will observe and return the Flow of Message for a specific ConversationId and messageId.

ObserveMessageReactionsUseCase

interface ObserveMessageReactionsUseCase

Use case to observe the reactions on a message

ObserveMessageReactionsUseCaseImpl

internal class ObserveMessageReactionsUseCaseImpl(reactionRepository: ReactionRepository) : ObserveMessageReactionsUseCase

ObserveMessageReceiptsUseCase

interface ObserveMessageReceiptsUseCase

Use case to observe the receipts on a message

ObserveMessageReceiptsUseCaseImpl

internal class ObserveMessageReceiptsUseCaseImpl(receiptRepository: ReceiptRepository) : ObserveMessageReceiptsUseCase

PendingProposalScheduler

internal interface PendingProposalScheduler

Schedule pending MLS proposals in a conversation to be committed at a given date. The scheduling persisted and resumes automatically.

PendingProposalSchedulerImpl

internal class PendingProposalSchedulerImpl(incrementalSyncRepository: IncrementalSyncRepository, mlsConversationRepository: Lazy<MLSConversationRepository>, subconversationRepository: Lazy<SubconversationRepository>, transactionProvider: CryptoTransactionProvider, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl, parentContext: CoroutineContext = SupervisorJob()) : PendingProposalScheduler

Result

sealed class Result

RetryFailedMessageUseCase

class RetryFailedMessageUseCase(messageRepository: MessageRepository, assetRepository: AssetRepository, conversationRepository: ConversationRepository, attachmentsRepository: MessageAttachmentDraftRepository, persistMessage: PersistMessageUseCase, publishAttachments: PublishAttachmentsUseCase, scope: CoroutineScope, dispatcher: KaliumDispatcher, messageSender: MessageSender, updateAssetMessageTransferStatus: UpdateAssetMessageTransferStatusUseCase, getAssetMessageTransferStatusUseCase: GetAssetMessageTransferStatusUseCase, messageSendFailureHandler: MessageSendFailureHandler)

SearchMessagesGloballyUseCase

interface SearchMessagesGloballyUseCase

Use case for searching messages across all conversations by text content.

SearchMessagesGloballyUseCaseImpl

internal class SearchMessagesGloballyUseCaseImpl(messageRepository: MessageRepository, dispatcher: KaliumDispatcher = KaliumDispatcherImpl) : SearchMessagesGloballyUseCase

SearchMessagesInConversationUseCase

interface SearchMessagesInConversationUseCase

Use case for searching messages in a conversation by text content.

SearchMessagesInConversationUseCaseImpl

internal class SearchMessagesInConversationUseCaseImpl(messageRepository: MessageRepository, dispatcher: KaliumDispatcher = KaliumDispatcherImpl) : SearchMessagesInConversationUseCase

SendEditMultipartMessageUseCase

class SendEditMultipartMessageUseCase(messageRepository: MessageRepository, selfUserId: QualifiedID, provideClientId: CurrentClientIdProvider, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, getMessageAttachments: GetMessageAttachmentsUseCase, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Edits a multipart message

SendEditTextMessageUseCase

class SendEditTextMessageUseCase(messageRepository: MessageRepository, selfUserId: QualifiedID, provideClientId: CurrentClientIdProvider, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, pendingMessagesEnabled: Boolean = true, dispatchers: KaliumDispatcher = KaliumDispatcherImpl)

Edits a text message

SendKnockUseCase

class SendKnockUseCase(persistMessage: PersistMessageUseCase, selfUserId: QualifiedID, currentClientIdProvider: CurrentClientIdProvider, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, selfDeleteTimer: ObserveSelfDeletionTimerSettingsForConversationUseCase, dispatcher: KaliumDispatcher = KaliumDispatcherImpl)

Sending a ping/knock message to a conversation

SendLocationUseCase

class SendLocationUseCase(persistMessage: PersistMessageUseCase, selfUserId: QualifiedID, currentClientIdProvider: CurrentClientIdProvider, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, selfDeleteTimer: ObserveSelfDeletionTimerSettingsForConversationUseCase, pendingMessagesEnabled: Boolean = true, dispatcher: KaliumDispatcher = KaliumDispatcherImpl)

Sending a location message to a conversation

SendMultipartMessageUseCase

class SendMultipartMessageUseCase(persistMessage: PersistMessageUseCase, selfUserId: QualifiedID, provideClientId: CurrentClientIdProvider, assetDataSource: AssetRepository, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, userPropertyRepository: UserPropertyRepository, conversationRepository: ConversationRepository, attachmentsRepository: MessageAttachmentDraftRepository, selfDeleteTimer: ObserveSelfDeletionTimerSettingsForConversationUseCase, publishAttachments: PublishAttachmentsUseCase, removeAttachmentDrafts: RemoveAttachmentDraftsUseCase, sendAssetMessage: ScheduleNewAssetMessageUseCase, dispatchers: KaliumDispatcher = KaliumDispatcherImpl, scope: CoroutineScope)

Use case to send a multipart message. Sends Multipart message with multiple attachments in conversations with Cell Feature enabled. For regular conversations, each attachment is sent as a separate Asset message.

SendTextMessageUseCase

class SendTextMessageUseCase(persistMessage: PersistMessageUseCase, selfUserId: QualifiedID, provideClientId: CurrentClientIdProvider, assetDataSource: AssetRepository, slowSyncRepository: SlowSyncRepository, messageSender: MessageSender, messageSendFailureHandler: MessageSendFailureHandler, userPropertyRepository: UserPropertyRepository, selfDeleteTimer: ObserveSelfDeletionTimerSettingsForConversationUseCase, dispatchers: KaliumDispatcher = KaliumDispatcherImpl, pendingMessagesEnabled: Boolean = true, scope: CoroutineScope)

SessionResetSender

internal interface SessionResetSender

SessionResetSenderImpl

internal class SessionResetSenderImpl(slowSyncRepository: SlowSyncRepository, selfUserId: QualifiedID, provideClientId: CurrentClientIdProvider, messageSender: MessageSender, dispatchers: KaliumDispatcher = KaliumDispatcherImpl) : SessionResetSender

StaleEpochVerifier

internal interface StaleEpochVerifier

StaleEpochVerifierImpl

internal class StaleEpochVerifierImpl(systemMessageInserter: SystemMessageInserter, fetchConversationUseCase: FetchConversationUseCase, conversationRepository: ConversationRepository, subconversationRepository: SubconversationRepository, mlsConversationRepository: MLSConversationRepository, joinExistingMLSConversation: JoinExistingMLSConversationUseCase) : StaleEpochVerifier

ToggleReactionResult

sealed class ToggleReactionResult

ToggleReactionUseCase

class ToggleReactionUseCase(currentClientIdProvider: CurrentClientIdProvider, userId: UserId, slowSyncRepository: SlowSyncRepository, reactionRepository: ReactionRepository, messageSender: MessageSender, persistenceEventHookNotifier: PersistenceEventHookNotifier, dispatcher: KaliumDispatcher = KaliumDispatcherImpl)

Properties

fetchOlderMessagesByConversationId

val MessageScope.fetchOlderMessagesByConversationId: FetchOlderNomadMessagesByConversationUseCase

getPaginatedFlowOfAssetMessageByConversationId

val MessageScope.getPaginatedFlowOfAssetMessageByConversationId: GetPaginatedFlowOfAssetMessageByConversationIdUseCase

getPaginatedFlowOfMessagesByConversation

val MessageScope.getPaginatedFlowOfMessagesByConversation: GetPaginatedFlowOfMessagesByConversationUseCase

getPaginatedFlowOfMessagesBySearchQueryAndConversation

val MessageScope.getPaginatedFlowOfMessagesBySearchQueryAndConversation: GetPaginatedFlowOfMessagesBySearchQueryAndConversationIdUseCase

observePaginatedImageAssetMessageByConversationId

val MessageScope.observePaginatedImageAssetMessageByConversationId: ObservePaginatedAssetImageMessages

Functions

metadata

internal fun AttachmentDraft.metadata(): AssetContent.AssetMetadata?