feat:develop multi manager

Author: limuy2022

gdrust/Cargo.lock

@@ -9,6 +9,8 @@ godot = { git = "https://github.com/godot-rust/gdext", branch = "master" }
 rand = "0.8"
 derive = { path = "./derive" }
 proto = { path = "proto" }
+tokio = "1"
+anyhow = "1"
 
 [lib]
 crate-type = ["cdylib"]

gdrust/Cargo.toml

@@ -18,4 +18,16 @@ struct GlobalClass {
 impl INode for GlobalClass {}
 
 #[godot_api()]
-impl GlobalClass {}
+impl GlobalClass {
+    #[func]
+    fn flush_multi(&mut self) {
+        match &mut self.multi_manager {
+            Some(manager) => {
+                manager;
+            }
+            None => {
+                godot_error!("MultiManager has not been initial")
+            }
+        }
+    }
+}

gdrust/src/global.rs

@@ -11,10 +11,20 @@ mod weapons;
 mod zenith;
 
 use godot::prelude::*;
-use std::panic::{set_hook, PanicInfo};
+use multi::{MultiManager, MultiManagerImpl};
+use std::{
+    panic::{set_hook, PanicInfo},
+    sync::{Arc, Mutex, OnceLock},
+};
 
 struct GdExtension;
 
+type MultiSingle = Arc<Mutex<MultiManagerImpl>>;
+fn get_multi_single() -> &'static MultiSingle {
+    static TMP: OnceLock<MultiSingle> = OnceLock::new();
+    TMP.get_or_init(|| Arc::new(Mutex::new(MultiManagerImpl::new())))
+}
+
 fn panic_handler(info: &PanicInfo) {
     if let Some(p) = info.location() {
         godot_error!(

gdrust/src/lib.rs

@@ -1,15 +1,63 @@
+use anyhow::Ok;
 use godot::engine::{INode, Node};
 use godot::prelude::*;
+use std::collections::HashMap;
+use std::sync::{Arc, Mutex};
+use tokio::net::TcpStream;
+use tokio::runtime::{Builder, Runtime};
+
+use crate::get_multi_single;
+
+pub struct MultiPlayer {}
+
+pub struct MultiManagerImpl {
+    clients: HashMap<usize, MultiPlayer>,
+    socket: Option<TcpStream>,
+    runtime: Runtime,
+}
+
+impl MultiManagerImpl {
+    fn set_connection(&mut self, socket: TcpStream) {
+        if self.socket.is_some() {
+            godot_warn!("Socket has value,but reset")
+        }
+        self.socket = Some(socket)
+    }
+
+    pub fn connect_to_server(&mut self, ip: &str) -> anyhow::Result<()> {
+        Ok(())
+    }
+}
+
+impl MultiManagerImpl {
+    pub fn new() -> Self {
+        Self {
+            clients: HashMap::new(),
+            socket: None,
+            runtime: Builder::new_multi_thread().enable_all().build().unwrap(),
+        }
+    }
+}
 
 #[derive(GodotClass)]
 #[class(base = Node)]
 pub struct MultiManager {
     base: Base<Node>,
+    multi_impl: Arc<Mutex<MultiManagerImpl>>,
 }
 
 #[godot_api()]
 impl INode for MultiManager {
     fn init(base: Base<Node>) -> Self {
-        Self { base }
+        Self {
+            base,
+            multi_impl: get_multi_single().clone(),
+        }
     }
 }
+
+#[godot_api()]
+impl MultiManager {
+    #[func]
+    fn add_new_player(&mut self) {}
+}

gdrust/src/multi.rs

@@ -29,14 +29,14 @@ impl MultiEnter {
     #[func]
     fn connect_to_server(&mut self, ip: String) -> bool {
         let global = self.base().get_node_as::<Node>("/root/Global");
-        let ret;
-        (self.socket, ret) = match TcpStream::connect(&ip) {
-            Ok(socket) => (Some(socket), true),
-            Err(error) => {
-                self.show_dialog(format!("Connect failed:{}", error));
-                (None, false)
-            }
-        };
+        let ret = true;
+        // (self.socket, ret) = match TcpStream::connect(&ip) {
+        //     Ok(socket) => (Some(socket), true),
+        //     Err(error) => {
+        //         self.show_dialog(format!("Connect failed:{}", error));
+        //         (None, false)
+        //     }
+        // };
         ret
     }
 

gdrust/src/ui/multi_enter.rs

@@ -15,12 +15,10 @@ func _on_pressed() -> void:
 	Global.connected_ip = $"../Input/IPBox/IP".text
 	Global.player_name = $"../Input/PlayerBox/Player".text
 	if Global.connected_ip.is_empty():
-		$WrongDialog.dialog_text = "Ip address is empty"
-		$WrongDialog.popup_centered()
+		self.show_dialog("Ip address is empty")
 		return
 	if Global.player_name.is_empty():
-		$WrongDialog.dialog_text = "Player name is empty"
-		$WrongDialog.popup_centered()
+		self.show_dialog("Player name is empty")
 		return
 	var state = self.connect_to_server(Global.connected_ip)
 	if state: