diff options
author | Vincent Ambo <mail@tazj.in> | 2022-12-13T17·17+0300 |
---|---|---|
committer | tazjin <tazjin@tvl.su> | 2022-12-22T19·09+0000 |
commit | ea7d63e177d8a951e30bc00918081eb069e2efb2 (patch) | |
tree | 9177f7ff683f2eeef178df2aeda349e52b915c05 /tvix/cli/src/nix_compat.rs | |
parent | 4714f8b93998bee9c1b656f0b2358a26d3cf899d (diff) |
feat(tvix/cli): implement `NixCompatIO` helper type r/5474
This type allows for temporarily compatibility with the C++ Nix store, specifically (for now) it gives us the store directory used by Nix and imports files the same way. Change-Id: I4767794ef2863eba49661315c63c4e17de946d60 Reviewed-on: https://cl.tvl.fyi/c/depot/+/7587 Reviewed-by: grfn <grfn@gws.fyi> Tested-by: BuildkiteCI
Diffstat (limited to 'tvix/cli/src/nix_compat.rs')
-rw-r--r-- | tvix/cli/src/nix_compat.rs | 82 |
1 files changed, 82 insertions, 0 deletions
diff --git a/tvix/cli/src/nix_compat.rs b/tvix/cli/src/nix_compat.rs new file mode 100644 index 000000000000..75281d90e85b --- /dev/null +++ b/tvix/cli/src/nix_compat.rs @@ -0,0 +1,82 @@ +//! 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::path::Path; +use std::process::Command; +use std::{io, path::PathBuf}; + +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, +} + +impl NixCompatIO { + pub fn new() -> Self { + NixCompatIO { underlying: StdIO } + } +} + +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> { + 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) + } +} + +/// Add a path to the Nix store using the `nix-store --add` +/// functionality from C++ Nix. +fn add_to_store(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))?; + + let mut out_path = PathBuf::new(); + out_path.push(out_path_str.trim()); + Ok(out_path) +} |