Function process_gource

api/src/main.rs:189–370

(
    repo_url: String,
    access_token: Option<String>,
    settings: Option<GourceSettings>,
    job_id: String,
    job_store: web::Data<JobStore>,
)

}

async fn process_gource(
    repo_url: String,
    access_token: Option<String>,
    settings: Option<GourceSettings>,
    job_id: String,
    job_store: web::Data<JobStore>,
) -> Result<(), GourceError> {
    let job_id_clone = job_id.clone();
    log_message(
        log::Level::Info,
        "Starting process_gource",
        Some(&job_id_clone),
    );
    let start_time = Instant::now();

    update_job_status(&job_store, &job_id, ProgressStep::InitializingProject).await;
    log_message(
        log::Level::Info,
        "Updated job status to InitializingProject",
        Some(&job_id_clone),
    );

    let url = Url::parse(&repo_url).map_err(|_| GourceError::InvalidUrl)?;
    let host = url.host_str().unwrap_or("");
    if !host.ends_with("github.com") {
        if access_token.is_some() {
            return Err(GourceError::UnsupportedRepository);
        }
    }
    log_message(
        log::Level::Info,
        &format!("Validated repository URL: {}", repo_url),
        Some(&job_id_clone),
    );

    let temp_dir = tempfile::TempDir::new().map_err(|_| GourceError::TempDirCreationFailed)?;
    log_message(
        log::Level::Info,
        "Created temporary directory",
        Some(&job_id_clone),
    );

    let clone_start = Instant::now();
    log_message(
        log::Level::Info,
        "Attempting to decrypt token",
        Some(&job_id_clone),
    );
    let decrypted_token = if let Some(encrypted_token) = access_token {
        log_message(
            log::Level::Info,
            "Access token provided, attempting decryption",
            Some(&job_id_clone),
        );
        let secret_key = dotenv::var("SECRET_KEY")
            .or_else(|_| std::env::var("SECRET_KEY"))
            .expect("SECRET_KEY must be set in .env file or environment");
        log_message(