//! This module implements (temporary) compatibility shims between
//! Tvix and C++ Nix.
//!
//! These are not intended to be long-lived, but should bootstrap Tvix
//! by piggybacking off functionality that already exists in Nix and
//! is still being implemented in Tvix.
use std::cell::RefCell;
use std::path::Path;
use std::process::Command;
use std::rc::Rc;
use std::{io, path::PathBuf};
use crate::known_paths::KnownPaths;
use smol_str::SmolStr;
use tvix_eval::{ErrorKind, EvalIO, FileType, StdIO};
/// Compatibility implementation of [`EvalIO`] that uses C++ Nix to
/// write files to the Nix store.
pub struct NixCompatIO {
/// Most IO requests are tunneled through to [`tvix_eval::StdIO`]
/// instead.
underlying: StdIO,
/// Ingested paths must be reported to this known paths tracker
/// for accurate build reference scanning.
known_paths: Rc<RefCell<KnownPaths>>,
}
impl EvalIO for NixCompatIO {
fn store_dir(&self) -> Option<String> {
Some("/nix/store".into())
}
// Pass path imports through to `nix-store --add`
fn import_path(&self, path: &Path) -> Result<PathBuf, ErrorKind> {
self.add_to_store(path).map_err(|error| ErrorKind::IO {
error: std::rc::Rc::new(error),
path: Some(path.to_path_buf()),
})
}
// Pass the rest of the functions through to `Self::underlying`
fn path_exists(&self, path: PathBuf) -> Result<bool, ErrorKind> {
self.underlying.path_exists(path)
}
fn read_to_string(&self, path: PathBuf) -> Result<String, ErrorKind> {
self.underlying.read_to_string(path)
}
fn read_dir(&self, path: PathBuf) -> Result<Vec<(SmolStr, FileType)>, ErrorKind> {
self.underlying.read_dir(path)
}
}
impl NixCompatIO {
pub fn new(known_paths: Rc<RefCell<KnownPaths>>) -> Self {
NixCompatIO {
underlying: StdIO,
known_paths,
}
}
/// Add a path to the Nix store using the `nix-store --add`
/// functionality from C++ Nix.
fn add_to_store(&self, path: &Path) -> Result<PathBuf, io::Error> {
if !path.try_exists()? {
return Err(io::Error::from(io::ErrorKind::NotFound));
}
let mut cmd = Command::new("nix-store");
cmd.arg("--add");
cmd.arg(path);
let out = cmd.output()?;
if !out.status.success() {
return Err(io::Error::new(
io::ErrorKind::Other,
String::from_utf8_lossy(&out.stderr),
));
}
let out_path_str = String::from_utf8(out.stdout)
.map_err(|err| io::Error::new(io::ErrorKind::InvalidData, err))?;
self.known_paths.borrow_mut().plain(&out_path_str);
let mut out_path = PathBuf::new();
out_path.push(out_path_str.trim());
Ok(out_path)
}
}