diff --git a/crates/bonfire/src/websocket.rs b/crates/bonfire/src/websocket.rs index 913245e9..bdada514 100644 --- a/crates/bonfire/src/websocket.rs +++ b/crates/bonfire/src/websocket.rs @@ -457,30 +457,8 @@ async fn worker( }; match payload { - ClientMessage::BeginTyping { channel } => { - if !subscribed.read().await.contains(&channel) { - 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::BeginTyping { .. } => {} + ClientMessage::EndTyping { .. } => {} ClientMessage::Subscribe { server_id } => { let mut servers = active_servers.lock().await; let has_item = servers.contains_key(&server_id); diff --git a/crates/core/database/src/models/users/model.rs b/crates/core/database/src/models/users/model.rs index 0c2b6cee..e35d4809 100644 --- a/crates/core/database/src/models/users/model.rs +++ b/crates/core/database/src/models/users/model.rs @@ -653,14 +653,14 @@ impl User { self.apply_options(partial.clone()); db.update_user(&self.id, &partial, remove.clone()).await?; - EventV1::UserUpdate { - id: self.id.clone(), - data: partial.into(), - clear: remove.into_iter().map(|v| v.into()).collect(), - event_id: Some(Ulid::new().to_string()), - } - .p_user(self.id.clone(), db) - .await; + // EventV1::UserUpdate { + // id: self.id.clone(), + // data: partial.into(), + // clear: remove.into_iter().map(|v| v.into()).collect(), + // event_id: Some(Ulid::new().to_string()), + // } + // .p_user(self.id.clone(), db) + // .await; Ok(()) }