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

ConnectionRepository

interface ConnectionRepository

Inheritors

ConnectionDataSource

Functions

deleteConnection

abstract suspend fun deleteConnection(connection: <Error class: unknown class>): Either<StorageFailure, Unit>

fetchSelfUserConnections

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

getConnection

abstract suspend fun getConnection(conversationId: <Error class: unknown class>): Either<StorageFailure, <Error class: unknown class>>

getConnections

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

ignoreConnectionRequest

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

insertConnectionFromEvent

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

observeConnectionList

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

observeConnectionRequestList

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

observeConnectionRequestsForNotification

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

sendUserConnection

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

setAllConnectionsAsNotified

abstract suspend fun setAllConnectionsAsNotified()

setConnectionAsNotified

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

updateConnectionStatus

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