feat: Try async recursion

Cargo.toml

@@ -6,6 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+async-recursion = "1.1.1"
 clap = "4.5.4"
 dunce = "1.0.4"
 rpassword = "7.3.1"

src/handler/mod.rs

@@ -8,7 +8,7 @@
  */
 use crate::server;
 
-pub fn handle(connection: &mut server::Connection, json: &str) {
+pub async fn handle(connection: &mut server::Connection, json: &str) {
     let v = serde_json::from_str(json);
     let val: serde_json::Value = v.unwrap();
 
@@ -19,7 +19,7 @@ pub fn handle(connection: &mut server::Connection, json: &str) {
 
     match method {
         "enter" => {
-            enter::handle(connection, &val);
+            enter::handle(connection, &val).await;
         }
         "exit" => {
             // TODO: ..
@@ -34,10 +34,11 @@ pub fn handle(connection: &mut server::Connection, json: &str) {
 mod enter {
     use crate::server;
 
-    pub fn handle(connection: &mut server::Connection, json: &serde_json::Value) {
+    pub async fn handle(connection: &mut server::Connection, json: &serde_json::Value) {
         tracing::trace!("method: {:?}", json["method"]);
         connection.send(serde_json::json!({
-            "": "",
-        }));
+            "jsonrpc": "2.0",
+            "method": "enter",
+        })).await;
     }
 }

src/server.rs

@@ -12,6 +12,8 @@ use serde_json::json;
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
 use tokio::net::TcpListener;
 
+use async_recursion::async_recursion;
+
 const SEPARATOR_LEN: usize = "\r\n".len();
 const BUF_SIZE: usize = 1024 * 1;
 
@@ -69,7 +71,7 @@ impl Connection {
                     self.data.append(&mut new_data.to_vec());
                 }
 
-                self.process();
+                self.process().await;
 
                 n
             }
@@ -80,7 +82,8 @@ impl Connection {
         };
     }
 
-    pub fn process(&mut self) {
+    #[async_recursion]
+    pub async fn process(&mut self) {
         let data = &self.data.clone();
         let decrypted = String::from_utf8_lossy(data);
 
@@ -112,7 +115,7 @@ impl Connection {
                         boundary += content_len;
 
                         let data = &line[..content_len];
-                        handler::handle(self, data);
+                        handler::handle(self, data).await;
                         //println!("{}: {}", "receive all", data);
 
                         process = true;
@@ -133,7 +136,7 @@ impl Connection {
                 boundary,
                 String::from_utf8_lossy(&self.data)
             );
-            self.process();
+            self.process().await;
         }
     }