From 4d22cb502e6d20259549cffd4fd4b99d32e0f748 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jakub=20Kub=C3=ADk?= <jakub.kubik.it@protonmail.com>
Date: Mon, 21 Nov 2022 22:48:58 +0100
Subject: [PATCH] feat(presence): remove old presence updates

---
 src/database/key_value/rooms/edus/presence.rs | 7 +++++++
 src/database/mod.rs                           | 3 ---
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/database/key_value/rooms/edus/presence.rs b/src/database/key_value/rooms/edus/presence.rs
index 3d6eb208..117c9da5 100644
--- a/src/database/key_value/rooms/edus/presence.rs
+++ b/src/database/key_value/rooms/edus/presence.rs
@@ -340,6 +340,13 @@ impl service::rooms::edus::presence::Data for KeyValueDatabase {
                         Some(user_id)
                     })
                 {
+                    match userid_presenceupdate.remove(&*user_id.as_bytes()) {
+                        Ok(_) => (),
+                        Err(e) => {
+                            error!("An errord occured while removing a stale presence update: {e}")
+                        }
+                    }
+
                     for room_id in services()
                         .rooms
                         .state_cache
diff --git a/src/database/mod.rs b/src/database/mod.rs
index 563076e1..7baa512a 100644
--- a/src/database/mod.rs
+++ b/src/database/mod.rs
@@ -825,9 +825,6 @@ impl KeyValueDatabase {
             );
         }
 
-        // Flush old presence data
-        db.userid_presenceupdate.clear()?;
-
         services().admin.start_handler();
 
         // Set emergency access for the conduit user