From 503cb23015ddb81993263f13fe0e38c154b9d0a3 Mon Sep 17 00:00:00 2001
From: htom <hatvanitamas09@gmail.com>
Date: Tue, 11 Nov 2025 15:25:42 +0100
Subject: [PATCH] accepted connection and sending data both ways

---
 server/src/main.rs | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

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::<Message>(txt) {}
+                    if let Ok(json) = serde_json::from_str::<Message>(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();
+                    }
                 }
             }
         });