logic/com.wire.kalium.logic.data.connection/ConnectionDataSource

ConnectionDataSource

internal class ConnectionDataSource(conversationDAO: <Error class: unknown class>, memberDAO: <Error class: unknown class>, connectionDAO: <Error class: unknown class>, connectionApi: <Error class: unknown class>, userDAO: <Error class: unknown class>, conversationRepository: ConversationRepository, connectionStatusMapper: ConnectionStatusMapper = MapperProvider.connectionStatusMapper(), connectionMapper: ConnectionMapper = MapperProvider.connectionMapper()) : ConnectionRepository

Constructors

constructor(conversationDAO: <Error class: unknown class>, memberDAO: <Error class: unknown class>, connectionDAO: <Error class: unknown class>, connectionApi: <Error class: unknown class>, userDAO: <Error class: unknown class>, conversationRepository: ConversationRepository, connectionStatusMapper: ConnectionStatusMapper = MapperProvider.connectionStatusMapper(), connectionMapper: ConnectionMapper = MapperProvider.connectionMapper())

Functions

deleteConnection

open suspend override fun deleteConnection(connection: <Error class: unknown class>): <Error class: unknown class>

fetchSelfUserConnections

open suspend override fun fetchSelfUserConnections(): Either<CoreFailure, Unit>

getConnection

open suspend override fun getConnection(conversationId: <Error class: unknown class>): <Error class: unknown class>

getConnections

open suspend override fun getConnections(): Either<StorageFailure, <Error class: unknown class><List<<Error class: unknown class>>>>

ignoreConnectionRequest

open suspend override fun ignoreConnectionRequest(userId: <Error class: unknown class>): Either<CoreFailure, Unit>

insertConnectionFromEvent

open suspend override fun insertConnectionFromEvent(event: Event.User.NewConnection): Either<CoreFailure, Unit>

observeConnectionList

open suspend override fun observeConnectionList(): <Error class: unknown class><List<<Error class: unknown class>>>

observeConnectionRequestList

open suspend override fun observeConnectionRequestList(): <Error class: unknown class><List<<Error class: unknown class>>>

observeConnectionRequestsForNotification

open suspend override fun observeConnectionRequestsForNotification(): <Error class: unknown class><List<<Error class: unknown class>>>

sendUserConnection

open suspend override fun sendUserConnection(userId: <Error class: unknown class>): Either<CoreFailure, Unit>

setAllConnectionsAsNotified

open suspend override fun setAllConnectionsAsNotified()

setConnectionAsNotified

open suspend override fun setConnectionAsNotified(userId: <Error class: unknown class>)

updateConnectionStatus

open suspend override fun updateConnectionStatus(userId: <Error class: unknown class>, connectionState: <Error class: unknown class>): Either<CoreFailure, <Error class: unknown class>>