ConnectionDataSource

internal class ConnectionDataSource(conversationDAO: ConversationDAO, memberDAO: MemberDAO, connectionDAO: ConnectionDAO, connectionApi: ConnectionApi, userDAO: UserDAO, conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase, connectionStatusMapper: ConnectionStatusMapper = MapperProvider.connectionStatusMapper(), connectionMapper: ConnectionMapper = MapperProvider.connectionMapper()) : ConnectionRepository

Constructors

constructor(conversationDAO: ConversationDAO, memberDAO: MemberDAO, connectionDAO: ConnectionDAO, connectionApi: ConnectionApi, userDAO: UserDAO, conversationRepository: ConversationRepository, persistConversations: PersistConversationsUseCase, connectionStatusMapper: ConnectionStatusMapper = MapperProvider.connectionStatusMapper(), connectionMapper: ConnectionMapper = MapperProvider.connectionMapper())

open suspend override fun deleteConnection(connection: Connection): Either<StorageFailure, Unit>

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

open suspend override fun getConnection(conversationId: ConversationId): Either<StorageFailure, ConversationDetails.Connection>

open override fun getConnections(): Either<StorageFailure, Flow<List<ConversationDetails>>>

open suspend override fun ignoreConnectionRequest(transactionContext: CryptoTransactionContext, userId: UserId): Either<CoreFailure, Unit>

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

open override fun observeConnectionList(): Flow<List<Connection>>

open suspend override fun sendUserConnection(transactionContext: CryptoTransactionContext, userId: UserId): Either<CoreFailure, Unit>

open suspend override fun setAllConnectionsAsNotified()

open suspend override fun setConnectionAsNotified(userId: UserId)

open suspend override fun updateConnectionStatus(transactionContext: CryptoTransactionContext, userId: UserId, connectionState: ConnectionState): Either<CoreFailure, Connection>

suspend fun updateRemoteConnectionStatus(transactionContext: CryptoTransactionContext, userId: UserId, connectionState: ConnectionState): Either<CoreFailure, ConnectionDTO>