wip

src/handler/mod.rs

@@ -6,8 +6,9 @@
  * $Notice: See LICENSE.txt for modification and distribution information
  *                   Copyright © 2024 by Shen, Jen-Chieh $
  */
+use crate::server;
 
-pub fn handle(json: &str) {
+pub fn handle(connection: &mut server::Connection, json: &str) {
     let v = serde_json::from_str(json);
     let val: serde_json::Value = v.unwrap();
 
@@ -18,25 +19,25 @@ pub fn handle(json: &str) {
 
     match method {
         "enter" => {
-            enter::handle(&val);
+            enter::handle(connection, &val);
         }
-        "login" => {
-            login::handle(&val);
+        "exit" => {
+            // TODO: ..
         }
         _ => {
             tracing::error!("Unkown method request: {:?}", method);
         }
     }
 }
 
+/// Enter session
 mod enter {
-    pub fn handle(json: &serde_json::Value) {
-        tracing::trace!("method: {:?}", json["method"]);
-    }
-}
+    use crate::server;
 
-mod login {
-    pub fn handle(json: &serde_json::Value) {
+    pub fn handle(connection: &mut server::Connection, json: &serde_json::Value) {
         tracing::trace!("method: {:?}", json["method"]);
+        connection.send(serde_json::json!({
+            "": "",
+        }));
     }
 }

src/server.rs

@@ -25,7 +25,7 @@ fn get_content_len(line: &str) -> usize {
     len_str.parse::<usize>().unwrap()
 }
 
-struct Connection {
+pub struct Connection {
     pub stream: tokio::net::TcpStream,
     pub addr: std::net::SocketAddr,
     read_buf: [u8; BUF_SIZE],
@@ -111,7 +111,7 @@ impl Connection {
                         boundary += content_len;
 
                         let data = &line[..content_len];
-                        handler::handle(data);
+                        handler::handle(&mut self, data);
                         //println!("{}: {}", "receive all", data);
 
                         process = true;