Status

src/engine/engine/mod.rs

@@ -79,6 +79,8 @@ impl Engine {
 
             self.status.lock().await.strategy_state = ItemState::Starting;
 
+            self.update_status().await?;
+
             self.strategy_engine.run().await?;
 
             self.terminal_server
@@ -92,4 +94,12 @@ impl Engine {
             strategy: self.strategy_engine.strategy.lock().await.manifest.clone(),
         }
     }
+
+    pub async fn update_status(&self) -> tokio::io::Result<()> {
+        self.terminal_server
+            .broadcast(TerminalServerMessage::StatusUpdated(
+                self.status.lock().await.clone(),
+            ))
+            .await
+    }
 }

src/engine/engine/strategy.rs

@@ -99,6 +99,7 @@ impl StrategyEngine {
             .await?;
 
         engine.status.lock().await.strategy_state = ItemState::Running;
+        engine.update_status().await?;
 
         loop {
             match StrategyChild::read(&mut stdout).await? {

src/engine/engine/terminal.rs

@@ -75,6 +75,12 @@ impl TerminalServer {
         )
         .await?;
 
+        self.send_to(
+            id,
+            TerminalServerMessage::StatusUpdated(engine.status.lock().await.clone()),
+        )
+        .await?;
+
         self.send_to(
             id,
             pulse_sdk::terminal::TerminalServerMessage::SetLogs(self.logs.lock().await.clone()),