hf-hub 1.0.0

//! Repository file and snapshot download builders.
//!
//! Builders on [`HFRepository`] for fetching file contents:
//!
//! - [`HFRepository::download_file`] — download one file to the cache or a local directory.
//! - [`HFRepository::download_file_stream`] — stream a file (or byte range) without buffering.
//! - [`HFRepository::download_file_to_bytes`] — read a file (or byte range) into memory.
//! - [`HFRepository::snapshot_download`] — download all files at a revision, optionally filtered by allow/ignore globs
//!   matched against repo-relative paths.
//!
//! Range parameters use Rust `std::ops::Range<u64>` semantics (start-inclusive, end-exclusive).
//! See each builder's docs for the exact path / range / glob format rules.

#[cfg(not(target_family = "wasm"))]
use std::{
    io::Write,
    path::{Path, PathBuf},
};

use bon::bon;
#[cfg(not(target_family = "wasm"))]
use futures::TryStreamExt;
use futures::stream::{Stream, StreamExt};
#[cfg(not(target_family = "wasm"))]
use reqwest::header::IF_NONE_MATCH;
#[cfg(not(target_family = "wasm"))]
use serde::Deserialize;

use super::files::extract_file_size;
#[cfg(not(target_family = "wasm"))]
use super::{
    FileMetadataInfo,
    files::{extract_commit_hash, extract_etag, extract_xet_hash, matches_any_glob},
};
use super::{HFRepository, RepoTreeEntry, RepoType};
#[cfg(not(target_family = "wasm"))]
use crate::cache::storage as cache;
use crate::error::{HFError, HFResult};
use crate::progress::{DownloadEvent, EmitEvent, FileProgress, FileStatus, Progress};
use crate::{constants, retry};

/// Boxed byte stream returned by [`HFRepository::download_file_stream`].
///
/// `Send + Unpin` on native targets; on wasm the browser `reqwest` backend
/// produces `!Send` streams, so the `Send` bound is dropped.
#[cfg(not(target_family = "wasm"))]
pub type HFByteStream = Box<dyn Stream<Item = HFResult<bytes::Bytes>> + Send + Unpin>;
#[cfg(target_family = "wasm")]
pub type HFByteStream = Box<dyn Stream<Item = HFResult<bytes::Bytes>> + Unpin>;

/// Internal options struct used by the file download helpers.
#[cfg(not(target_family = "wasm"))]
struct DownloadFileParams {
    filename: String,
    local_dir: Option<PathBuf>,
    revision: Option<String>,
    force_download: bool,
    local_files_only: bool,
    progress: Option<Progress>,
}

/// Internal options struct used by the streaming download helpers.
struct DownloadFileStreamParams {
    filename: String,
    revision: Option<String>,
    range: Option<std::ops::Range<u64>>,
    progress: Option<Progress>,
}

/// Internal options struct used by `snapshot_download_impl`.
#[cfg(not(target_family = "wasm"))]
struct SnapshotDownloadParams {
    revision: Option<String>,
    allow_patterns: Option<Vec<String>>,
    ignore_patterns: Option<Vec<String>>,
    local_dir: Option<PathBuf>,
    force_download: bool,
    local_files_only: bool,
    max_workers: Option<usize>,
    progress: Option<Progress>,
}

impl<T: RepoType> HFRepository<T> {
    #[cfg(not(target_family = "wasm"))]
    async fn download_file_impl(&self, params: DownloadFileParams) -> HFResult<PathBuf> {
        let result = self.download_file_inner(&params).await;
        if result.is_ok() {
            params.progress.emit(DownloadEvent::Complete);
        }
        result
    }

    #[cfg(not(target_family = "wasm"))]
    async fn download_file_inner(&self, params: &DownloadFileParams) -> HFResult<PathBuf> {
        if params.local_dir.is_some() {
            self.download_file_to_local_dir(params).await
        } else {
            if !self.hf_client.cache_enabled() {
                return Err(HFError::CacheNotEnabled);
            }
            self.download_file_to_cache(params).await
        }
    }

    // Determine whether the file is xet-backed and learn its size.
    //
    // Native: HEAD the resolve URL and read `X-Xet-Hash` /
    // `Content-Length` / `X-Linked-Size` from the response headers.
    //
    // Wasm: the resolve URL 302-redirects to a CAS blob URL, and the Fetch
    // spec only surfaces the final response's headers when following
    // redirects (`redirect: 'manual'` doesn't help — it yields an opaque
    // response with no readable headers). So on wasm we dispatch via
    // `paths-info`, a non-redirecting JSON endpoint that returns the same
    // metadata in the body.
    #[cfg(not(target_family = "wasm"))]
    async fn resolve_xet_hash_and_size(
        &self,
        revision: &str,
        filename: &str,
    ) -> HFResult<(Option<String>, Option<u64>)> {
        let repo_path = self.repo_path();
        let url = self
            .hf_client
            .download_url(T::default().url_prefix(), &repo_path, revision, filename)?;
        let headers = self.hf_client.auth_headers();
        let head_response = retry::retry(self.hf_client.retry_config(), || {
            self.hf_client.http_client().head(&url).headers(headers.clone()).send()
        })
        .await?;
        let head_response = self
            .hf_client
            .check_response(
                head_response,
                Some(&repo_path),
                crate::error::NotFoundContext::Entry {
                    path: filename.to_string(),
                },
            )
            .await?;
        Ok((extract_xet_hash(&head_response), extract_file_size(&head_response)))
    }

    #[cfg(target_family = "wasm")]
    async fn resolve_xet_hash_and_size(
        &self,
        revision: &str,
        filename: &str,
    ) -> HFResult<(Option<String>, Option<u64>)> {
        let entries = self
            .get_paths_info()
            .paths(vec![filename.to_string()])
            .revision(revision.to_string())
            .send()
            .await?;
        let entry = entries
            .into_iter()
            .find(|e| matches!(e, RepoTreeEntry::File { path, .. } if path == filename));
        match entry {
            Some(RepoTreeEntry::File { xet_hash, size, .. }) => Ok((xet_hash, Some(size))),
            _ => Err(HFError::EntryNotFound {
                path: filename.to_string(),
                repo_id: self.repo_path(),
                context: None,
            }),
        }
    }

    async fn download_file_stream_impl(
        &self,
        params: DownloadFileStreamParams,
    ) -> HFResult<(Option<u64>, HFByteStream)> {
        if let Some(ref range) = params.range
            && range.start >= range.end
        {
            return Err(HFError::InvalidParameter(format!(
                "range start ({}) must be less than end ({})",
                range.start, range.end
            )));
        }

        let revision = params.revision.as_deref().unwrap_or(constants::DEFAULT_REVISION);
        let repo_path = self.repo_path();
        let url = self
            .hf_client
            .download_url(self.repo_type.url_prefix(), &repo_path, revision, &params.filename)?;

        let headers = self.hf_client.auth_headers();

        let (xet_hash, file_size_hint) = self.resolve_xet_hash_and_size(revision, &params.filename).await?;

        if let Some(xet_hash) = xet_hash {
            let file_size: u64 = file_size_hint.unwrap_or_else(|| {
                tracing::warn!(url = %url, "missing file size for xet file, defaulting to 0");
                0
            });

            let content_length = params.range.as_ref().map(|r| r.end.saturating_sub(r.start)).or(Some(file_size));

            let stream = self
                .xet_download_stream(revision, &xet_hash, file_size, params.range.clone())
                .await?;

            let total_bytes = content_length.unwrap_or(0);
            params.progress.emit(DownloadEvent::Start {
                total_files: 1,
                total_bytes,
            });
            let wrapped =
                wrap_stream_with_progress(Box::new(Box::pin(stream)), params.progress, params.filename, total_bytes);
            #[cfg(target_family = "wasm")]
            let wrapped = buffer_wasm_stream(wrapped);
            return Ok((content_length, wrapped));
        }

        let range_header = params
            .range
            .as_ref()
            .map(|r| format!("bytes={}-{}", r.start, r.end.saturating_sub(1)));
        let response = retry::retry(self.hf_client.retry_config(), || {
            let mut req = self.hf_client.http_client().get(&url).headers(headers.clone());
            if let Some(ref range) = range_header {
                req = req.header(reqwest::header::RANGE, range);
            }
            req.send()
        })
        .await?;
        let response = self
            .hf_client
            .check_response(
                response,
                Some(&repo_path),
                crate::error::NotFoundContext::Entry {
                    path: params.filename.clone(),
                },
            )
            .await?;

        let content_length = extract_file_size(&response);
        let total_bytes = content_length.unwrap_or(0);
        let stream = response.bytes_stream().map(|r| r.map_err(HFError::from));
        params.progress.emit(DownloadEvent::Start {
            total_files: 1,
            total_bytes,
        });
        let wrapped =
            wrap_stream_with_progress(Box::new(Box::pin(stream)), params.progress, params.filename, total_bytes);
        #[cfg(target_family = "wasm")]
        let wrapped = buffer_wasm_stream(wrapped);
        Ok((content_length, wrapped))
    }

    async fn download_file_to_bytes_impl(&self, params: DownloadFileStreamParams) -> HFResult<bytes::Bytes> {
        let (content_length, stream) = self.download_file_stream_impl(params).await?;
        futures::pin_mut!(stream);

        let capacity = content_length.unwrap_or(0) as usize;
        let mut buf = bytes::BytesMut::with_capacity(capacity);
        while let Some(chunk) = stream.next().await {
            buf.extend_from_slice(&chunk?);
        }
        Ok(buf.freeze())
    }

    #[cfg(not(target_family = "wasm"))]
    async fn download_file_to_local_dir(&self, params: &DownloadFileParams) -> HFResult<PathBuf> {
        let revision = params.revision.as_deref().unwrap_or(constants::DEFAULT_REVISION);
        let repo_path = self.repo_path();
        let url = self
            .hf_client
            .download_url(self.repo_type.url_prefix(), &repo_path, revision, &params.filename)?;

        let headers = self.hf_client.auth_headers();
        let head_response = retry::retry(self.hf_client.retry_config(), || {
            self.hf_client.http_client().head(&url).headers(headers.clone()).send()
        })
        .await?;

        let head_response = self
            .hf_client
            .check_response(
                head_response,
                Some(&repo_path),
                crate::error::NotFoundContext::Entry {
                    path: params.filename.clone(),
                },
            )
            .await?;

        let file_size = extract_file_size(&head_response).unwrap_or(0);
        let has_xet_hash = head_response.headers().get(constants::HEADER_X_XET_HASH).is_some();

        params.progress.emit(DownloadEvent::Start {
            total_files: 1,
            total_bytes: file_size,
        });

        if has_xet_hash {
            let local_dir = params.local_dir.as_ref().unwrap();
            return self
                .xet_download_to_local_dir(revision, &params.filename, local_dir, &head_response, &params.progress)
                .await;
        }

        let response = retry::retry(self.hf_client.retry_config(), || {
            self.hf_client.http_client().get(&url).headers(headers.clone()).send()
        })
        .await?;
        let response = self
            .hf_client
            .check_response(
                response,
                Some(&repo_path),
                crate::error::NotFoundContext::Entry {
                    path: params.filename.clone(),
                },
            )
            .await?;

        let local_dir = params.local_dir.as_ref().unwrap();
        std::fs::create_dir_all(local_dir)?;

        let dest_path = local_dir.join(&params.filename);
        if let Some(parent) = dest_path.parent() {
            std::fs::create_dir_all(parent)?;
        }

        stream_response_to_file_with_progress(
            response,
            &dest_path,
            &params.progress,
            Some(&params.filename),
            file_size,
        )
        .await?;
        params.progress.emit(DownloadEvent::Progress {
            files: vec![FileProgress {
                filename: params.filename.clone(),
                bytes_completed: file_size,
                total_bytes: file_size,
                status: FileStatus::Complete,
            }],
        });

        Ok(dest_path)
    }

    /// Resolve a file from the local cache without making network requests.
    /// Matches Python's `try_to_load_from_cache`: checks the snapshot pointer
    /// first, then consults `.no_exist` markers for negative cache hits.
    #[cfg(not(target_family = "wasm"))]
    fn resolve_from_cache_only(&self, repo_folder: &str, revision: &str, filename: &str) -> HFResult<PathBuf> {
        let cache_dir = self.hf_client.cache_dir();

        let commit_hash = if cache::is_commit_hash(revision) {
            Some(revision.to_string())
        } else {
            let ref_path = cache::ref_path(cache_dir, repo_folder, revision);
            std::fs::read_to_string(&ref_path).ok().map(|s| s.trim().to_string())
        };

        if let Some(ref hash) = commit_hash {
            let snap = cache::snapshot_path(cache_dir, repo_folder, hash, filename);
            if snap.exists() {
                return Ok(snap);
            }
            if cache::no_exist_path(cache_dir, repo_folder, hash, filename).exists() {
                return Err(HFError::EntryNotFound {
                    path: filename.to_string(),
                    repo_id: String::new(),
                    context: None,
                });
            }
        }

        Err(HFError::LocalEntryNotFound {
            path: filename.to_string(),
        })
    }

    /// Resolve the cached etag for a file by reading the symlink target in snapshots/.
    /// On Windows, where copies are used instead of symlinks, `read_link` will fail
    /// and this returns `None`, disabling conditional-request (If-None-Match) optimization.
    #[cfg(not(target_family = "wasm"))]
    fn find_cached_etag(&self, repo_folder: &str, revision: &str, filename: &str) -> Option<String> {
        let cache_dir = self.hf_client.cache_dir();

        let commit_hash = if cache::is_commit_hash(revision) {
            Some(revision.to_string())
        } else {
            let ref_path = cache::ref_path(cache_dir, repo_folder, revision);
            std::fs::read_to_string(&ref_path).ok().map(|s| s.trim().to_string())
        };

        let hash = commit_hash?;
        let snap = cache::snapshot_path(cache_dir, repo_folder, &hash, filename);
        let target = std::fs::read_link(&snap).ok()?;
        target.file_name()?.to_str().map(|s| s.to_string())
    }

    #[cfg(not(target_family = "wasm"))]
    async fn download_file_to_cache(&self, params: &DownloadFileParams) -> HFResult<PathBuf> {
        let revision = params.revision.as_deref().unwrap_or(constants::DEFAULT_REVISION);
        let cache_dir = self.hf_client.cache_dir();
        let repo_folder = cache::repo_folder_name(&self.repo_path(), self.repo_type.plural());
        let force_download = params.force_download;

        if cache::is_commit_hash(revision) && !force_download {
            let snap = cache::snapshot_path(cache_dir, &repo_folder, revision, &params.filename);
            if snap.exists() {
                return Ok(snap);
            }
        }

        if params.local_files_only {
            return self.resolve_from_cache_only(&repo_folder, revision, &params.filename);
        }

        let result = self
            .download_file_to_cache_network(params, revision, cache_dir, &repo_folder, force_download)
            .await;

        match &result {
            Err(e) if e.is_transient() && !force_download => self
                .resolve_from_cache_only(&repo_folder, revision, &params.filename)
                .or(result),
            _ => result,
        }
    }

    #[cfg(not(target_family = "wasm"))]
    async fn download_file_to_cache_network(
        &self,
        params: &DownloadFileParams,
        revision: &str,
        cache_dir: &Path,
        repo_folder: &str,
        force_download: bool,
    ) -> HFResult<PathBuf> {
        let repo_path = self.repo_path();
        let url = self
            .hf_client
            .download_url(self.repo_type.url_prefix(), &repo_path, revision, &params.filename)?;

        let cached_etag = if !force_download {
            self.find_cached_etag(repo_folder, revision, &params.filename)
        } else {
            None
        };

        let mut head_headers = self.hf_client.auth_headers();
        if let Some(ref etag_val) = cached_etag
            && let Ok(hv) = reqwest::header::HeaderValue::from_str(&format!("\"{etag_val}\""))
        {
            head_headers.insert(IF_NONE_MATCH, hv);
        }

        let head_response = self.hf_client.head_with_relative_redirects(&url, &head_headers).await?;

        let status = head_response.status();

        if status == reqwest::StatusCode::NOT_FOUND {
            return Err(mark_no_exist_and_return_error(
                cache_dir,
                repo_folder,
                revision,
                &head_response,
                &repo_path,
                &params.filename,
            )
            .await);
        }

        if status == reqwest::StatusCode::NOT_MODIFIED {
            let etag = cached_etag
                .ok_or_else(|| HFError::malformed_response_at("304 Not Modified without cached ETag", url.clone()))?;
            let commit_hash = if cache::is_commit_hash(revision) {
                revision.to_string()
            } else {
                cache::read_ref(cache_dir, repo_folder, revision).await?.ok_or_else(|| {
                    HFError::malformed_response_at("304 Not Modified without cached commit hash", url.clone())
                })?
            };
            return finalize_cached_file(cache_dir, repo_folder, revision, &commit_hash, &params.filename, &etag).await;
        }

        let etag = extract_etag(&head_response)
            .ok_or_else(|| HFError::malformed_response_at("missing ETag header", url.clone()));
        let commit_hash = extract_commit_hash(&head_response);
        let xet_hash = extract_xet_hash(&head_response);
        let has_xet_hash = xet_hash.is_some();
        let file_size: u64 = extract_file_size(&head_response).unwrap_or_else(|| {
            tracing::warn!(url = %url, "missing or invalid Content-Length/X-Linked-Size header, defaulting file size to 0");
            0
        });

        if !status.is_success() && !status.is_redirection() {
            self.hf_client
                .check_response(
                    head_response,
                    Some(&repo_path),
                    crate::error::NotFoundContext::Entry {
                        path: params.filename.clone(),
                    },
                )
                .await?;
        }

        let etag = etag?;
        let commit_hash =
            commit_hash.ok_or_else(|| HFError::malformed_response_at("missing X-Repo-Commit header", url.clone()))?;

        params.progress.emit(DownloadEvent::Start {
            total_files: 1,
            total_bytes: file_size,
        });

        if has_xet_hash {
            let xet_hash =
                xet_hash.ok_or_else(|| HFError::malformed_response_at("missing X-Xet-Hash header", url.clone()))?;
            let blob = cache::blob_path(cache_dir, repo_folder, &etag);
            if !blob.exists() || force_download {
                if let Some(parent) = blob.parent() {
                    std::fs::create_dir_all(parent)?;
                }
                let _lock = cache::acquire_lock(cache_dir, repo_folder, &etag).await?;

                self.xet_download_to_blob(revision, &params.filename, &xet_hash, file_size, &blob, &params.progress)
                    .await?;
            }

            return finalize_cached_file(cache_dir, repo_folder, revision, &commit_hash, &params.filename, &etag).await;
        }

        let blob = cache::blob_path(cache_dir, repo_folder, &etag);

        if blob.exists() && !force_download {
            params.progress.emit(DownloadEvent::Progress {
                files: vec![FileProgress {
                    filename: params.filename.clone(),
                    bytes_completed: file_size,
                    total_bytes: file_size,
                    status: FileStatus::Complete,
                }],
            });
            return finalize_cached_file(cache_dir, repo_folder, revision, &commit_hash, &params.filename, &etag).await;
        }

        let _lock = cache::acquire_lock(cache_dir, repo_folder, &etag).await?;
        let incomplete_path = PathBuf::from(format!("{}.incomplete", blob.display()));
        if let Some(parent) = incomplete_path.parent() {
            std::fs::create_dir_all(parent)?;
        }

        let dl_headers = self.hf_client.auth_headers();
        let response = retry::retry(self.hf_client.retry_config(), || {
            self.hf_client.http_client().get(&url).headers(dl_headers.clone()).send()
        })
        .await?;
        stream_response_to_file_with_progress(
            response,
            &incomplete_path,
            &params.progress,
            Some(&params.filename),
            file_size,
        )
        .await?;
        params.progress.emit(DownloadEvent::Progress {
            files: vec![FileProgress {
                filename: params.filename.clone(),
                bytes_completed: file_size,
                total_bytes: file_size,
                status: FileStatus::Complete,
            }],
        });
        std::fs::rename(&incomplete_path, &blob)?;

        finalize_cached_file(cache_dir, repo_folder, revision, &commit_hash, &params.filename, &etag).await
    }

    #[cfg(not(target_family = "wasm"))]
    async fn resolve_commit_hash(&self, revision: &str) -> HFResult<String> {
        if cache::is_commit_hash(revision) {
            return Ok(revision.to_string());
        }
        #[derive(Deserialize)]
        struct ShaOnly {
            sha: Option<String>,
        }
        let repo_path = self.repo_path();
        let info: ShaOnly = self.fetch_repo_info(Some(revision.to_string()), None).await?;
        info.sha.ok_or_else(|| {
            HFError::malformed_response(format!("repo info for {}@{} returned no commit sha", repo_path, revision))
        })
    }

    #[cfg(not(target_family = "wasm"))]
    async fn list_filtered_files(
        &self,
        revision: &str,
        allow_patterns: Option<&Vec<String>>,
        ignore_patterns: Option<&Vec<String>>,
    ) -> HFResult<Vec<String>> {
        let stream = self.list_tree().revision(revision.to_string()).recursive(true).send()?;
        futures::pin_mut!(stream);

        let mut filenames: Vec<String> = Vec::new();
        while let Some(entry) = stream.next().await {
            let entry = entry?;
            if let RepoTreeEntry::File { path, .. } = entry {
                filenames.push(path);
            }
        }

        if let Some(allow) = allow_patterns {
            filenames.retain(|f| matches_any_glob(allow, f));
        }
        if let Some(ignore) = ignore_patterns {
            filenames.retain(|f| !matches_any_glob(ignore, f));
        }

        Ok(filenames)
    }

    #[cfg(not(target_family = "wasm"))]
    async fn snapshot_download_impl(&self, params: SnapshotDownloadParams) -> HFResult<PathBuf> {
        if params.local_dir.is_none() && !self.hf_client.cache_enabled() {
            return Err(HFError::CacheNotEnabled);
        }
        let revision = params.revision.as_deref().unwrap_or(constants::DEFAULT_REVISION);
        let max_workers = params.max_workers.unwrap_or(8);
        let repo_folder = cache::repo_folder_name(&self.repo_path(), self.repo_type.plural());
        let cache_dir = self.hf_client.cache_dir();

        if params.local_files_only {
            let commit_hash = if cache::is_commit_hash(revision) {
                revision.to_string()
            } else {
                cache::read_ref(cache_dir, &repo_folder, revision).await?.ok_or_else(|| {
                    HFError::LocalEntryNotFound {
                        path: format!("{}/{}", repo_folder, revision),
                    }
                })?
            };
            let snapshot_dir = cache_dir.join(&repo_folder).join("snapshots").join(&commit_hash);
            if snapshot_dir.exists() {
                return Ok(snapshot_dir);
            }
            return Err(HFError::LocalEntryNotFound {
                path: format!("{}/{}", repo_folder, commit_hash),
            });
        }

        let commit_hash = self.resolve_commit_hash(revision).await?;

        let mut filenames = self
            .list_filtered_files(&commit_hash, params.allow_patterns.as_ref(), params.ignore_patterns.as_ref())
            .await?;

        let total_files = filenames.len();
        let force = params.force_download;

        let mut cached_filenames = Vec::new();
        if !force && params.local_dir.is_none() {
            filenames.retain(|f| {
                if cache::snapshot_path(cache_dir, &repo_folder, &commit_hash, f).exists() {
                    cached_filenames.push(f.clone());
                    false
                } else {
                    true
                }
            });
        }

        let repo_path = self.repo_path();
        let repo_path_ref = &repo_path;
        let commit_hash_ref = &commit_hash;
        let mut head_futs = Vec::with_capacity(filenames.len());
        for filename in &filenames {
            let auth = self.hf_client.auth_headers();
            let filename = filename.clone();
            let repo_folder_ref = &repo_folder;
            head_futs.push(async move {
                    let url = self
                        .hf_client
                        .download_url(self.repo_type.url_prefix(), repo_path_ref, commit_hash_ref, &filename)?;
                    let resp = self.hf_client.head_with_relative_redirects(&url, &auth).await?;
                    // Per-file 404 resilience: write a .no_exist marker and skip
                    // the file rather than aborting the entire snapshot download.
                    // This matches the Python huggingface_hub library behavior.
                    // Alternative: since the file list comes from list_repo_tree
                    // on a pinned commit, a 404 here is unexpected and could be
                    // treated as an error instead.
                    if resp.status() == reqwest::StatusCode::NOT_FOUND {
                        if let Some(commit) = extract_commit_hash(&resp) {
                            let no_exist = cache::no_exist_path(cache_dir, repo_folder_ref, &commit, &filename);
                            if let Some(parent) = no_exist.parent() {
                                let _ = std::fs::create_dir_all(parent);
                            }
                            let _ = std::fs::write(&no_exist, b"");
                        }
                        return Ok::<_, HFError>(None);
                    } else if !resp.status().is_success() && !resp.status().is_redirection() {
                        let context = Box::new(crate::error::HttpErrorContext::from_response(resp).await);
                        return Err(HFError::Http { context });
                    }
                    let etag = extract_etag(&resp).ok_or_else(|| {
                        HFError::malformed_response_at(format!("missing ETag header for {filename}"), url.clone())
                    })?;
                    let commit = extract_commit_hash(&resp).unwrap_or_else(|| commit_hash_ref.clone());
                    let xet_hash = extract_xet_hash(&resp);
                    let file_size: u64 = extract_file_size(&resp).unwrap_or_else(|| {
                        tracing::warn!(file = %filename, "missing or invalid Content-Length/X-Linked-Size header, defaulting file size to 0");
                        0
                    });
                    let location = Some(resp.url().to_string());
                    Ok::<_, HFError>(Some(FileMetadataInfo {
                        filename,
                        etag,
                        commit_hash: commit,
                        xet_hash,
                        file_size,
                        location,
                    }))
            });
        }

        let file_metas: Vec<FileMetadataInfo> = futures::stream::iter(head_futs)
            .buffer_unordered(max_workers)
            .try_collect::<Vec<Option<FileMetadataInfo>>>()
            .await?
            .into_iter()
            .flatten()
            .collect();

        let total_bytes: u64 = file_metas.iter().map(|m| m.file_size).sum();
        params.progress.emit(DownloadEvent::Start {
            total_files,
            total_bytes,
        });
        if !cached_filenames.is_empty() {
            params.progress.emit(DownloadEvent::Progress {
                files: cached_filenames
                    .iter()
                    .map(|f| FileProgress {
                        filename: f.clone(),
                        bytes_completed: 0,
                        total_bytes: 0,
                        status: FileStatus::Complete,
                    })
                    .collect(),
            });
        }

        let mut xet_metas = Vec::new();
        let mut non_xet_filenames = Vec::new();

        if let Some(ref local_dir) = params.local_dir {
            let mut local_cached = Vec::new();
            for meta in file_metas {
                let dest = local_dir.join(&meta.filename);
                if dest.exists() && !force {
                    local_cached.push(meta.filename);
                    continue;
                }
                if meta.xet_hash.is_some() {
                    xet_metas.push(meta);
                } else {
                    non_xet_filenames.push(meta.filename);
                }
            }
            if !local_cached.is_empty() {
                params.progress.emit(DownloadEvent::Progress {
                    files: local_cached
                        .iter()
                        .map(|f| FileProgress {
                            filename: f.clone(),
                            bytes_completed: 0,
                            total_bytes: 0,
                            status: FileStatus::Complete,
                        })
                        .collect(),
                });
            }

            let xet_batch_fut = async {
                if xet_metas.is_empty() {
                    return Ok::<_, HFError>(());
                }
                let batch_files: Vec<crate::xet::XetBatchFile> = xet_metas
                    .iter()
                    .map(|m| crate::xet::XetBatchFile {
                        hash: m.xet_hash.as_ref().unwrap().clone(),
                        file_size: m.file_size,
                        path: local_dir.join(&m.filename),
                        filename: m.filename.clone(),
                    })
                    .collect();
                self.xet_download_batch(&commit_hash, &batch_files, &params.progress).await?;
                Ok(())
            };

            let non_xet_dl_params = build_download_params(
                &repo_path,
                &non_xet_filenames,
                &commit_hash,
                params.force_download,
                Some(local_dir.clone()),
                &params.progress,
            );
            let non_xet_fut = async {
                download_concurrently(self, &non_xet_dl_params, max_workers).await?;
                Ok::<_, HFError>(())
            };

            tokio::try_join!(xet_batch_fut, non_xet_fut)?;
            params.progress.emit(DownloadEvent::Complete);
            return Ok(local_dir.clone());
        }

        // Cache mode
        let mut cached_progress: Vec<FileProgress> = Vec::new();
        for meta in file_metas {
            let blob = cache::blob_path(cache_dir, &repo_folder, &meta.etag);
            if blob.exists() && !force {
                cache::create_pointer_symlink(cache_dir, &repo_folder, &meta.commit_hash, &meta.filename, &meta.etag)
                    .await?;
                cached_progress.push(FileProgress {
                    filename: meta.filename.clone(),
                    bytes_completed: meta.file_size,
                    total_bytes: meta.file_size,
                    status: FileStatus::Complete,
                });
                continue;
            }
            if meta.xet_hash.is_some() {
                xet_metas.push(meta);
            } else {
                non_xet_filenames.push(meta.filename);
            }
        }
        if !cached_progress.is_empty() {
            params.progress.emit(DownloadEvent::Progress { files: cached_progress });
        }

        let xet_batch_fut = async {
            if xet_metas.is_empty() {
                return Ok::<_, HFError>(());
            }
            let mut locks = Vec::with_capacity(xet_metas.len());
            for m in &xet_metas {
                locks.push(cache::acquire_lock(cache_dir, &repo_folder, &m.etag).await?);
            }
            let batch_files: Vec<crate::xet::XetBatchFile> = xet_metas
                .iter()
                .map(|m| crate::xet::XetBatchFile {
                    hash: m.xet_hash.as_ref().unwrap().clone(),
                    file_size: m.file_size,
                    path: cache::blob_path(cache_dir, &repo_folder, &m.etag),
                    filename: m.filename.clone(),
                })
                .collect();
            self.xet_download_batch(&commit_hash, &batch_files, &params.progress).await?;
            for m in &xet_metas {
                cache::create_pointer_symlink(cache_dir, &repo_folder, &m.commit_hash, &m.filename, &m.etag).await?;
            }
            drop(locks);
            Ok(())
        };

        let non_xet_dl_params = build_download_params(
            &repo_path,
            &non_xet_filenames,
            &commit_hash,
            params.force_download,
            None,
            &params.progress,
        );
        let non_xet_fut = async {
            download_concurrently(self, &non_xet_dl_params, max_workers).await?;
            Ok::<_, HFError>(())
        };

        tokio::try_join!(xet_batch_fut, non_xet_fut)?;

        if !cache::is_commit_hash(revision) {
            cache::write_ref(cache_dir, &repo_folder, revision, &commit_hash).await?;
        }

        params.progress.emit(DownloadEvent::Complete);
        Ok(cache_dir.join(&repo_folder).join("snapshots").join(&commit_hash))
    }
}

#[cfg(not(target_family = "wasm"))]
async fn mark_no_exist_and_return_error(
    cache_dir: &Path,
    repo_folder: &str,
    revision: &str,
    response: &reqwest::Response,
    repo_id: &str,
    filename: &str,
) -> HFError {
    if let Some(commit_hash) = extract_commit_hash(response) {
        let no_exist = cache::no_exist_path(cache_dir, repo_folder, &commit_hash, filename);
        if let Some(parent) = no_exist.parent() {
            let _ = std::fs::create_dir_all(parent);
        }
        let _ = std::fs::write(&no_exist, b"");
        if !cache::is_commit_hash(revision) {
            let _ = cache::write_ref(cache_dir, repo_folder, revision, &commit_hash).await;
        }
    }
    HFError::EntryNotFound {
        path: filename.to_string(),
        repo_id: repo_id.to_string(),
        context: None,
    }
}

#[cfg(not(target_family = "wasm"))]
async fn finalize_cached_file(
    cache_dir: &Path,
    repo_folder: &str,
    revision: &str,
    commit_hash: &str,
    filename: &str,
    etag: &str,
) -> HFResult<PathBuf> {
    if !cache::is_commit_hash(revision) {
        cache::write_ref(cache_dir, repo_folder, revision, commit_hash).await?;
    }
    cache::create_pointer_symlink(cache_dir, repo_folder, commit_hash, filename, etag).await?;
    Ok(cache::snapshot_path(cache_dir, repo_folder, commit_hash, filename))
}

#[cfg(not(target_family = "wasm"))]
fn build_download_params(
    _repo_id: &str,
    filenames: &[String],
    commit_hash: &str,
    force_download: bool,
    local_dir: Option<PathBuf>,
    progress: &Option<Progress>,
) -> Vec<DownloadFileParams> {
    filenames
        .iter()
        .map(|filename| DownloadFileParams {
            filename: filename.clone(),
            local_dir: local_dir.clone(),
            revision: Some(commit_hash.to_string()),
            force_download,
            local_files_only: false,
            progress: progress.clone(),
        })
        .collect()
}

#[cfg(not(target_family = "wasm"))]
async fn download_concurrently<T: RepoType>(
    api: &HFRepository<T>,
    params: &[DownloadFileParams],
    max_workers: usize,
) -> HFResult<Vec<PathBuf>> {
    let mut download_futs = Vec::with_capacity(params.len());
    for file_params in params {
        download_futs.push(api.download_file_inner(file_params));
    }
    futures::stream::iter(download_futs)
        .buffer_unordered(max_workers)
        .try_collect()
        .await
}

#[cfg(not(target_family = "wasm"))]
async fn stream_response_to_file_with_progress(
    response: reqwest::Response,
    dest: &Path,
    handler: &Option<Progress>,
    filename: Option<&str>,
    total_bytes: u64,
) -> HFResult<()> {
    let mut file = std::fs::File::create(dest)?;
    let mut stream = response.bytes_stream();
    let mut bytes_read: u64 = 0;

    if let (Some(h), Some(filename)) = (handler, filename) {
        h.emit(DownloadEvent::Progress {
            files: vec![FileProgress {
                filename: filename.to_string(),
                bytes_completed: 0,
                total_bytes,
                status: FileStatus::Started,
            }],
        });
    }

    while let Some(chunk) = stream.next().await {
        let chunk = chunk?;
        file.write_all(&chunk)?;
        bytes_read += chunk.len() as u64;

        if let (Some(h), Some(filename)) = (handler, filename) {
            h.emit(DownloadEvent::Progress {
                files: vec![FileProgress {
                    filename: filename.to_string(),
                    bytes_completed: bytes_read,
                    total_bytes,
                    status: FileStatus::InProgress,
                }],
            });
        }
    }
    file.flush()?;
    Ok(())
}

/// Decouple the inner byte stream from the JS-side `ReadableStream` reader cadence on wasm.
///
/// `wasm_streams::ReadableStream::from_stream` builds the JS stream with `QueuingStrategy(0.0)`
/// (HWM=0) — the underlying Rust stream is only polled when JS calls `reader.read()`. For the xet
/// download path, slow JS-side consumption then propagates through hf-xet's term-permit semaphore
/// (`AdjustableSemaphore` in `file_reconstructor.rs`) and stalls xorb fetching. Browsers differ in
/// how aggressively they schedule the `pull` callback, so the effect is intermittent.
///
/// This pump task drains the inner stream into a small bounded channel under `spawn_local`. JS
/// `reader.read()` now pulls from the local channel (cheap) instead of gating the live xet
/// pipeline; xet keeps making progress as long as the channel has room. The channel depth bounds
/// the extra in-flight bytes — at most `depth * max_chunk_size` beyond what xet already buffers.
#[cfg(target_family = "wasm")]
pub(crate) fn buffer_wasm_stream(inner: HFByteStream) -> HFByteStream {
    use futures::SinkExt;
    use futures::channel::mpsc;

    const BUFFER_DEPTH: usize = 2;
    let (mut tx, rx) = mpsc::channel::<HFResult<bytes::Bytes>>(BUFFER_DEPTH);

    wasm_bindgen_futures::spawn_local(async move {
        let mut inner = inner;
        while let Some(item) = inner.next().await {
            let is_err = item.is_err();
            if tx.send(item).await.is_err() {
                return;
            }
            if is_err {
                return;
            }
        }
    });

    Box::new(Box::pin(rx))
}

pub(crate) fn wrap_stream_with_progress(
    stream: HFByteStream,
    progress: Option<Progress>,
    filename: String,
    total_bytes: u64,
) -> HFByteStream {
    if progress.is_none() {
        return stream;
    }
    let wrapped = futures::stream::unfold((stream, 0u64, false), move |(mut inner, bytes_completed, ended)| {
        let progress = progress.clone();
        let filename = filename.clone();
        async move {
            if ended {
                return None;
            }
            match inner.next().await {
                Some(Ok(chunk)) => {
                    let bytes_completed = bytes_completed + chunk.len() as u64;
                    progress.emit(DownloadEvent::Progress {
                        files: vec![FileProgress {
                            filename,
                            bytes_completed,
                            total_bytes,
                            status: FileStatus::InProgress,
                        }],
                    });
                    Some((Ok(chunk), (inner, bytes_completed, false)))
                },
                Some(Err(e)) => Some((Err(e), (inner, bytes_completed, true))),
                None => {
                    progress.emit(DownloadEvent::Complete);
                    None
                },
            }
        }
    });
    Box::new(Box::pin(wrapped))
}

#[bon]
impl<T: RepoType> HFRepository<T> {
    /// Download a single file from a repository.
    ///
    /// When `local_dir` is `Some`, the file is downloaded directly to that directory
    /// (no caching). When `local_dir` is `None`, the HF cache system is used:
    /// blobs are stored by etag and symlinked from snapshots/{commit}/{filename}.
    ///
    /// Returns the local filesystem path of the downloaded or cached file. Use
    /// [`HFRepository::download_file_stream`] or
    /// [`HFRepository::download_file_to_bytes`] when you do not want to write to
    /// disk.
    ///
    /// # Offline / cache-only lookups
    ///
    /// Set `.local_files_only(true)` to resolve strictly from the local cache
    /// without any network request — this is the replacement for the 0.x
    /// `Cache::get` API. A cache miss returns
    /// [`HFError::LocalEntryNotFound`], which is distinct from a real failure:
    /// match it to tell "not cached" apart from a genuinely missing file
    /// ([`HFError::EntryNotFound`]) or any transport error.
    ///
    /// ```no_run
    /// # #[tokio::main] async fn main() -> hf_hub::HFResult<()> {
    /// use hf_hub::HFError;
    ///
    /// let repo = hf_hub::HFClient::new()?.model("openai-community", "gpt2");
    /// match repo.download_file().filename("config.json").local_files_only(true).send().await {
    ///     Ok(path) => println!("cached at {}", path.display()),
    ///     Err(HFError::LocalEntryNotFound { .. }) => println!("not in cache"),
    ///     Err(e) => return Err(e),
    /// }
    /// # Ok(()) }
    /// ```
    ///
    /// Endpoint: `GET {endpoint}/{prefix}{repo_id}/resolve/{revision}/{filename}`.
    ///
    /// # Parameters
    ///
    /// - `filename` (required): path of the file to download within the repository.
    /// - `local_dir`: local directory to download the file into. When set, the file is saved with its repo path
    ///   structure.
    /// - `revision`: Git revision. Defaults to the main branch.
    /// - `force_download` (default `false`): re-download the file even if a cached copy exists.
    /// - `local_files_only` (default `false`): only return the file if cached locally; never make a network request.
    /// - `progress`: optional progress handler.
    #[cfg(not(target_family = "wasm"))]
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub async fn download_file(
        &self,
        /// Path of the file to download within the repository.
        #[builder(into)]
        filename: String,
        /// Local directory to download the file into. When set, the file is saved with its repo path structure.
        #[builder(into)]
        local_dir: Option<PathBuf>,
        /// Git revision. Defaults to the main branch.
        #[builder(into)]
        revision: Option<String>,
        /// Re-download the file even if a cached copy exists.
        #[builder(default)]
        force_download: bool,
        /// Only return the file if cached locally; never make a network request.
        #[builder(default)]
        local_files_only: bool,
        /// Progress handler.
        #[builder(into)]
        progress: Option<Progress>,
    ) -> HFResult<PathBuf> {
        Box::pin(self.download_file_impl(DownloadFileParams {
            filename,
            local_dir,
            revision,
            force_download,
            local_files_only,
            progress,
        }))
        .await
    }

    /// Download a file and return a byte stream instead of writing to disk.
    ///
    /// Returns a `(content_length, stream)` tuple. `content_length` is `Some`
    /// when the server provides a `Content-Length` header.
    ///
    /// When `range` is set, only the specified byte range is fetched.
    ///
    /// # Parameters
    ///
    /// - `filename` (required): path of the file to stream within the repository.
    /// - `revision`: Git revision. Defaults to the main branch.
    /// - `range`: byte range to request, as a Rust `std::ops::Range<u64>`. The range follows standard Rust semantics —
    ///   `start` is **inclusive**, `end` is **exclusive** — so `0..1024` fetches the first 1024 bytes (offsets
    ///   `0..=1023`). Internally, this is converted to the HTTP `Range: bytes=<start>-<end-1>` header. `start` must be
    ///   strictly less than `end`; an empty or inverted range returns [`HFError::InvalidParameter`].
    /// - `progress`: optional progress handler. `Start` is emitted before the stream is returned; `Progress` is emitted
    ///   as the caller polls each chunk; `Complete` is emitted when the stream is exhausted.
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub async fn download_file_stream(
        &self,
        /// Path of the file to stream within the repository.
        #[builder(into)]
        filename: String,
        /// Git revision. Defaults to the main branch.
        #[builder(into)]
        revision: Option<String>,
        /// Byte range to request, as a Rust `std::ops::Range<u64>`. The range follows standard Rust semantics —
        /// `start` is **inclusive**, `end` is **exclusive** — so `0..1024` fetches the first 1024 bytes (offsets
        /// `0..=1023`). Internally, this is converted to the HTTP `Range: bytes=<start>-<end-1>` header. `start` must
        /// be strictly less than `end`; an empty or inverted range returns [`HFError::InvalidParameter`].
        range: Option<std::ops::Range<u64>>,
        /// Progress handler. `Start` is emitted before the stream is returned; `Progress` is emitted
        /// as the caller polls each chunk; `Complete` is emitted when the stream is exhausted.
        #[builder(into)]
        progress: Option<Progress>,
    ) -> HFResult<(Option<u64>, HFByteStream)> {
        Box::pin(self.download_file_stream_impl(DownloadFileStreamParams {
            filename,
            revision,
            range,
            progress,
        }))
        .await
    }

    /// Download a file (or byte range) into memory and return the contents as [`bytes::Bytes`].
    ///
    /// This is a convenience wrapper around
    /// [`download_file_stream`](Self::download_file_stream) that collects the entire stream into
    /// a single buffer. When `range` is set, only the specified byte range is fetched.
    ///
    /// # Parameters
    ///
    /// - `filename` (required): path of the file to download within the repository.
    /// - `revision`: Git revision. Defaults to the main branch.
    /// - `range`: byte range to request, as a Rust `std::ops::Range<u64>`. The range follows standard Rust semantics —
    ///   `start` is **inclusive**, `end` is **exclusive** — so `0..1024` fetches the first 1024 bytes (offsets
    ///   `0..=1023`). Internally, this is converted to the HTTP `Range: bytes=<start>-<end-1>` header. `start` must be
    ///   strictly less than `end`; an empty or inverted range returns [`HFError::InvalidParameter`].
    /// - `progress`: optional progress handler. Emits `Start`/`Progress`/`Complete` as the underlying stream is
    ///   drained, identically to [`download_file_stream`](Self::download_file_stream).
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub async fn download_file_to_bytes(
        &self,
        /// Path of the file to download within the repository.
        #[builder(into)]
        filename: String,
        /// Git revision. Defaults to the main branch.
        #[builder(into)]
        revision: Option<String>,
        /// Byte range to request, as a Rust `std::ops::Range<u64>`. The range follows standard Rust semantics —
        /// `start` is **inclusive**, `end` is **exclusive** — so `0..1024` fetches the first 1024 bytes (offsets
        /// `0..=1023`). Internally, this is converted to the HTTP `Range: bytes=<start>-<end-1>` header. `start` must
        /// be strictly less than `end`; an empty or inverted range returns [`HFError::InvalidParameter`].
        range: Option<std::ops::Range<u64>>,
        /// Progress handler. Emits `Start`/`Progress`/`Complete` as the underlying stream is
        /// drained, identically to [`HFRepository::download_file_stream`].
        #[builder(into)]
        progress: Option<Progress>,
    ) -> HFResult<bytes::Bytes> {
        Box::pin(self.download_file_to_bytes_impl(DownloadFileStreamParams {
            filename,
            revision,
            range,
            progress,
        }))
        .await
    }

    /// Download all selected files for a resolved revision.
    ///
    /// When `local_dir` is `None`, files are stored in the HF cache, and the returned path is the
    /// cache snapshot directory for the resolved commit. When `local_dir` is `Some`, files are
    /// written directly under that directory.
    ///
    /// `allow_patterns` and `ignore_patterns` use [`globset`](https://docs.rs/globset) syntax
    /// (`*`, `?`, `**`, character classes, etc.). Both are matched against each candidate file's
    /// **repository path** — forward-slash-joined and relative to the repo root, e.g.,
    /// `tokenizer.json` or `weights/model-00001-of-00003.safetensors`.
    ///
    /// # Parameters
    ///
    /// - `revision`: Git revision. Defaults to the main branch.
    /// - `allow_patterns`: globs selecting which repository files to download. When set, only files whose repo path
    ///   matches at least one pattern are downloaded.
    /// - `ignore_patterns`: globs of repository files to skip. Matched against the same repo paths as `allow_patterns`.
    /// - `local_dir`: local directory to download into.
    /// - `force_download` (default `false`): re-download all files even if cached.
    /// - `local_files_only` (default `false`): resolve only from the local cache.
    /// - `max_workers`: maximum concurrent file downloads (default 8).
    /// - `progress`: optional progress handler.
    #[cfg(not(target_family = "wasm"))]
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub async fn snapshot_download(
        &self,
        /// Git revision. Defaults to the main branch.
        #[builder(into)]
        revision: Option<String>,
        /// Globs selecting which repository files to download. When set, only files whose repo path
        /// matches at least one pattern are downloaded.
        allow_patterns: Option<Vec<String>>,
        /// Globs of repository files to skip. Matched against the same repo paths as `allow_patterns`.
        ignore_patterns: Option<Vec<String>>,
        /// Local directory to download into.
        #[builder(into)]
        local_dir: Option<PathBuf>,
        /// Re-download all files even if cached.
        #[builder(default)]
        force_download: bool,
        /// Resolve only from the local cache.
        #[builder(default)]
        local_files_only: bool,
        /// Maximum concurrent file downloads (default 8).
        max_workers: Option<usize>,
        /// Progress handler.
        #[builder(into)]
        progress: Option<Progress>,
    ) -> HFResult<PathBuf> {
        Box::pin(self.snapshot_download_impl(SnapshotDownloadParams {
            revision,
            allow_patterns,
            ignore_patterns,
            local_dir,
            force_download,
            local_files_only,
            max_workers,
            progress,
        }))
        .await
    }
}

#[cfg(feature = "blocking")]
#[bon]
impl<T: RepoType> crate::blocking::HFRepositorySync<T> {
    /// Blocking counterpart of [`HFRepository::download_file`]. See the async method for
    /// parameters and behavior.
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub fn download_file(
        &self,
        #[builder(into)] filename: String,
        #[builder(into)] local_dir: Option<PathBuf>,
        #[builder(into)] revision: Option<String>,
        #[builder(default)] force_download: bool,
        #[builder(default)] local_files_only: bool,
        #[builder(into)] progress: Option<Progress>,
    ) -> HFResult<PathBuf> {
        self.runtime.block_on(
            self.inner
                .download_file()
                .filename(filename)
                .maybe_local_dir(local_dir)
                .maybe_revision(revision)
                .force_download(force_download)
                .local_files_only(local_files_only)
                .maybe_progress(progress)
                .send(),
        )
    }

    /// Blocking counterpart of [`HFRepository::download_file_to_bytes`]. See the async method for
    /// parameters and behavior.
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub fn download_file_to_bytes(
        &self,
        #[builder(into)] filename: String,
        #[builder(into)] revision: Option<String>,
        range: Option<std::ops::Range<u64>>,
        #[builder(into)] progress: Option<Progress>,
    ) -> HFResult<bytes::Bytes> {
        self.runtime.block_on(
            self.inner
                .download_file_to_bytes()
                .filename(filename)
                .maybe_revision(revision)
                .maybe_range(range)
                .maybe_progress(progress)
                .send(),
        )
    }

    /// Blocking counterpart of [`HFRepository::snapshot_download`]. See the async method for
    /// parameters and behavior.
    #[builder(finish_fn = send, derive(Debug, Clone))]
    pub fn snapshot_download(
        &self,
        #[builder(into)] revision: Option<String>,
        allow_patterns: Option<Vec<String>>,
        ignore_patterns: Option<Vec<String>>,
        #[builder(into)] local_dir: Option<PathBuf>,
        #[builder(default)] force_download: bool,
        #[builder(default)] local_files_only: bool,
        max_workers: Option<usize>,
        #[builder(into)] progress: Option<Progress>,
    ) -> HFResult<PathBuf> {
        self.runtime.block_on(
            self.inner
                .snapshot_download()
                .maybe_revision(revision)
                .maybe_allow_patterns(allow_patterns)
                .maybe_ignore_patterns(ignore_patterns)
                .maybe_local_dir(local_dir)
                .force_download(force_download)
                .local_files_only(local_files_only)
                .maybe_max_workers(max_workers)
                .maybe_progress(progress)
                .send(),
        )
    }
}