diff --git a/src/notifications/events.rs b/src/notifications/events.rs index 74b55755..5ec1fc85 100644 --- a/src/notifications/events.rs +++ b/src/notifications/events.rs @@ -36,6 +36,7 @@ pub enum ServerboundNotification { Authenticate(AuthType), BeginTyping { channel: String }, EndTyping { channel: String }, + Ping { data: Vec } } #[derive(Serialize, Deserialize, Debug, Clone)] diff --git a/src/notifications/websocket.rs b/src/notifications/websocket.rs index 66322407..e6ae3506 100644 --- a/src/notifications/websocket.rs +++ b/src/notifications/websocket.rs @@ -120,6 +120,7 @@ async fn accept(stream: TcpStream) { let maybe_decoded = match msg { Message::Text(text) => serde_json::from_str::(&text).map_err(|e| e.to_string()), Message::Binary(vec) => rmp_serde::decode::from_read::<&[u8], ServerboundNotification>(vec.as_slice()).map_err(|e| e.to_string()), + Message::Ping(vec) => Ok(ServerboundNotification::Ping { data: vec }), _ => return Ok(()) }; @@ -296,6 +297,9 @@ async fn accept(stream: TcpStream) { return Ok(()); } } + ServerboundNotification::Ping { data } => { + info!("Ping received from User {}. Payload: {:?}", &addr, data); + } } Ok(()) });