Merge pull request #199 from Far-Beyond-Dev/feature/dynamic-socket-ch…

…annels

Perf: Implement Dynamic Channel-Based Socket Streaming for Infinite Worlds

server/src/server/in_world/mod.rs

@@ -0,0 +1,30 @@
+use socketioxide::extract::{ SocketRef, Data };
+use serde::Serialize;
+use serde_json::Value;
+use std::collections::HashMap;
+use uuid::Uuid;
+
+
+pub struct Object {
+    uuid: Uuid,
+    name: String,
+    replicated: bool,
+}
+
+impl Object {
+    pub fn new(name: String, replicated: bool) -> Self {
+        Self {
+            uuid: Uuid::new_v4(),
+            name, // Fetch name from method params
+            replicated, // Fetch replicated from method params
+        }
+    }
+
+    pub fn get_uuid(&self) -> Uuid {
+        self.uuid
+    }
+    pub fn send_event(&self, instigator: SocketRef, event_name: String, event_data: Value) {
+        let _ = socketioxide::socket::Socket::within(&instigator, self.uuid.to_string()).emit(event_name, &event_data);
+    }
+}
+

server/src/server/mod.rs

@@ -31,7 +31,8 @@ use std::sync::Arc;
 use tokio::sync::Mutex;
 use uuid::Uuid;
 pub mod config;
-mod event_rep;
+pub mod in_world;
+
 use lazy_static::lazy_static;
 
 lazy_static! {
@@ -187,6 +188,16 @@ fn on_connect(socket: SocketRef, Data(data): Data<serde_json::Value>) {
 
     let player_arc: Arc<horizon_data_types::Player> = Arc::new(player);
 
+    // TODO: move this to example backend
+    let player_char = in_world::Object::new("Player Character".to_string(), true);
+    println!("Player joined: {:?}", player_char.get_uuid().to_string());
+
+    let player_json_value: serde_json::Value = serde_json::json!({ "joined": true });
+    player_char.send_event(socket, "playerjoined".to_string(), player_json_value);
+    println!("Sent player joined event Successfully");
+
+
+    // let casted_struct = plugin_api::get_plugin!(unreal_adapter_horizon, target_thread.plugins);
     //let casted_struct = plugin_api::get_plugin!(unreal_adapter_horizon, target_thread.plugins);
 
     //casted_struct.player_joined(socket, player_arc);