fix: callbacks are fnmut

examples/commands.rs

@@ -11,28 +11,37 @@ fn main() -> Result<(), CrowserError> {
   let mut window = Window::new(config, None, profile_dir)?;
   let ipc = window.ipc();
 
+  let ipc_thread = std::thread::spawn(move || setup_commands(&ipc));
+
   window.clear_profile().unwrap_or_default();
 
   std::thread::spawn(move || {
-    ipc.block_until_initialized().unwrap_or_default();
-
-    ipc
-      .register_command("hello", |_| {
-        println!("Got hello command");
-        Ok(serde_json::json!("Hello from Crowser!"))
-      })
-      .unwrap_or_default();
-
-    std::thread::sleep(std::time::Duration::from_secs(1));
-
-    // Eval some JS that calls that command
-    let result = ipc
-      .eval("window.__CROWSER.ipc.invoke('hello')")
-      .unwrap_or_default();
-    println!("Result: {:?}", result);
+
   });
 
   window.create()?;
 
+  ipc_thread.join().expect("Failed to join IPC thread").expect("IPC thread panicked");
+
   Ok(())
 }
+
+fn setup_commands(ipc: &crowser::WindowIpc) -> Result<(), CrowserError> {
+  ipc.block_until_initialized()?;
+
+  ipc
+    .register_command("hello", |_| {
+      println!("Got hello command");
+      Ok(serde_json::json!("Hello from Crowser!"))
+    })?;
+
+  std::thread::sleep(std::time::Duration::from_secs(1));
+
+  println!("Waiting for result...");
+  // Eval some JS that calls that command
+  let result = ipc
+    .eval("window.__CROWSER.ipc.invoke('hello')")?;
+  println!("Result: {:?}", result);
+
+  Ok(())
+}

src/cdp/mod.rs

@@ -167,7 +167,7 @@ impl Cdp {
       let timeout = timeout.unwrap_or(std::time::Duration::from_secs(1));
       let now = std::time::Instant::now();
 
-      // Wait for a response in the manager using try_lock and the timeout
+      // Wait for a response
       loop {
         // Wait an amount of time, to prevent a tight loop
         std::thread::sleep(std::time::Duration::from_millis(1));

src/ipc.rs

@@ -17,7 +17,7 @@ use crate::{
 };
 
 type IpcRegistrationMap =
-  Arc<Mutex<HashMap<String, Vec<Box<dyn Fn(Value) -> Result<Value, CrowserError> + Send + Sync>>>>>;
+  Arc<Mutex<HashMap<String, Vec<Box<dyn FnMut(Value) -> Result<Value, CrowserError> + Send + Sync + 'static>>>>>;
 
 #[derive(Clone)]
 pub struct BrowserIpc {
@@ -324,7 +324,9 @@ impl BrowserIpc {
     };
 
     let cmd = CDPCommand::new("Runtime.evaluate", params, Some(self.session_id.clone()));
+    println!("Before send: {:?}", cmd);
     let result = cdp.send(cmd, None)?;
+    println!("After send: {:?}", result["result"]["result"]);
     let res_type = result["result"]["result"]["type"]
       .as_str()
       .unwrap_or_default();
@@ -345,7 +347,7 @@ impl BrowserIpc {
   pub fn register_command(
     &mut self,
     name: impl AsRef<str>,
-    callback: fn(Value) -> Result<Value, CrowserError>,
+    callback: impl FnMut(Value) -> Result<Value, CrowserError> + Send + Sync + 'static,
   ) -> Result<(), CrowserError> {
     let mut commands = self.commands.lock().unwrap();
 
@@ -363,7 +365,7 @@ impl BrowserIpc {
   pub fn listen(
     &mut self,
     name: impl AsRef<str>,
-    callback: Box<dyn Fn(Value) -> Result<Value, CrowserError> + Send + Sync>,
+    callback: Box<dyn FnMut(Value) -> Result<Value, CrowserError> + Send + Sync + 'static>,
   ) -> Result<(), CrowserError> {
     let mut listeners = self.listeners.lock().unwrap();
 

src/lib.rs

@@ -256,7 +256,7 @@ impl WindowIpc {
   pub fn register_command(
     &self,
     name: impl AsRef<str>,
-    callback: fn(Value) -> Result<Value, CrowserError>,
+    callback: impl FnMut(Value) -> Result<Value, CrowserError> + Send + Sync + 'static,
   ) -> Result<(), CrowserError> {
     let mut ipc = self.inner.lock().unwrap();