Function stop_job

api/src/main.rs:372–414

(job_id: web::Path<String>, job_store: web::Data<JobStore>)

}

async fn stop_job(job_id: web::Path<String>, job_store: web::Data<JobStore>) -> impl Responder {
    let mut store = job_store.lock().await;
    let response = match store.get_mut(job_id.as_str()) {
        Some(status) => {
            if status.video_url.is_none() && status.error.is_none() {
                status.error = Some("Job stopped by user".to_string());

                log_message(
                    log::Level::Info,
                    &format!("Job {} stopped by user", job_id),
                    Some(job_id.as_str()),
                );
                serde_json::json!({
                    "message": "Job stopped successfully and temporary files cleaned up",
                    "status": "stopped"
                })
            } else {
                log_message(
                    log::Level::Info,
                    &format!("Cannot stop job {}: already completed or errored", job_id),
                    Some(job_id.as_str()),
                );
                serde_json::json!({
                    "error": "Cannot stop job: already completed or errored",
                    "status": "unchanged"
                })
            }
        }
        None => {
            log_message(
                log::Level::Info,
                &format!("Job not found: {}", job_id),
                Some(job_id.as_str()),
            );
            serde_json::json!({
                "error": "Job not found",
                "status": "not_found"
            })
        }
    };

    HttpResponse::Ok().json(response)
}

async fn get_job_status(
    job_id: web::Path<String>,