Struct Fetcher 

pub struct Fetcher { /* private fields */ }

Fetcher for remote content

Implementations

impl Fetcher

pub fn new(config: FetchConfig) -> Self

Create a new fetcher with the given config BlossomClient auto-loads servers from ~/.hashtree/config.toml

pub fn with_keys(config: FetchConfig, keys: Keys) -> Self

Create a new fetcher with specific keys (for authenticated uploads)

pub fn blossom(&self) -> &BlossomClient

Get the underlying BlossomClient

pub async fn fetch_chunk( &self, webrtc_state: Option<&Arc<WebRTCState>>, hash_hex: &str, ) -> Result<Vec<u8>>

Fetch a single chunk by hash, trying WebRTC first then Blossom

pub async fn fetch_chunk_with_store( &self, store: &HashtreeStore, webrtc_state: Option<&Arc<WebRTCState>>, hash: &[u8; 32], ) -> Result<Vec<u8>>

Fetch a chunk, checking local storage first

pub async fn fetch_tree( &self, store: &HashtreeStore, webrtc_state: Option<&Arc<WebRTCState>>, root_hash: &[u8; 32], ) -> Result<(usize, u64)>

Fetch an entire tree (all chunks recursively) - sequential version Returns (chunks_fetched, bytes_fetched)

pub async fn fetch_tree_parallel( &self, store: &HashtreeStore, webrtc_state: Option<&Arc<WebRTCState>>, root_hash: &[u8; 32], concurrency: usize, ) -> Result<(usize, u64)>

Fetch an entire tree with parallel downloads Uses work-stealing: always keeps concurrency requests in flight Returns (chunks_fetched, bytes_fetched)

pub async fn fetch_file( &self, store: &HashtreeStore, webrtc_state: Option<&Arc<WebRTCState>>, hash: &[u8; 32], ) -> Result<Option<Vec<u8>>>

Fetch a file by hash, fetching all chunks if needed Returns the complete file content

pub async fn fetch_directory( &self, store: &HashtreeStore, webrtc_state: Option<&Arc<WebRTCState>>, hash: &[u8; 32], ) -> Result<Option<DirectoryListing>>

Fetch a directory listing, fetching chunks if needed

pub async fn upload(&self, data: &[u8]) -> Result<String>

Upload data to Blossom servers

pub async fn upload_if_missing(&self, data: &[u8]) -> Result<(String, bool)>

Upload data if it doesn’t already exist