Function cancel_task_internal

depot/dispatch/src/main.rs:1322–1370

(
    state: &AppState,
    task_id: Uuid,
)

}

async fn cancel_task_internal(
    state: &AppState,
    task_id: Uuid,
) -> Result<impl IntoResponse, (StatusCode, String)> {
    let task: Task = sqlx::query_as(
        r#"
        UPDATE tasks 
        SET status = 'cancelled', ended_at = now()
        WHERE id = $1 AND status IN ('pending', 'assigned', 'active')
        RETURNING id, mission_id, rover_id, status, progress, waypoint, lap, error, created_at, started_at, ended_at
        "#,
    )
    .bind(task_id)
    .fetch_optional(&state.db)
    .await
    .map_err(|e| (StatusCode::INTERNAL_SERVER_ERROR, e.to_string()))?
    .ok_or((
        StatusCode::NOT_FOUND,
        "Task not found or already completed".to_string(),
    ))?;

    let rover_id = task.rover_id.clone();

    info!(task_id = %task_id, rover_id = %rover_id, "Task cancelled");

    // Clear rover's current task
    {
        let mut rovers = state.rovers.write().await;
        if let Some(rover) = rovers.get_mut(&rover_id) {
            rover.current_task = None;
        }
    }

    // Send cancel to rover
    state
        .send_to_rover(&rover_id, DispatchToRover::Cancel { task_id })
        .await;

    // Broadcast update
    state.broadcast(BroadcastMessage::TaskUpdate { task: task.clone() });
    state.broadcast(BroadcastMessage::RoverUpdate {
        rover_id,
        connected: true,
        task_id: None,
        trace_id: None,
    });

    Ok(Json(task))
}

// =============================================================================
// Voice Command API