From 1f8ea963ad742f693f405e6438f1c343c81e6579 Mon Sep 17 00:00:00 2001
From: Paul Makles <me@insrt.uk>
Date: Fri, 13 Feb 2026 19:49:23 +0000
Subject: [PATCH] fix: cut presence traffic too while we engineer a new events
 architecture (#561)

Signed-off-by: izzy <me@insrt.uk>
---
 crates/bonfire/src/events/impl.rs | 42 ++++++++++++++++---------------
 1 file changed, 22 insertions(+), 20 deletions(-)

diff --git a/crates/bonfire/src/events/impl.rs b/crates/bonfire/src/events/impl.rs
index e0e9ac71..82667175 100644
--- a/crates/bonfire/src/events/impl.rs
+++ b/crates/bonfire/src/events/impl.rs
@@ -169,7 +169,9 @@ impl State {
             }) {
                 if let Ok(Some(voice_state)) = get_channel_voice_state(channel).await {
                     if let Some(server) = channel.server() {
-                        let set = voice_state_server_members.entry(server.to_string()).or_default();
+                        let set = voice_state_server_members
+                            .entry(server.to_string())
+                            .or_default();
 
                         for participant in &voice_state.participants {
                             user_ids.insert(participant.id.clone());
@@ -397,27 +399,27 @@ impl State {
 
     /// Push presence change to the user and all associated server topics
     pub async fn broadcast_presence_change(&self, target: bool) {
-        if if let Some(status) = &self.cache.users.get(&self.cache.user_id).unwrap().status {
-            status.presence != Some(Presence::Invisible)
-        } else {
-            true
-        } {
-            let event = EventV1::UserUpdate {
-                id: self.cache.user_id.clone(),
-                data: v0::PartialUser {
-                    online: Some(target),
-                    ..Default::default()
-                },
-                clear: vec![],
-                event_id: Some(ulid::Ulid::new().to_string()),
-            };
+        // if if let Some(status) = &self.cache.users.get(&self.cache.user_id).unwrap().status {
+        //     status.presence != Some(Presence::Invisible)
+        // } else {
+        //     true
+        // } {
+        //     let event = EventV1::UserUpdate {
+        //         id: self.cache.user_id.clone(),
+        //         data: v0::PartialUser {
+        //             online: Some(target),
+        //             ..Default::default()
+        //         },
+        //         clear: vec![],
+        //         event_id: Some(ulid::Ulid::new().to_string()),
+        //     };
 
-            for server in self.cache.servers.keys() {
-                event.clone().p(server.clone()).await;
-            }
+        //     for server in self.cache.servers.keys() {
+        //         event.clone().p(server.clone()).await;
+        //     }
 
-            event.p(self.cache.user_id.clone()).await;
-        }
+        //     event.p(self.cache.user_id.clone()).await;
+        // }
     }
 
     /// Handle an incoming event for protocol version 1