logic/com.wire.kalium.logic.data.call/CallDataSource

CallDataSource

internal class CallDataSource(callApi: CallApi, serverTimeApi: ServerTimeApi, qualifiedIdMapper: QualifiedIdMapper, persistMessage: PersistMessageUseCase, callDAO: CallDAO, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, epochChangesObserver: EpochChangesObserver, subconversationRepository: SubconversationRepository, userRepository: UserRepository, teamRepository: TeamRepository, joinSubconversation: JoinSubconversationUseCase, leaveSubconversation: LeaveSubconversationUseCase, transactionProvider: CryptoTransactionProvider, callMapper: CallMapper, federatedIdMapper: FederatedIdMapper, kaliumDispatchers: KaliumDispatcher = KaliumDispatcherImpl, initialCallMetadataProfile: CallMetadataProfile = CallMetadataProfile(), initialCallQualityDataProfile: CallQualityDataProfile = CallQualityDataProfile()) : CallRepository

Constructors

CallDataSource

constructor(callApi: CallApi, serverTimeApi: ServerTimeApi, qualifiedIdMapper: QualifiedIdMapper, persistMessage: PersistMessageUseCase, callDAO: CallDAO, conversationRepository: ConversationRepository, mlsConversationRepository: MLSConversationRepository, epochChangesObserver: EpochChangesObserver, subconversationRepository: SubconversationRepository, userRepository: UserRepository, teamRepository: TeamRepository, joinSubconversation: JoinSubconversationUseCase, leaveSubconversation: LeaveSubconversationUseCase, transactionProvider: CryptoTransactionProvider, callMapper: CallMapper, federatedIdMapper: FederatedIdMapper, kaliumDispatchers: KaliumDispatcher = KaliumDispatcherImpl, initialCallMetadataProfile: CallMetadataProfile = CallMetadataProfile(), initialCallQualityDataProfile: CallQualityDataProfile = CallQualityDataProfile())

Types

Companion

object Companion

Functions

activeCallsFlow

open override fun activeCallsFlow(): Flow<List<Call>>

advanceEpoch

open suspend override fun advanceEpoch(conversationId: ConversationId)

callsFlow

open override fun callsFlow(): Flow<List<Call>>

connectToSFT

open suspend override fun connectToSFT(url: String, data: String): Either<CoreFailure, ByteArray>

createCall

open suspend override fun createCall(conversationId: ConversationId, type: ConversationTypeForCall, status: CallStatus, callerId: UserId, isMuted: Boolean, isCameraOn: Boolean, isCbrEnabled: Boolean)

currentCallProtocol

open override fun currentCallProtocol(conversationId: ConversationId): Conversation.ProtocolInfo?

establishedCallConversationId

open suspend override fun establishedCallConversationId(): ConversationId?

establishedCallsFlow

open override fun establishedCallsFlow(): Flow<List<Call>>

fetchServerTime

open suspend override fun fetchServerTime(): Instant?

getCallConfigResponse

open suspend override fun getCallConfigResponse(limit: Int?): Either<CoreFailure, String>

getCallMetadata

open override fun getCallMetadata(conversationId: ConversationId): CallMetadata?

getLastClosedCallCreatedByConversationId

open override fun getLastClosedCallCreatedByConversationId(conversationId: ConversationId): Flow<String?>

incomingCallsFlow

open override fun incomingCallsFlow(): Flow<List<Call>>

joinableCallsByConversationIdFlow

open override fun joinableCallsByConversationIdFlow(): Flow<Map<ConversationId, Call>>

joinableCallsFlow

open override fun joinableCallsFlow(): Flow<List<Call>>

joinMlsConference

open suspend override fun joinMlsConference(conversationId: ConversationId, onJoined: suspend () -> Unit, onEpochChange: suspend (ConversationId, EpochInfo) -> Unit): Either<CoreFailure, Unit>

leaveMlsConference

open suspend override fun leaveMlsConference(conversationId: ConversationId)

leaveStaleMlsConferenceIfNeeded

open suspend override fun leaveStaleMlsConferenceIfNeeded(conversationId: ConversationId)

observeCallQualityData

open override fun observeCallQualityData(conversationId: ConversationId): Flow<CallQualityData>

observeEpochInfo

open suspend override fun observeEpochInfo(conversationId: ConversationId): Either<CoreFailure, Flow<EpochInfo>>

observeLastActiveCallByConversationId

open override fun observeLastActiveCallByConversationId(conversationId: ConversationId): Flow<Call?>

observeRecentlyEndedCallMetadata

open suspend override fun observeRecentlyEndedCallMetadata(): Flow<RecentlyEndedCallMetadata>

observeStaleOpenCallsCleanupFinished

open override fun observeStaleOpenCallsCleanupFinished(): Flow<Boolean>

ongoingCallsFlow

open override fun ongoingCallsFlow(): Flow<List<Call>>

outgoingCallsFlow

open override fun outgoingCallsFlow(): Flow<List<Call>>

persistMissedCall

open suspend override fun persistMissedCall(conversationId: ConversationId)

setStaleOpenCallsCleanupFinished

open override fun setStaleOpenCallsCleanupFinished()

updateCallParticipants

open suspend override fun updateCallParticipants(conversationId: ConversationId, participants: List<ParticipantMinimized>)

updateCallQualityData

open override fun updateCallQualityData(conversationId: ConversationId, callQualityData: CallQualityData)

updateCallStatusById

open suspend override fun updateCallStatusById(conversationId: ConversationId, status: CallStatus)

updateIsAnsweredElsewhere

open suspend override fun updateIsAnsweredElsewhere(conversationId: ConversationId)

updateIsCameraOnById

open override fun updateIsCameraOnById(conversationId: ConversationId, isCameraOn: Boolean)

updateIsCbrEnabled

open suspend override fun updateIsCbrEnabled(isCbrEnabled: Boolean)

updateIsMutedById

open override fun updateIsMutedById(conversationId: ConversationId, isMuted: Boolean)

updateParticipantsActiveSpeaker

open override fun updateParticipantsActiveSpeaker(conversationId: ConversationId, activeSpeakers: Map<UserId, List<String>>)

updateRecentlyEndedCallMetadata

open suspend override fun updateRecentlyEndedCallMetadata(recentlyEndedCallMetadata: RecentlyEndedCallMetadata)