Function attach_vm_progress_metadata

crates/openshell-driver-vm/src/driver.rs:5055–5106

(event: &mut PlatformEvent)

}

fn attach_vm_progress_metadata(event: &mut PlatformEvent) {
    if event.source != "vm" {
        return;
    }

    match event.reason.as_str() {
        "Scheduled" => {
            mark_progress_complete(
                &mut event.metadata,
                PROGRESS_STEP_REQUESTING_SANDBOX,
                "Sandbox allocated",
            );
            mark_progress_active(&mut event.metadata, PROGRESS_STEP_PULLING_IMAGE);
        }
        "Pulling" => {
            mark_progress_active(&mut event.metadata, PROGRESS_STEP_PULLING_IMAGE);
            if let Some(image_ref) = event.metadata.get("image_ref").cloned() {
                mark_progress_detail(&mut event.metadata, image_ref);
            } else if let Some(image_ref) = pulling_image_from_message(&event.message) {
                mark_progress_detail(&mut event.metadata, image_ref);
            }
        }
        "Pulled" => {
            let label = pulled_label(event);
            mark_progress_complete(&mut event.metadata, PROGRESS_STEP_PULLING_IMAGE, label);
            mark_progress_active(&mut event.metadata, PROGRESS_STEP_STARTING_SANDBOX);
        }
        "PullingLayer" => {
            if let Some(detail) = pulling_layer_detail(&event.metadata) {
                mark_progress_detail(&mut event.metadata, detail);
            }
        }
        "ResolvingImage" => mark_progress_detail(&mut event.metadata, "Resolving image"),
        "AuthenticatingRegistry" => {
            mark_progress_detail(&mut event.metadata, "Authenticating registry");
        }
        "FetchingManifest" => mark_progress_detail(&mut event.metadata, "Fetching image manifest"),
        "CacheHit" => mark_progress_detail(&mut event.metadata, "Using cached root disk"),
        "CacheMiss" => mark_progress_detail(&mut event.metadata, "Preparing image cache"),
        "WaitingForImageCacheLock" => {
            mark_progress_detail(&mut event.metadata, "Waiting for image cache lock");
        }
        "ExportingRootfs" => {
            mark_progress_detail(&mut event.metadata, "Exporting local image rootfs");
        }
        "PreparingRootfs" => mark_progress_detail(&mut event.metadata, "Preparing rootfs"),
        "CreatingRootDisk" => mark_progress_detail(&mut event.metadata, "Formatting root disk"),
        "PreparingOverlay" => mark_progress_detail(&mut event.metadata, "Preparing overlay disk"),
        "Started" => mark_progress_detail(&mut event.metadata, "Waiting for VM supervisor"),
        _ => {}
    }
}

fn pulling_image_from_message(message: &str) -> Option<String> {
    let image = message