HMC/handmade-revolt-backend
6
0
Fork 0
forked from jmug/stoatchat
Code Pull Requests Actions Packages Releases 2 Activity

fix: cut events traffic while we engineer a new events architecture (#559)

Browse Source 
Signed-off-by: izzy <me@insrt.uk>
This commit is contained in:
Paul Makles
2026-02-13 19:40:51 +00:00
committed by GitHub
parent 2e87696c83
commit a11986ba1a
2 changed files with 10 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
crates/bonfire/src/websocket.rs
View File

@@ -457,30 +457,8 @@ async fn worker(
}; };
match payload { match payload {
ClientMessage::BeginTyping { channel } => { ClientMessage::BeginTyping { .. } => {}
if !subscribed.read().await.contains(&channel) { ClientMessage::EndTyping { .. } => {}
continue;
}
EventV1::ChannelStartTyping {
id: channel.clone(),
user: user_id.clone(),
}
.p(channel.clone())
.await;
}
ClientMessage::EndTyping { channel } => {
if !subscribed.read().await.contains(&channel) {
continue;
}
EventV1::ChannelStopTyping {
id: channel.clone(),
user: user_id.clone(),
}
.p(channel.clone())
.await;
}
ClientMessage::Subscribe { server_id } => { ClientMessage::Subscribe { server_id } => {
let mut servers = active_servers.lock().await; let mut servers = active_servers.lock().await;
let has_item = servers.contains_key(&server_id); let has_item = servers.contains_key(&server_id);

16
crates/core/database/src/models/users/model.rs
View File

@@ -653,14 +653,14 @@ impl User {
self.apply_options(partial.clone()); self.apply_options(partial.clone());
db.update_user(&self.id, &partial, remove.clone()).await?; db.update_user(&self.id, &partial, remove.clone()).await?;
EventV1::UserUpdate { // EventV1::UserUpdate {
id: self.id.clone(), // id: self.id.clone(),
data: partial.into(), // data: partial.into(),
clear: remove.into_iter().map(|v| v.into()).collect(), // clear: remove.into_iter().map(|v| v.into()).collect(),
event_id: Some(Ulid::new().to_string()), // event_id: Some(Ulid::new().to_string()),
} // }
.p_user(self.id.clone(), db) // .p_user(self.id.clone(), db)
.await; // .await;
Ok(()) Ok(())
} }