feat(all): integrated game RPC support!

src-tauri/Cargo.toml

@@ -34,6 +34,9 @@ urlencoding = "2.1.3"
 # launch on startup
 auto-launch = "0.5.0"
 
+# rpc server
+rsrpc = { git = "https://www.github.com/SpikeHD/rsRPC" }
+
 [target."cfg(any(target_os = \"linux\", target_os = \"dragonfly\", target_os = \"freebsd\", target_os = \"openbsd\", target_os = \"netbsd\"))".dependencies]
 webkit2gtk = "0.18.2"
 

src-tauri/src/config.rs

@@ -138,7 +138,7 @@ pub fn get_streamer_mode_detection() -> bool {
   parsed.streamer_mode_detection.unwrap_or(false)
 }
 
-pub fn _get_rpc_server() -> bool {
+pub fn get_rpc_server() -> bool {
   let parsed: Config =
     serde_json::from_str(read_config_file().as_str()).unwrap_or_else(|_| default_config());
   parsed.rpc_server.unwrap_or(false)

src-tauri/src/functionality/mod.rs

@@ -1 +1,2 @@
 pub mod streamer_mode;
+pub mod rpc;

src-tauri/src/functionality/rpc.rs

@@ -0,0 +1,12 @@
+use rsrpc::RPCServer;
+
+pub fn start_rpc_server() {
+  let detectable = reqwest::blocking::get("https://raw.githubusercontent.com/OpenAsar/arrpc/main/src/process/detectable.json").unwrap().text().unwrap();
+
+  // This accepts both a `&str` or a `String`
+  let mut server = RPCServer::from_json_str(detectable);
+
+  server.process_scan_ms = Some(100);
+
+  server.start();
+}

src-tauri/src/main.rs

@@ -122,9 +122,18 @@ fn main() {
 
   // Safemode check
   let safemode = std::env::args().any(|arg| arg == "--safemode");
-
   println!("Safemode enabled: {}", safemode);
 
+  // Begin the RPC server
+  let rpc_thread = std::thread::spawn(|| {
+    if !config::get_rpc_server() {
+      return;
+    }
+
+    println!("Starting RPC server...");
+    functionality::rpc::start_rpc_server();
+  });
+
   // Begin the proxy server
   let proxy_thread = std::thread::spawn(|| block_on(proxy_server::start_server(8678)));
 
@@ -238,7 +247,8 @@ fn main() {
     .run(context)
     .expect("error while running tauri application");
 
-  // Join the proxy thread
+  // Join threads
+  rpc_thread.join().unwrap();
   proxy_thread.join().unwrap();
 }