Update supervisor tasks page when supervisor spawns a new task

1 files changed, 21 insertions, 1 deletions

diff --git a/makima/src/server/handlers/mesh_supervisor.rs b/makima/src/server/handlers/mesh_supervisor.rs
index 1b5e376..1b476ef 100644
--- a/makima/src/server/handlers/mesh_supervisor.rs
+++ b/makima/src/server/handlers/mesh_supervisor.rs
@@ -19,7 +19,7 @@ use crate::db::repository;
 use crate::server::auth::Authenticated;
 use crate::server::handlers::mesh::{extract_auth, AuthSource};
 use crate::server::messages::ApiError;
-use crate::server::state::{DaemonCommand, SharedState, TaskOutputNotification};
+use crate::server::state::{DaemonCommand, SharedState, TaskOutputNotification, TaskUpdateNotification};
 
 // =============================================================================
 // Request/Response Types
@@ -650,6 +650,16 @@ pub async fn spawn_task(
         }),
     ).await;
 
+    // Broadcast task creation notification to WebSocket subscribers
+    state.broadcast_task_update(TaskUpdateNotification {
+        task_id: task.id,
+        owner_id: Some(owner_id),
+        version: task.version,
+        status: task.status.clone(),
+        updated_fields: vec!["created".to_string()],
+        updated_by: "supervisor".to_string(),
+    });
+
     // Start task on a daemon
     // Find a daemon that belongs to this owner
     let mut updated_task = task;
@@ -714,6 +724,16 @@ pub async fn spawn_task(
                 let _ = repository::update_task_for_owner(pool, updated_task.id, owner_id, rollback_req).await;
             } else {
                 tracing::info!(task_id = %updated_task.id, daemon_id = %daemon.id, repo_url = ?repo_url, "Task spawn command sent");
+
+                // Broadcast task status update notification to WebSocket subscribers
+                state.broadcast_task_update(TaskUpdateNotification {
+                    task_id: updated_task.id,
+                    owner_id: Some(owner_id),
+                    version: updated_task.version,
+                    status: "starting".to_string(),
+                    updated_fields: vec!["status".to_string(), "daemon_id".to_string()],
+                    updated_by: "supervisor".to_string(),
+                });
             }
             break;
         }