From 23238aa8fe1cdceea414c6876db42d5a3c92c3ad Mon Sep 17 00:00:00 2001
From: rcmerci <rcmerci@gmail.com>
Date: Tue, 25 Jun 2024 12:31:21 +0800
Subject: [PATCH] fix(rtc): dedupe recent-updates-flow

---
 src/main/frontend/components/rtc/flows.cljs | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/main/frontend/components/rtc/flows.cljs b/src/main/frontend/components/rtc/flows.cljs
index 804cc3107..c4ff91d10 100644
--- a/src/main/frontend/components/rtc/flows.cljs
+++ b/src/main/frontend/components/rtc/flows.cljs
@@ -47,10 +47,11 @@
                                     [user-uuid
                                      {:user-info (user-uuid->user user-uuid)
                                       :updates
-                                      (take-while
-                                       (fn [[inst _]] (> inst mins-ago))
+                                      (sequence
+                                       (comp (take-while (fn [[inst _]] (> inst mins-ago)))
+                                             (dedupe))
                                        (concat (get-in latest-updates [graph-uuid user-uuid])
-                                               (get-in @*buffer [graph-uuid user-uuid])))}]))
+                                               (get-in @*buffer [graph-uuid user-uuid :updates])))}]))
                              latest-keys)}]
                   (swap! *buffer merge new-map)
                   @*buffer))))