From 281f496c832cba074e72622c3b59608373407822 Mon Sep 17 00:00:00 2001 From: htom Date: Wed, 12 Nov 2025 15:14:07 +0100 Subject: [PATCH] removed these files, ready to start working on event system messages --- server/src/broadcast_message.rs | 19 ------------------ server/src/handle_connection.rs | 34 --------------------------------- server/src/server_event.rs | 20 ------------------- 3 files changed, 73 deletions(-) delete mode 100644 server/src/broadcast_message.rs delete mode 100644 server/src/handle_connection.rs delete mode 100644 server/src/server_event.rs diff --git a/server/src/broadcast_message.rs b/server/src/broadcast_message.rs deleted file mode 100644 index 0248aab..0000000 --- a/server/src/broadcast_message.rs +++ /dev/null @@ -1,19 +0,0 @@ -use crate::ConnectionMap; -use futures_util::SinkExt; -use tokio_tungstenite::tungstenite::Message as WsMessage; - -pub async fn broadcast_message(connections: &ConnectionMap, msg: &WsMessage) { - let mut dead = vec![]; - let mut map = connections.lock().await; - - for (id, tx) in map.iter_mut() { - if let Err(e) = tx.send(msg.clone()).await { - eprintln!("Failed to send to {id}: {e}"); - dead.push(*id); - } - } - - for id in dead { - map.remove(&id); - } -} diff --git a/server/src/handle_connection.rs b/server/src/handle_connection.rs deleted file mode 100644 index af7849b..0000000 --- a/server/src/handle_connection.rs +++ /dev/null @@ -1,34 +0,0 @@ -use crate::ConnectionMap; -use futures_util::StreamExt; -use tokio_tungstenite::accept_async; -use uuid::Uuid; - -use super::broadcast_message::broadcast_message; - -pub async fn handle_connection(stream: tokio::net::TcpStream, connections: ConnectionMap) { - let ws_stream = accept_async(stream).await.unwrap(); - let (write, mut read) = ws_stream.split(); - - let id = Uuid::new_v4(); - - { - let mut map = connections.lock().await; - map.insert(id, write); - } - - println!("New connection: {id}"); - - while let Some(Ok(msg)) = read.next().await { - if msg.is_text() { - println!("Recieved from {id}: {}", msg); - broadcast_message(&connections, &msg).await; - } - } - - { - let mut map = connections.lock().await; - map.remove(&id); - } - - println!("Connection removed: {id}"); -} diff --git a/server/src/server_event.rs b/server/src/server_event.rs deleted file mode 100644 index a763837..0000000 --- a/server/src/server_event.rs +++ /dev/null @@ -1,20 +0,0 @@ -use uuid::Uuid; - -struct Step { - from: String, - to: String, -} - -enum ServerEvent { - PlayerJoined(Uuid), //tarolja el a kapcsolatot - PlayerLeft(Uuid), //torolje a jatekos a listabol mert kilepett - PlayerJoinedQeue(Uuid), //online jatekra var - PlayerJoinedMatch(Uuid), //player joined a match - PlayerRequestAvailableSteps(Uuid, String), //string board - PlayerSteps(Uuid, Step), //player moves piece - CheckWinner(Uuid, String), //player asks server if they won - PlayerIsInCheck(Uuid, String), //board state - PlayerOpponentUpdateUI(Uuid, String), //board state - PlayerLost(Uuid), - PlayerReturnToMenu(Uuid), -}