Function pull_images_impl

crates/lib/src/boundimage.rs:177–202

(
    imgstore: &CStorage,
    bound_images: Vec<crate::boundimage::BoundImage>,
)

#[context("Pulling bound images")]
pub(crate) async fn pull_images_impl(
    imgstore: &CStorage,
    bound_images: Vec<crate::boundimage::BoundImage>,
) -> Result<()> {
    let n = bound_images.len();
    tracing::debug!("Pulling bound images: {n}");
    // TODO: do this in parallel
    for bound_image in bound_images {
        let image = &bound_image.image;
        if imgstore.exists(image).await? {
            tracing::debug!("Bound image already present: {image}");
            continue;
        }
        let desc = format!("Fetching bound image: {image}");
        crate::utils::async_task_with_spinner(&desc, async move {
            imgstore
                .pull(&bound_image.image, PullMode::IfNotExists)
                .await
        })
        .await?;
    }

    println!("Bound images stored: {n}");

    Ok(())
}

impl BoundImage {
    fn new(image: String, auth_file: Option<String>) -> Result<BoundImage> {