Function spawn

crates/openshell-server/src/compute/vm.rs:452–516

(
    config: &Config,
    vm_config: &VmComputeConfig,
)

/// kills the subprocess and removes the socket on drop.
#[cfg(unix)]
pub async fn spawn(
    config: &Config,
    vm_config: &VmComputeConfig,
) -> Result<AcquiredRemoteDriverEndpoint> {
    if vm_config.grpc_endpoint.trim().is_empty() {
        return Err(Error::config(
            "grpc_endpoint is required when using the vm compute driver",
        ));
    }

    let driver_bin = resolve_compute_driver_bin(vm_config)?;
    let socket_path = compute_driver_socket_path(vm_config);
    let guest_tls_paths = compute_driver_guest_tls_paths(vm_config)?;
    prepare_compute_driver_socket_path(vm_config, &socket_path)?;

    let mut command = Command::new(&driver_bin);
    command.kill_on_drop(true);
    command.stdin(Stdio::null());
    command.stdout(Stdio::inherit());
    command.stderr(Stdio::inherit());
    command.arg("--bind-socket").arg(&socket_path);
    command
        .arg("--expected-peer-pid")
        .arg(std::process::id().to_string());
    command.arg("--log-level").arg(&config.log_level);
    command
        .arg("--openshell-endpoint")
        .arg(&vm_config.grpc_endpoint);
    command.arg("--state-dir").arg(&vm_config.state_dir);
    if !vm_config.default_image.trim().is_empty() {
        command.arg("--default-image").arg(&vm_config.default_image);
    }
    if !vm_config.bootstrap_image.trim().is_empty() {
        command
            .arg("--bootstrap-image")
            .arg(&vm_config.bootstrap_image);
    }
    command
        .arg("--krun-log-level")
        .arg(vm_config.krun_log_level.to_string());
    command.arg("--vcpus").arg(vm_config.vcpus.to_string());
    command.arg("--mem-mib").arg(vm_config.mem_mib.to_string());
    command
        .arg("--overlay-disk-mib")
        .arg(vm_config.overlay_disk_mib.to_string());
    if let Some(tls) = guest_tls_paths {
        command.arg("--guest-tls-ca").arg(tls.ca);
        command.arg("--guest-tls-cert").arg(tls.cert);
        command.arg("--guest-tls-key").arg(tls.key);
    }

    let mut child = command.spawn().map_err(|e| {
        Error::execution(format!(
            "failed to launch vm compute driver '{}': {e}",
            driver_bin.display()
        ))
    })?;
    let channel = wait_for_compute_driver(&socket_path, &mut child).await?;