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

Package-level declarations

Types

data class ApplicationMessage(val message: ByteArray, val senderID: <Error class: unknown class>, val senderClientID: <Error class: unknown class>)

ConversationDataSource

internal class ConversationDataSource(selfUserId: <Error class: unknown class>, conversationDAO: <Error class: unknown class>, memberDAO: <Error class: unknown class>, conversationApi: <Error class: unknown class>, messageDAO: <Error class: unknown class>, messageDraftDAO: <Error class: unknown class>, clientDAO: <Error class: unknown class>, clientApi: <Error class: unknown class>, conversationMetaDataDAO: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, 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()) : ConversationRepository

ConversationGroupRepository

interface ConversationGroupRepository

ConversationGroupRepositoryImpl

internal class ConversationGroupRepositoryImpl(mlsConversationRepository: MLSConversationRepository, joinExistingMLSConversation: JoinExistingMLSConversationUseCase, memberJoinEventHandler: MemberJoinEventHandler, memberLeaveEventHandler: MemberLeaveEventHandler, conversationMessageTimerEventHandler: ConversationMessageTimerEventHandler, conversationDAO: <Error class: unknown class>, conversationApi: <Error class: unknown class>, newConversationMembersRepository: NewConversationMembersRepository, userRepository: UserRepository, newGroupConversationSystemMessagesCreator: <Error class: unknown class><NewGroupConversationSystemMessagesCreator>, selfUserId: <Error class: unknown class>, teamIdProvider: SelfTeamIdProvider, legalHoldHandler: LegalHoldHandler, conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId), protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper()) : ConversationGroupRepository

ConversationMapper

interface ConversationMapper

ConversationMapperImpl

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

ConversationMetaDataDataSource

internal class ConversationMetaDataDataSource(conversationMetaDataDAO: <Error class: unknown class>, protocolInfoMapper: ProtocolInfoMapper = MapperProvider.protocolInfoMapper()) : ConversationMetaDataRepository

ConversationMetaDataRepository

interface ConversationMetaDataRepository

ConversationQueryConfig

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

ConversationRepository

interface ConversationRepository

ConversationRepositoryExtensions

interface ConversationRepositoryExtensions

ConversationRepositoryExtensionsImpl

class ConversationRepositoryExtensionsImpl(conversationDAO: <Error class: unknown class>, conversationMapper: ConversationMapper) : ConversationRepositoryExtensions

ConversationRoleMapper

interface ConversationRoleMapper

ConversationRoleMapperImpl

internal class ConversationRoleMapperImpl : ConversationRoleMapper

ConversationStatusMapper

interface ConversationStatusMapper

ConversationStatusMapperImpl

class ConversationStatusMapperImpl(val idMapper: IdMapper) : ConversationStatusMapper

DecryptedMessageBundle

data class DecryptedMessageBundle(val groupID: <Error class: unknown class>, val applicationMessage: ApplicationMessage?, val commitDelay: Long?, val identity: <Error class: unknown class>?)

EpochChangesObserver

interface EpochChangesObserver

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) : FetchConversationUseCase

FetchMLSOneToOneConversationUseCase

internal interface FetchMLSOneToOneConversationUseCase

FetchMLSOneToOneConversationUseCaseImpl

internal class FetchMLSOneToOneConversationUseCaseImpl(selfUserId: <Error class: unknown class>, conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase, conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId)) : FetchMLSOneToOneConversationUseCase

GroupWithEpoch

data class GroupWithEpoch(val groupId: <Error class: unknown class>, val epoch: <Error class: unknown class>)

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) : JoinExistingMLSConversationsUseCase

JoinExistingMLSConversationUseCase

internal interface JoinExistingMLSConversationUseCase

Send 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: <Error class: unknown class>, clientRepository: ClientRepository, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, fetchMLSOneToOneConversation: FetchMLSOneToOneConversationUseCase, fetchConversation: FetchConversationUseCase, selfUserId: <Error class: unknown class>, kaliumDispatcher: <Error class: unknown class> = KaliumDispatcherImpl) : JoinExistingMLSConversationUseCase

JoinSubconversationUseCase

internal interface JoinSubconversationUseCase

Join a sub-conversation of a MLS conversation

JoinSubconversationUseCaseImpl

internal class JoinSubconversationUseCaseImpl(conversationApi: <Error class: unknown class>, mlsConversationRepository: MLSConversationRepository, subconversationRepository: SubconversationRepository) : JoinSubconversationUseCase

LeaveSubconversationUseCase

internal interface LeaveSubconversationUseCase

Leave a sub-conversation you've previously joined

LeaveSubconversationUseCaseImpl

internal class LeaveSubconversationUseCaseImpl(val conversationApi: <Error class: unknown class>, val mlsClientProvider: MLSClientProvider, val subconversationRepository: SubconversationRepository, val selfUserId: <Error class: unknown class>, val selfClientIdProvider: CurrentClientIdProvider) : LeaveSubconversationUseCase

LegalHoldStatusMapper

interface LegalHoldStatusMapper

LegalHoldStatusMapperImpl

internal object LegalHoldStatusMapperImpl : LegalHoldStatusMapper

MemberMapper

interface MemberMapper

MemberMapperImpl

internal class MemberMapperImpl(idMapper: IdMapper, roleMapper: ConversationRoleMapper) : MemberMapper

MLSCommitBundleMapper

interface MLSCommitBundleMapper

MLSCommitBundleMapperImpl

class MLSCommitBundleMapperImpl : MLSCommitBundleMapper

MLSConversationDataSource

internal class MLSConversationDataSource(selfUserId: <Error class: unknown class>, keyPackageRepository: KeyPackageRepository, mlsClientProvider: MLSClientProvider, conversationDAO: <Error class: unknown class>, clientApi: <Error class: unknown class>, mlsPublicKeysRepository: MLSPublicKeysRepository, proposalTimersFlow: <Error class: unknown class><<Error class: unknown class>>, keyPackageLimitsProvider: KeyPackageLimitsProvider, revocationListChecker: RevocationListChecker, certificateRevocationListRepository: CertificateRevocationListRepository, mutex: <Error class: unknown class>, idMapper: IdMapper = MapperProvider.idMapper(), conversationMapper: ConversationMapper = MapperProvider.conversationMapper(selfUserId), dispatchers: <Error class: unknown class> = KaliumDispatcherImpl) : MLSConversationRepository

MLSConversationRepository

interface MLSConversationRepository

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: <Error class: unknown class>, newGroupConversationSystemMessagesCreator: <Error class: unknown class><NewGroupConversationSystemMessagesCreator>, idMapper: IdMapper = MapperProvider.idMapper(), memberMapper: MemberMapper = MapperProvider.memberMapper()) : NewConversationMembersRepository

NewGroupConversationSystemMessagesCreator

internal interface NewGroupConversationSystemMessagesCreator

This class is responsible to generate system messages for new group conversations. This can be orchestrated by different components that creates a new group conversation, ie: Events, UseCases, Repositories.

NewGroupConversationSystemMessagesCreatorImpl

internal class NewGroupConversationSystemMessagesCreatorImpl(persistMessage: PersistMessageUseCase, selfTeamIdProvider: SelfTeamIdProvider, qualifiedIdMapper: QualifiedIdMapper, selfUserId: <Error class: unknown class>) : NewGroupConversationSystemMessagesCreator

PersistConversationsUseCase

interface PersistConversationsUseCase

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

PersistConversationsUseCaseImpl

internal class PersistConversationsUseCaseImpl(selfUserId: <Error class: unknown class>, conversationRepository: ConversationRepository, selfTeamIdProvider: SelfTeamIdProvider, mlsClientProvider: MLSClientProvider, 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

ProtocolInfoMapper

interface ProtocolInfoMapper

ProtocolInfoMapperImpl

class ProtocolInfoMapperImpl(val idMapper: IdMapper = MapperProvider.idMapper()) : ProtocolInfoMapper

ReceiptModeMapper

interface ReceiptModeMapper

ReceiptModeMapperImpl

class ReceiptModeMapperImpl(val idMapper: IdMapper = MapperProvider.idMapper()) : ReceiptModeMapper

SubconversationRepository

interface SubconversationRepository

SubconversationRepositoryImpl

class SubconversationRepositoryImpl(conversationApi: <Error class: unknown class>) : SubconversationRepository

TypingIndicatorIncomingRepository

internal interface TypingIndicatorIncomingRepository

TypingIndicatorIncomingRepositoryImpl

internal class TypingIndicatorIncomingRepositoryImpl(userTypingCache: <Error class: unknown class><<Error class: unknown class>, MutableSet<<Error class: unknown class>>>, userPropertyRepository: UserPropertyRepository) : TypingIndicatorIncomingRepository

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: <Error class: unknown class> = KaliumDispatcherImpl, userSessionCoroutineScope: <Error class: unknown class>) : TypingIndicatorSenderHandler

UpdateConversationProtocolUseCase

interface UpdateConversationProtocolUseCase

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

UpdateConversationProtocolUseCaseImpl

internal class UpdateConversationProtocolUseCaseImpl(conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase) : UpdateConversationProtocolUseCase

Functions

fromDaoModelToType

fun <Error class: unknown class>.fromDaoModelToType(isChannel: Boolean): <Error class: unknown class>

link

fun <Error class: unknown class>.link(accountUrl: String): String

fun Event.Conversation.CodeUpdated.link(accountUrl: String): String

toApi

internal fun <Error class: unknown class>.toApi(): <Error class: unknown class>

fun <Error class: unknown class>.toApi(): <Error class: unknown class>

toConversationType

internal fun <Error class: unknown class>.toConversationType(selfUserTeamId: <Error class: unknown class>?): <Error class: unknown class>

toDAO

internal fun <Error class: unknown class>.toDAO(): <Error class: unknown class>

toDao

internal fun <Error class: unknown class>.toDao(): <Error class: unknown class>

toDaoChannelPermission

fun <Error class: unknown class>.toDaoChannelPermission(): <Error class: unknown class>

toModel

internal fun <Error class: unknown class>.toModel(): <Error class: unknown class>

fun <Error class: unknown class>.toModel(): <Error class: unknown class>

fun <Error class: unknown class>.toModel(groupID: <Error class: unknown class>): DecryptedMessageBundle

toModelChannelAccess

fun <Error class: unknown class>.toModelChannelAccess(): <Error class: unknown class>

toModelChannelPermission

fun <Error class: unknown class>.toModelChannelPermission(): <Error class: unknown class>

toStatusDto

fun <Error class: unknown class>.toStatusDto(): <Error class: unknown class>