fix(core/shell/command): retry sending events when it fails, closes #…

…7684

.changes/shell-command-lost-events.md

@@ -0,0 +1,5 @@
+---
+"tauri": "patch:bug"
+---
+
+Fix the JS `Command` API from `shell` module, losing events for `stdout`.

core/tauri/Cargo.toml

@@ -51,7 +51,7 @@ normal = [ "reqwest", "nix" ]
 [dependencies]
 serde_json = { version = "1.0", features = [ "raw_value", "preserve_order" ] }
 serde = { version = "1.0", features = [ "derive" ] }
-tokio = { version = "1", features = [ "rt", "rt-multi-thread", "sync", "fs", "io-util" ] }
+tokio = { version = "1", features = ["time", "rt", "rt-multi-thread", "sync", "fs", "io-util" ] }
 futures-util = "0.3"
 uuid = { version = "1", features = [ "v4" ] }
 url = { version = "2.3" }

core/tauri/src/endpoints/shell.rs

@@ -91,6 +91,9 @@ impl Cmd {
     on_event_fn: CallbackFn,
     options: CommandOptions,
   ) -> super::Result<ChildId> {
+    use std::future::Future;
+    use std::pin::Pin;
+
     let mut command = if options.sidecar {
       #[cfg(not(shell_sidecar))]
       return Err(crate::Error::ApiNotAllowlisted("shell > sidecar".to_string()).into_anyhow());
@@ -170,7 +173,19 @@ impl Cmd {
           let js = crate::api::ipc::format_callback(on_event_fn, &event)
             .expect("unable to serialize CommandEvent");
 
-          let _ = context.window.eval(js.as_str());
+          fn eval<'a, R: Runtime>(
+            window: &'a crate::Window<R>,
+            js: &'a str,
+          ) -> Pin<Box<dyn Future<Output = ()> + Send + 'a>> {
+            Box::pin(async move {
+              if window.eval(js).is_err() {
+                tokio::time::sleep(std::time::Duration::from_millis(15)).await;
+                eval(window, js).await;
+              }
+            })
+          }
+
+          eval(&context.window, js.as_str()).await;
         }
       });