ReactionRepositoryImpl
internal class ReactionRepositoryImpl(selfUserId: UserId, reactionsDAO: ReactionDAO, reactionsMapper: ReactionsMapper = MapperProvider.reactionsMapper()) : ReactionRepository
Constructors
Link copied to clipboard
constructor(selfUserId: UserId, reactionsDAO: ReactionDAO, reactionsMapper: ReactionsMapper = MapperProvider.reactionsMapper())
Functions
Link copied to clipboard
open suspend override fun deleteReaction(originalMessageId: String, conversationId: ConversationId, senderUserId: UserId, emoji: String): Either<StorageFailure, Unit>
Link copied to clipboard
open suspend override fun getSelfUserReactionsForMessage(originalMessageId: String, conversationId: ConversationId): Either<StorageFailure, UserReactions>
Link copied to clipboard
open override fun observeMessageReactions(conversationId: ConversationId, messageId: String): Flow<List<MessageReaction>>
Link copied to clipboard
open suspend override fun persistReaction(originalMessageId: String, conversationId: ConversationId, senderUserId: UserId, instant: Instant, emoji: String): Either<StorageFailure, Unit>
Link copied to clipboard
open suspend override fun updateReaction(originalMessageId: String, conversationId: ConversationId, senderUserId: UserId, instant: Instant, userReactions: UserReactions): Either<StorageFailure, Unit>