evix 0.1.0

Evaluate a Nix expression and stream derivation info as JSON lines
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

mod eval;
mod master;
mod worker;

use std::{env, path::PathBuf};

use anyhow::Result;
use clap::{ArgGroup, Parser};

pub const WORKER_ENV: &str = "_NEJ_WORKER";

#[derive(Parser, Clone)]
#[command(name = "evix", about = "Evaluate a Nix attrset and emit one JSON line per derivation")]
#[command(group(ArgGroup::new("input").required(true).args(["flake", "expr", "file"])))]
pub struct Args {
    /// Evaluate a flake output (e.g. `.#hydraJobs`).
    #[arg(long)]
    pub flake: Option<String>,

    /// Evaluate an inline Nix expression.
    #[arg(long)]
    pub expr: Option<String>,

    /// Evaluate a Nix file.
    #[arg(long)]
    pub file: Option<PathBuf>,

    /// Pass a Nix expression as an argument: `--arg NAME EXPR`.
    #[arg(long = "arg", value_names = ["NAME", "EXPR"], num_args = 2, action = clap::ArgAction::Append)]
    pub arg: Vec<String>,

    /// Pass a string value as an argument: `--argstr NAME VALUE`.
    #[arg(long = "argstr", value_names = ["NAME", "VALUE"], num_args = 2, action = clap::ArgAction::Append)]
    pub argstr: Vec<String>,

    /// Number of worker processes.
    #[arg(long, default_value_t = 1)]
    pub workers: usize,

    /// Memory limit per worker in MB; worker restarts when exceeded.
    #[arg(long, default_value_t = 4096)]
    pub max_memory_size: usize,

    /// Recurse into all attrsets, ignoring recurseForDerivations.
    #[arg(long)]
    pub force_recurse: bool,

    /// Directory in which to register GC roots for evaluated derivations.
    #[arg(long)]
    pub gc_roots_dir: Option<PathBuf>,
}

fn main() -> Result<()> {
    let args = Args::parse();
    if env::var(WORKER_ENV).is_ok() {
        worker::run_worker(&args)
    } else {
        master::run_master(&args)
    }
}