From 50d2faf38198042a3aa96b8cc043a149d5cc2b35 Mon Sep 17 00:00:00 2001
From: Greyson Parrelli <greyson@signal.org>
Date: Fri, 10 Dec 2021 10:29:56 -0500
Subject: [PATCH] Fix bug in reaction bottom sheet data observation.

---
 .../securesms/reactions/ReactionsRepository.kt            | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/app/src/main/java/org/thoughtcrime/securesms/reactions/ReactionsRepository.kt b/app/src/main/java/org/thoughtcrime/securesms/reactions/ReactionsRepository.kt
index aae36a7084..51ade0c42b 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/reactions/ReactionsRepository.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/reactions/ReactionsRepository.kt
@@ -1,6 +1,5 @@
 package org.thoughtcrime.securesms.reactions
 
-import android.content.Context
 import io.reactivex.rxjava3.core.Observable
 import io.reactivex.rxjava3.core.ObservableEmitter
 import io.reactivex.rxjava3.schedulers.Schedulers
@@ -18,8 +17,10 @@ class ReactionsRepository {
     return Observable.create { emitter: ObservableEmitter<List<ReactionDetails>> ->
       val databaseObserver: DatabaseObserver = ApplicationDependencies.getDatabaseObserver()
 
-      val messageObserver = DatabaseObserver.MessageObserver { messageId ->
-        emitter.onNext(fetchReactionDetails(messageId))
+      val messageObserver = DatabaseObserver.MessageObserver { reactionMessageId ->
+        if (reactionMessageId == messageId) {
+          emitter.onNext(fetchReactionDetails(reactionMessageId))
+        }
       }
 
       databaseObserver.registerMessageUpdateObserver(messageObserver)
@@ -33,7 +34,6 @@ class ReactionsRepository {
   }
 
   private fun fetchReactionDetails(messageId: MessageId): List<ReactionDetails> {
-    val context: Context = ApplicationDependencies.getApplication()
     val reactions: List<ReactionRecord> = SignalDatabase.reactions.getReactions(messageId)
 
     return reactions.map { reaction ->