diff --git a/server/src/main.rs b/server/src/main.rs index cca71d3..2ce3e48 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -1,7 +1,8 @@ use futures_util::{SinkExt, StreamExt}; use serde::{Deserialize, Serialize}; use tokio::net::TcpListener; -use tokio_tungstenite::accept_async; +use tokio_tungstenite::{accept_async, connect_async}; +use url::Url; #[derive(Serialize, Deserialize, Debug)] struct Message { @@ -25,7 +26,17 @@ async fn main() { while let Some(Ok(msg)) = read.next().await { if msg.is_text() { let txt = msg.to_text().unwrap(); - if let Ok(json) = serde_json::from_str::(txt) {} + if let Ok(json) = serde_json::from_str::(txt) { + println!("Recieved: {:?}", json); + + //for testing the write channel, we send back the + //same data the client sent + let reply = serde_json::to_string(&json).unwrap(); + write + .send(tokio_tungstenite::tungstenite::Message::Text(reply)) + .await + .unwrap(); + } } } });