rollback

Author: rog1gor

Client/Cargo.lock

@@ -1,5 +1,5 @@
 [package]
-name = "Client"
+name = "client"
 version = "0.1.0"
 edition = "2021"
 

Client/Cargo.toml

@@ -0,0 +1,6 @@
+use serde::{Serialize, Deserialize};
+
+#[derive(Debug, Serialize, Deserialize)]
+pub enum Action {
+    Handshake,
+}

Client/src/libs/action.rs

@@ -0,0 +1,68 @@
+use std::net::{TcpListener, TcpStream};
+use std::io::{self, prelude::*, BufReader, Read, Write};
+use serde::{Serialize, Deserialize};
+
+use crate::action::Action;
+
+pub struct Client {
+    tcp_listener: TcpListener,
+    running: std::sync::atomic::AtomicBool,
+}
+
+impl Default for Client {
+    fn default() -> Self {
+        let tcp_listener = TcpListener::bind("127.0.0.1:8888").unwrap();
+        Server {
+            tcp_listener,
+            running: AtomicBool::new(true),
+        }
+    }
+}
+
+impl Server {
+    pub fn new(port: u16) -> Self {
+        let tcp_listener = TcpListener::bind(format!("127.0.0.1:{}", port)).unwrap();
+        Server {
+            tcp_listener,
+            running: AtomicBool::new(true),
+        }
+    }
+
+    pub fn start(&self) {
+        for stream in listener.incoming() {
+            let stream = stream.unwrap();
+            handle_action(stream);
+        }
+    }
+
+    pub fn handle_action(mut stream: TcpStream) -> io::Result<()> {
+        let buf_reader = BufReader::new(&mut stream);
+        let mut buffer = Vec::new();
+
+        buf_reader.read_to_end($mut buffer)?;
+
+        let action: Action = serde_json::from_slice(&buffer)?;
+        println!("Action from another client: {:?}", action);
+
+        Ok(())
+    }
+
+    pub fn send_action(mut streamL TcpStream) -> io::Result<()> {
+        let action = Action::Handshake;
+        let serialized_action = serde_json::to_vec(&action)?;
+        stream.write_all(&serialized_action)?;
+    }
+
+    pub fn stop(&self) {
+        // We set the flag and make a new connection to make sure that the server checks the flag
+        self.running
+            .store(false, std::sync::atomic::Ordering::Relaxed);
+        TcpStream::connect(("127.0.0.1", self.port())).unwrap();
+
+        // TODO: close all streams using `shutdown`
+    }
+
+    pub fn port(&self) -> u16 {
+        self.tcp_listener.local_addr().unwrap().port()
+    }
+}

Client/src/libs/game-state renamed to Client/src/libs/game-state.rs

@@ -1,5 +1,5 @@
 [package]
-name = "Server"
+name = "server"
 version = "0.1.0"
 edition = "2021"