use crate::error::Result; use crate::image::cache::ImageCache; use crate::image::{ImageCompiler, ImageInfo}; use ocipkg::ImageName; use std::fs; use std::path::PathBuf; use uuid::Uuid; use xenclient::{DomainConfig, XenClient}; pub struct Controller { image_cache: ImageCache, image: String, client: XenClient, kernel_path: String, initrd_path: String, vcpus: u32, mem: u64, } impl Controller { pub fn new( cache_path: String, kernel_path: String, initrd_path: String, image: String, vcpus: u32, mem: u64, ) -> Result { fs::create_dir_all(&cache_path)?; let client = XenClient::open()?; let mut image_cache_path = PathBuf::from(cache_path); image_cache_path.push("image"); fs::create_dir_all(&image_cache_path)?; let image_cache = ImageCache::new(&image_cache_path)?; Ok(Controller { image_cache, image, client, kernel_path, initrd_path, vcpus, mem, }) } fn compile(&mut self) -> Result { let image = ImageName::parse(&self.image)?; let compiler = ImageCompiler::new(&self.image_cache)?; compiler.compile(&image) } pub fn launch(&mut self) -> Result { let uuid = Uuid::new_v4(); let name = format!("hypha-{uuid}"); let _image_info = self.compile()?; let config = DomainConfig { name: &name, max_vcpus: self.vcpus, mem_mb: self.mem, kernel_path: self.kernel_path.as_str(), initrd_path: self.initrd_path.as_str(), cmdline: "debug elevator=noop", }; Ok(self.client.create(&config)?) } }