persistence/com.wire.kalium.persistence.dao/ConnectionDAOImpl

ConnectionDAOImpl

class ConnectionDAOImpl(connectionsQueries: ConnectionsQueries, conversationsQueries: ConversationsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher) : ConnectionDAO

Constructors

Link copied to clipboard
constructor(connectionsQueries: ConnectionsQueries, conversationsQueries: ConversationsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

Functions

Link copied to clipboard
open suspend override fun deleteConnectionDataAndConversation(conversationId: QualifiedIDEntity)
Link copied to clipboard
open suspend override fun getConnection(conversationId: QualifiedIDEntity): ConnectionEntity?
Link copied to clipboard
open suspend override fun getConnectionByUser(userId: QualifiedIDEntity): ConnectionEntity?
Link copied to clipboard
open override fun getConnectionRequests(): Flow<List<ConnectionEntity>>
Link copied to clipboard
open override fun getConnectionRequestsForNotification(): Flow<List<ConnectionEntity>>
Link copied to clipboard
open override fun getConnections(): Flow<List<ConnectionEntity>>
Link copied to clipboard
open suspend override fun insertConnection(connectionEntity: ConnectionEntity)
Link copied to clipboard
open suspend override fun insertConnections(users: List<ConnectionEntity>)
Link copied to clipboard
open suspend override fun setAllConnectionsAsNotified()
Link copied to clipboard
open suspend override fun updateConnectionLastUpdatedTime(lastUpdate: String, id: String)
Link copied to clipboard
open suspend override fun updateConnectionStatus(userId: QualifiedIDEntity, status: ConnectionEntity.State)

Sets the user's connection status and the status of their stored request, if any, in one transaction.

Link copied to clipboard
open suspend override fun updateNotificationFlag(flag: Boolean, userId: QualifiedIDEntity)
Generated by Dokka
© 2026 Copyright