logic/com.wire.kalium.logic.data.conversation

Package-level declarations

Types

internal class ConversationDataSource(selfUserId: UserId, conversationDAO: ConversationDAO, memberDAO: MemberDAO, conversationApi: ConversationApi, messageDAO: MessageDAO, messageDraftDAO: MessageDraftDAO, clientDAO: ClientDAO, clientApi: ClientApi, conversationMetaDataDAO: ConversationMetaDataDAO, idMapper: IdMapper = MapperProvider.idMapper(), conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), memberMapper: MemberMapper = MapperProvider.memberMapper(), conversationStatusMapper: ConversationStatusMapper = MapperProvider.conversationStatusMapper(), conversationRoleMapper: ConversationRoleMapper = MapperProvider.conversationRoleMapper(), protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper(), receiptModeMapper: ReceiptModeMapper = MapperProvider.receiptModeMapper(), userMapper: UserMapper = MapperProvider.userMapper()) : ConversationRepository

ConversationGroupRepository

internal interface ConversationGroupRepository

ConversationGroupRepositoryImpl

internal class ConversationGroupRepositoryImpl(mlsConversationRepository: MLSConversationRepository, localEventRepository: LocalEventRepository, conversationMessageTimerEventHandler: ConversationMessageTimerEventHandler, conversationDAO: ConversationDAO, conversationApi: ConversationApi, newConversationMembersRepository: NewConversationMembersRepository, userRepository: UserRepository, newGroupConversationSystemMessagesCreator: Lazy<NewGroupConversationSystemMessagesCreator>, selfUserId: UserId, teamIdProvider: SelfTeamIdProvider, legalHoldHandler: LegalHoldHandler, transactionProvider: CryptoTransactionProvider, pendingActionsRepository: PendingActionsRepository, conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId), protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper()) : ConversationGroupRepository

ConversationListChannelAccess

enum ConversationListChannelAccess : Enum<ConversationListChannelAccess>

ConversationListItem

sealed interface ConversationListItem

ConversationListPosition

data class ConversationListPosition(val activityTime: Instant, val conversationId: ConversationId)

ConversationListPreview

data class ConversationListPreview(val content: MessagePreviewContent, val isSelfMessage: Boolean)

ConversationListQuery

data class ConversationListQuery(val source: ConversationListSource = ConversationListSource.ALL, val searchQuery: String = "", val fromArchive: Boolean = false, val onlyInteractionEnabled: Boolean = false, val strictMlsFilter: Boolean = true, val unreadOnly: Boolean = false)

ConversationListSource

enum ConversationListSource : Enum<ConversationListSource>

ConversationListUnreadState

data class ConversationListUnreadState(val messages: Int = 0, val mentions: Int = 0, val replies: Int = 0, val missedCalls: Int = 0, val knocks: Int = 0)

ConversationListUser

data class ConversationListUser(val id: UserId, val name: String?, val avatarAssetId: UserAssetId?, val accentId: Int, val availabilityStatus: UserAvailabilityStatus, val userType: UserTypeInfo, val connectionStatus: ConnectionState, val deleted: Boolean, val defederated: Boolean)

ConversationMapper

internal interface ConversationMapper

ConversationMapperImpl

internal class ConversationMapperImpl(selfUserId: UserId, idMapper: IdMapper, conversationStatusMapper: ConversationStatusMapper, protocolInfoMapper: ProtocolInfoMapper, userAvailabilityStatusMapper: AvailabilityStatusMapper, domainUserTypeMapper: DomainUserTypeMapper, connectionStatusMapper: ConnectionStatusMapper, conversationRoleMapper: ConversationRoleMapper, messageMapper: MessageMapper, receiptModeMapper: ReceiptModeMapper = MapperProvider.receiptModeMapper()) : ConversationMapper

ConversationMemberCounts

internal data class ConversationMemberCounts(val conversationSize: Int, val servicesCount: Int, val guestsCount: Int, val guestsProCount: Int)

ConversationMembersQueryConfig

data class ConversationMembersQueryConfig(val searchQuery: String = "", val fromArchive: Boolean = false, val onlyInteractionEnabled: Boolean = false, val onlyTeamId: String? = null, val onlyDomain: String? = null)

ConversationMetaDataDataSource

internal class ConversationMetaDataDataSource(conversationMetaDataDAO: ConversationMetaDataDAO, protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper()) : ConversationMetaDataRepository

ConversationMetaDataRepository

internal interface ConversationMetaDataRepository

ConversationQueryConfig

data class ConversationQueryConfig(val searchQuery: String = "", val fromArchive: Boolean = false, val onlyInteractionEnabled: Boolean = false, val newActivitiesOnTop: Boolean = false, val conversationFilter: ConversationFilter = ConversationFilter.All)

ConversationRepository

internal interface ConversationRepository : SendingConversations

ConversationRepositoryExtensions

internal interface ConversationRepositoryExtensions

ConversationRepositoryExtensionsImpl

internal class ConversationRepositoryExtensionsImpl(selfUserId: UserId, conversationDAO: ConversationDAO, conversationMapper: ConversationMapper, userMapper: UserMapper, memberMapper: MemberMapper) : ConversationRepositoryExtensions

ConversationSyncReason

sealed interface ConversationSyncReason

ConversationWithOtherUserName

internal data class ConversationWithOtherUserName(val conversation: Conversation, val otherUserName: String?, val selfIsMember: Boolean)

CreateGroupConversationResult

internal sealed interface CreateGroupConversationResult

EpochChangesObserver

internal interface EpochChangesObserver : MLSEpochObserver

EpochChangesObserverImpl

internal class EpochChangesObserverImpl : EpochChangesObserver

FetchConversationIfUnknownUseCase

internal interface FetchConversationIfUnknownUseCase

Use case responsible for ensuring that a conversation is available locally.

FetchConversationIfUnknownUseCaseImpl

internal class FetchConversationIfUnknownUseCaseImpl(conversationRepository: ConversationRepository, fetchConversation: FetchConversationUseCase) : FetchConversationIfUnknownUseCase

FetchConversationsUseCase

internal interface FetchConversationsUseCase

Use case responsible for fetching all available conversations from the backend, handling pagination, and persisting them locally.

FetchConversationsUseCaseImpl

internal class FetchConversationsUseCaseImpl(conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase) : FetchConversationsUseCase

FetchConversationUseCase

interface FetchConversationUseCase

Use case responsible for fetching a single conversation from the backend and persisting it locally if the fetch is successful.

FetchConversationUseCaseImpl

internal class FetchConversationUseCaseImpl(conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase, transactionProvider: CryptoTransactionProvider) : FetchConversationUseCase

FetchMLSOneToOneConversationUseCase

internal interface FetchMLSOneToOneConversationUseCase

FetchMLSOneToOneConversationUseCaseImpl

internal class FetchMLSOneToOneConversationUseCaseImpl(selfUserId: UserId, conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase, conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId)) : FetchMLSOneToOneConversationUseCase

GroupWithEpoch

internal data class GroupWithEpoch(val groupId: GroupID, val epoch: ULong)

JoinExistingMLSConversationsUseCase

internal interface JoinExistingMLSConversationsUseCase

Send an external commit to join all MLS conversations for which the user is a member, but has not yet joined the corresponding MLS group.

JoinExistingMLSConversationsUseCaseImpl

internal class JoinExistingMLSConversationsUseCaseImpl(featureSupport: FeatureSupport, clientRepository: ClientRepository, conversationRepository: ConversationRepository, joinExistingMLSConversationUseCase: JoinExistingMLSConversationUseCase, transactionProvider: CryptoTransactionProvider, pendingActionsRepository: PendingActionsRepository, selfUserId: UserId, maxConcurrentJoins: Int = DEFAULT_MAX_CONCURRENT_JOINS, maxThrottleRetries: Int = DEFAULT_MAX_THROTTLE_RETRIES, throttleRetryDelayMs: Long = DEFAULT_THROTTLE_RETRY_DELAY_MS) : JoinExistingMLSConversationsUseCase

JoinExistingMLSConversationUseCase

internal interface JoinExistingMLSConversationUseCase

Use case for joining or establishing an MLS group for an existing conversation. If the conversation is MLS-capable, it checks if it is already established. If not, it establishes the MLS group, otherwise it sends an external commit to join an MLS conversation for which the user is a member, but has not yet joined the corresponding MLS group.

JoinExistingMLSConversationUseCaseImpl

internal class JoinExistingMLSConversationUseCaseImpl(featureSupport: FeatureSupport, conversationApi: ConversationApi, clientRepository: ClientRepository, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, fetchMLSOneToOneConversation: FetchMLSOneToOneConversationUseCase, fetchConversation: FetchConversationUseCase, resetMLSConversation: ResetMLSConversationUseCase, selfUserId: UserId, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl) : JoinExistingMLSConversationUseCase

JoinSubconversationUseCase

internal interface JoinSubconversationUseCase

Join a sub-conversation of a MLS conversation

JoinSubconversationUseCaseImpl

internal class JoinSubconversationUseCaseImpl(conversationApi: ConversationApi, mlsConversationRepository: MLSConversationRepository, subconversationRepository: SubconversationRepository, transactionProvider: CryptoTransactionProvider) : JoinSubconversationUseCase

LeaveSubconversationUseCase

internal interface LeaveSubconversationUseCase

Leave a sub-conversation you've previously joined

LeaveSubconversationUseCaseImpl

internal class LeaveSubconversationUseCaseImpl(val conversationApi: ConversationApi, val subconversationRepository: SubconversationRepository, val selfUserId: UserId, val selfClientIdProvider: CurrentClientIdProvider, val subgroupProposals: PendingSubconversationProposals) : LeaveSubconversationUseCase

LegalHoldStatusMapper

internal interface LegalHoldStatusMapper

LegalHoldStatusMapperImpl

internal object LegalHoldStatusMapperImpl : LegalHoldStatusMapper

MLSConversationDataSource

internal class MLSConversationDataSource(selfUserId: UserId, keyPackageRepository: KeyPackageRepository, conversationDAO: ConversationDAO, clientApi: ClientApi, mlsPublicKeysRepository: MLSPublicKeysRepository, proposalTimersFlow: MutableSharedFlow<ProposalTimer>, keyPackageLimitsProvider: KeyPackageLimitsProvider, mutex: Mutex, idMapper: IdMapper = MapperProvider.idMapper(), conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), dispatchers: KaliumDispatcher = KaliumDispatcherImpl) : MLSConversationRepository

MLSConversationRepository

internal interface MLSConversationRepository : MLSMemberAdder

NewConversationMembersRepository

internal interface NewConversationMembersRepository

Handles the addition of members to a new conversation and the related system messages when a conversation is started. Either all users are added or some of them could fail to be added.

NewConversationMembersRepositoryImpl

internal class NewConversationMembersRepositoryImpl(memberDAO: MemberDAO, newGroupConversationSystemMessagesCreator: Lazy<NewGroupConversationSystemMessagesCreator>, idMapper: IdMapper = MapperProvider.idMapper(), memberMapper: MemberMapper = MapperProvider.memberMapper()) : NewConversationMembersRepository

PersistConversationsUseCase

internal interface PersistConversationsUseCase

Use case responsible for persisting a list of conversations in the local database.

PersistConversationsUseCaseImpl

internal class PersistConversationsUseCaseImpl(selfUserId: UserId, conversationRepository: ConversationRepository, selfTeamIdProvider: SelfTeamIdProvider, idMapper: IdMapper = IdMapperImpl(), conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId)) : PersistConversationsUseCase

PersistConversationUseCase

internal interface PersistConversationUseCase

Use case responsible for persisting a single conversation, if it doesn't already exist or if its group state is not yet fully established.

PersistConversationUseCaseImpl

internal class PersistConversationUseCaseImpl(conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase) : PersistConversationUseCase

PreparedX509KeyPackages

internal data class PreparedX509KeyPackages(val keyPackages: List<ByteArray>, val cipherSuite: CipherSuite)

ResetMLSConversationResult

sealed class ResetMLSConversationResult

ResetMLSConversationUseCase

interface ResetMLSConversationUseCase

Reset an MLS conversation which cannot be recovered by any other means.

ResetMLSConversationUseCaseImpl

internal class ResetMLSConversationUseCaseImpl(selfUserId: UserId, userConfig: UserConfigRepository, transactionProvider: CryptoTransactionProvider, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, fetchConversationUseCase: FetchConversationUseCase, endCallOnMLSReset: EndCallOnMLSResetUseCase, kaliumConfigs: KaliumConfigs) : ResetMLSConversationUseCase

SubconversationRepository

internal interface SubconversationRepository

SubconversationRepositoryImpl

internal class SubconversationRepositoryImpl(conversationApi: ConversationApi, subconversations: SubconversationDAO) : SubconversationRepository

TypingIndicatorIncomingRepository

internal interface TypingIndicatorIncomingRepository

TypingIndicatorIncomingRepositoryImpl

internal class TypingIndicatorIncomingRepositoryImpl(userPropertyRepository: UserPropertyRepository, timeSource: TimeSource.WithComparableMarks = TimeSource.Monotonic) : TypingIndicatorIncomingRepository

Remembers, per conversation, when each user last sent a typing STARTED event.

TypingIndicatorOutgoingRepository

internal interface TypingIndicatorOutgoingRepository

TypingIndicatorOutgoingRepositoryImpl

internal class TypingIndicatorOutgoingRepositoryImpl(typingIndicatorSenderHandler: TypingIndicatorSenderHandler, userPropertyRepository: UserPropertyRepository) : TypingIndicatorOutgoingRepository

TypingIndicatorSenderHandler

internal interface TypingIndicatorSenderHandler

Outgoing user typing sent events manager.

TypingIndicatorSenderHandlerImpl

internal class TypingIndicatorSenderHandlerImpl(conversationRepository: ConversationRepository, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl, userSessionCoroutineScope: CoroutineScope) : TypingIndicatorSenderHandler, CoroutineScope

UpdateConversationProtocolUseCase

internal interface UpdateConversationProtocolUseCase

Use case responsible for updating the protocol of a conversation, either locally or remotely.

UpdateConversationProtocolUseCaseImpl