persistence/com.wire.kalium.persistence.dao.call/CallDAOImpl

CallDAOImpl

internal class CallDAOImpl(callsQueries: CallsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher, mapper: CallMapper = CallMapper) : CallDAO

Constructors

constructor(callsQueries: CallsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher, mapper: CallMapper = CallMapper)

Functions

getCallerIdByConversationId

open suspend override fun getCallerIdByConversationId(conversationId: QualifiedIDEntity): String?

getCallStatusByConversationId

open suspend override fun getCallStatusByConversationId(conversationId: QualifiedIDEntity): CallEntity.Status?

getEstablishedCall

open suspend override fun getEstablishedCall(): CallEntity

getLastCallConversationTypeByConversationId

open suspend override fun getLastCallConversationTypeByConversationId(conversationId: QualifiedIDEntity): ConversationEntity.Type?

getLastClosedCallByConversationId

open override fun getLastClosedCallByConversationId(conversationId: QualifiedIDEntity): Flow<String?>

open suspend override fun insertCall(call: CallEntity)

observeActiveCalls

open override fun observeActiveCalls(): Flow<List<CallEntity>>

open override fun observeCalls(): Flow<List<CallEntity>>

observeEstablishedCalls

open override fun observeEstablishedCalls(): Flow<List<CallEntity>>

observeIncomingCalls

open override fun observeIncomingCalls(): Flow<List<CallEntity>>

observeLastActiveCallByConversationId

open override fun observeLastActiveCallByConversationId(conversationId: QualifiedIDEntity): Flow<CallEntity?>

observeOngoingCalls

open override fun observeOngoingCalls(): Flow<List<CallEntity>>

observeOutgoingCalls

open override fun observeOutgoingCalls(): Flow<List<CallEntity>>

updateLastCallStatusByConversationId

open suspend override fun updateLastCallStatusByConversationId(status: CallEntity.Status, conversationId: QualifiedIDEntity)