From 2322b6ae7f5167230cb24c91eeb47775fe0bb148 Mon Sep 17 00:00:00 2001 From: Evie Viau Date: Thu, 17 Feb 2022 19:13:48 -0500 Subject: [PATCH] Add more debugging printlns --- src/main.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main.rs b/src/main.rs index b6bce46..931cc2a 100644 --- a/src/main.rs +++ b/src/main.rs @@ -64,6 +64,7 @@ async fn handle_conn(peer: SocketAddr, stream: TcpStream) -> tokio_tungstenite:: .map(char::from) .collect(); + println!("HELLO to {}", &peer); ws_sender.send(Message::Text( serde_json::to_string( &SocketMessage { @@ -88,14 +89,18 @@ async fn handle_conn(peer: SocketAddr, stream: TcpStream) -> tokio_tungstenite:: if op.is_ok() { match op.unwrap().0 { OpCode::IDENTIFY => { + println!("IDENTIFY from {}", &peer); unimplemented!() } OpCode::RESUME => { + println!("RESUME from {}", &peer); unimplemented!() } OpCode::HEARTBEAT => { + println!("HEARTBEAT from {}", &peer); + println!("HEARTBEAT_ACK to {}", &peer); ws_sender.send(Message::Text( serde_json::to_string( &SocketMessage { @@ -109,6 +114,7 @@ async fn handle_conn(peer: SocketAddr, stream: TcpStream) -> tokio_tungstenite:: } OpCode::INFO => { + println!("INFO from {}", &peer); unimplemented!() },