ReactionDAOImpl

Constructors

constructor(reactionsQueries: ReactionsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

open suspend override fun countMessageReactionsBackup(): Long

open suspend override fun deleteReaction(originalMessageId: String, conversationId: ConversationIDEntity, senderUserId: UserIDEntity, emoji: String)

open override fun getPagedReactionsFlow(pageSize: Int): Flow<List<MessageReactionsEntity>>

open suspend override fun getReaction(originalMessageId: String, conversationId: ConversationIDEntity, senderUserId: UserIDEntity): UserReactionsEntity

open suspend override fun insertOrIgnoreReactions(reactions: List<MessageReactionsEntity>, instant: Instant)

open suspend override fun insertReaction(originalMessageId: String, conversationId: ConversationIDEntity, senderUserId: UserIDEntity, instant: Instant, emoji: String)

open override fun observeMessageReactions(conversationId: QualifiedIDEntity, messageId: String): Flow<List<MessageReactionEntity>>

open suspend override fun updateReactions(originalMessageId: String, conversationId: ConversationIDEntity, senderUserId: UserIDEntity, instant: Instant, reactions: UserReactionsEntity)