get_iroh_collection_full.rs

/// Run a get request that is complete (no dealing with resume) and hardcoded to the (name, hash) iroh collection
async fn run_get_request_collection(
    opts: iroh::dial::Options,
    hash: Hash,
) -> anyhow::Result<Stats> {
    let request = GetRequest::all(hash).into();
    let connection = iroh::dial::dial(opts).await?;
    let initial = fsm::start(connection, request);
    let connected = initial.next().await?;
    // on connected callback
    use fsm::*;
    let ConnectedNext::StartRoot(sc) = connected.next().await? else {
        anyhow::bail!("request did not include collection");
    };
    let (end, data) = sc.next().concatenate_into_vec().await?;
    let collection = Collection::from_bytes(&data)?;
    // on collection callback
    let mut next = end.next();
    let finishing = loop {
        let start = match next {
            EndBlobNext::MoreChildren(start) => start,
            EndBlobNext::Closing(finishing) => break finishing,
        };
        let blob = &collection.blobs()[start.child_offset() as usize];
        let (done, data) = start.next(blob.hash).concatenate_into_vec().await?;
        // on blob callback
        next = done.next();
    };
    let stats = finishing.next().await?;
    Ok(stats)
}