Function start_gource

api/src/main.rs:131–187

(
    repo_request: web::Json<GourceRequest>,
    job_store: web::Data<JobStore>,
)

}

async fn start_gource(
    repo_request: web::Json<GourceRequest>,
    job_store: web::Data<JobStore>,
) -> impl Responder {
    let job_id = Uuid::new_v4().to_string();
    log_message(
        log::Level::Info,
        &format!("Starting new job with ID: {}", job_id),
        None,
    );

    let repo_url = repo_request.repo_url.clone();
    let access_token = repo_request.access_token.clone();
    let settings = repo_request.settings.clone().unwrap_or_default();

    {
        let mut store = job_store.lock().await;
        store.insert(
            job_id.clone(),
            JobStatus {
                step: ProgressStep::InitializingProject,
                video_url: None,
                repo_url: repo_url.clone(),
                error: None,
                settings: settings.clone(),
            },
        );
    }

    let job_store_clone = job_store.clone();
    let job_id_clone = job_id.clone();

    tokio::spawn(async move {
        if let Err(e) = process_gource(
            repo_url,
            access_token,
            Some(settings),
            job_id_clone.clone(),
            job_store_clone.clone(),
        )
        .await
        {
            log_message(
                log::Level::Error,
                &format!("Job failed: {}", e),
                Some(&job_id_clone),
            );
            let mut store = job_store_clone.lock().await;
            if let Some(status) = store.get_mut(&job_id_clone) {
                status.step = ProgressStep::GeneratingVisualization;
                status.error = Some(e.to_string());
            }
        }
    });

    HttpResponse::Ok().json(GourceResponse { job_id })
}