procman 0.23.8

mod args;
mod checks;
mod config;
mod dependency;
mod log;
mod output;
mod output_match;
mod pman;
mod process;
mod signal;
mod watch;

use std::{
    collections::HashMap,
    sync::{Arc, Mutex, mpsc},
};

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

#[derive(Parser)]
#[command(
    version,
    about = "A process supervisor driven by a .pman process definition file",
    after_help = "\
EXAMPLES:
    # Run all jobs defined in a config file
    procman myapp.pman

    # Pass extra environment variables
    procman myapp.pman -e PORT=3000 -e DEBUG=1

    # Pass user-defined args (defined in config args: section)
    procman myapp.pman -- --rust-log debug --enable-feature

    # Pause shutdown on child failure for interactive debugging
    procman myapp.pman --debug

    # Validate the config file and exit without starting processes
    procman myapp.pman --check

    # Run specific tasks defined in the config file
    procman tests.pman -t test_system_a -t test_system_b

SIGNALS:
    On SIGINT or SIGTERM, all children receive SIGTERM. After a 2-second
    grace period, remaining processes are sent SIGKILL."
)]
struct Cli {
    /// Path to config file
    file: String,
    /// Extra environment variables (repeatable, KEY=VALUE format)
    #[arg(short = 'e', long = "env", value_name = "KEY=VALUE")]
    env: Vec<String>,
    /// Pause shutdown on child failure for interactive debugging
    #[arg(long)]
    debug: bool,
    /// Validate the config file and exit without starting processes
    #[arg(long)]
    check: bool,
    /// Task(s) to run (repeatable)
    #[arg(short = 't', long = "task", value_name = "NAME")]
    tasks: Vec<String>,
    /// Arguments for config-defined args (passed after --)
    #[arg(last = true)]
    user_args: Vec<String>,
}

fn parse_env_args(args: &[String]) -> Result<HashMap<String, String>> {
    let mut map = HashMap::new();
    for arg in args {
        let (key, value) = arg
            .split_once('=')
            .ok_or_else(|| anyhow::anyhow!("invalid env argument (expected KEY=VALUE): {arg}"))?;
        if key.is_empty() {
            anyhow::bail!("invalid env argument (empty key): {arg}");
        }
        map.insert(key.to_string(), value.to_string());
    }
    Ok(map)
}

fn run_supervisor(
    config_path: String,
    extra_env: HashMap<String, String>,
    user_args: Vec<String>,
    task_names: Vec<String>,
    debug: bool,
    check: bool,
) -> Result<()> {
    if debug {
        anyhow::ensure!(
            std::io::IsTerminal::is_terminal(&std::io::stdin()),
            "--debug requires an interactive terminal"
        );
    }

    let content =
        std::fs::read_to_string(&config_path).with_context(|| format!("reading {config_path}"))?;

    // Handle --help: use old-style full load (literal paths) to collect all defs.
    if user_args.contains(&"--help".to_string()) {
        let (_, header) = pman::load_header(&content, &config_path)?;
        args::print_usage(&header.arg_defs);
        std::process::exit(0);
    }

    // Phase 1: Parse root file only (no imports loaded yet)
    let root = pman::parse_root(&content, &config_path)?;

    // Phase 2: Collect root-level arg defs
    let root_arg_defs = pman::collect_root_arg_defs(&root, &config_path)?;

    // Phase 3: Parse root args, collect remaining (namespaced) args for later
    let (root_arg_values, remaining_args) =
        args::parse_root_args(&user_args, &root_arg_defs, check)?;

    // Phase 4: Load imports with ${args.NAME} substitution in paths
    let (modules, header) = pman::load_with_args(root, &config_path, &root_arg_values, check)?;

    // Phase 5: Parse remaining args against imported module (namespaced) defs
    let namespaced_defs: Vec<_> = header
        .arg_defs
        .iter()
        .filter(|d| d.namespace.is_some())
        .cloned()
        .collect();
    let namespaced_values = args::parse_user_args(&remaining_args, &namespaced_defs)?;

    // Phase 6: Merge all arg values
    let mut arg_values = root_arg_values;
    arg_values.extend(namespaced_values);

    // Phase 7: Build env with correct precedence
    // arg env vars (defaults + user overrides) < -e flags
    let mut merged_env = HashMap::new();
    for def in &header.arg_defs {
        if def.namespace.is_none()
            && let Some(ref env_name) = def.env
            && let Some(value) = arg_values.get(&def.name)
        {
            merged_env.insert(env_name.clone(), value.clone());
        }
    }
    merged_env.extend(extra_env);

    // Phase 4: lower with pre-loaded modules
    let (mut configs, _, module_args) = pman::lower_loaded(&modules, &merged_env, &arg_values)?;

    // Phase 5: activate triggered tasks
    for task_name in &task_names {
        let found = configs
            .iter_mut()
            .find(|c| c.is_task && c.name == *task_name);
        match found {
            Some(config) => config.autostart = true,
            None => {
                let available: Vec<&str> = configs
                    .iter()
                    .filter(|c| c.is_task)
                    .map(|c| c.name.as_str())
                    .collect();
                anyhow::bail!(
                    "unknown task '{task_name}'. available tasks: {}",
                    if available.is_empty() {
                        "(none)".to_string()
                    } else {
                        available.join(", ")
                    }
                );
            }
        }
    }

    if check {
        // Silent success — no output on valid config.
        return Ok(());
    }

    let (shutdown, signal_triggered) = signal::setup()?;

    let mut names: Vec<String> = configs.iter().map(|c| c.name.clone()).collect();
    names.insert(0, "procman".to_string());
    let logger = Arc::new(Mutex::new(log::Logger::new(
        &names,
        header.log_dir.as_deref(),
        header.log_time,
    )?));

    {
        let mut lg = logger.lock().unwrap();
        lg.log_line("procman", &format!("started with {} job(s)", configs.len()));
        for (module_name, args) in &module_args {
            lg.log_line("procman", &format!("args for {module_name}:"));
            for (key, value) in args {
                lg.log_line("procman", &format!("  {key} = {value}"));
            }
        }
    }

    let (tx, rx) = mpsc::channel::<config::SupervisorCommand>();

    let task_set: std::collections::HashSet<String> = task_names.into_iter().collect();
    let group = process::ProcessGroup::spawn(
        &configs,
        tx,
        Arc::clone(&shutdown),
        Arc::clone(&logger),
        debug,
        task_set,
    )?;
    let exit_code = group.wait_and_shutdown(shutdown, signal_triggered, rx, Arc::clone(&logger));

    logger.lock().unwrap().log_line(
        "procman",
        &format!("shutting down with exit code {exit_code}"),
    );

    std::process::exit(exit_code);
}

fn main() -> Result<()> {
    let cli = Cli::parse();
    let extra_env = parse_env_args(&cli.env)?;
    run_supervisor(
        cli.file,
        extra_env,
        cli.user_args,
        cli.tasks,
        cli.debug,
        cli.check,
    )
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn parse_env_args_valid() {
        let args = vec!["FOO=bar".to_string(), "BAZ=qux".to_string()];
        let map = parse_env_args(&args).unwrap();
        assert_eq!(map.get("FOO").unwrap(), "bar");
        assert_eq!(map.get("BAZ").unwrap(), "qux");
    }

    #[test]
    fn parse_env_args_empty_value() {
        let args = vec!["KEY=".to_string()];
        let map = parse_env_args(&args).unwrap();
        assert_eq!(map.get("KEY").unwrap(), "");
    }

    #[test]
    fn parse_env_args_missing_equals() {
        let args = vec!["NOEQUALS".to_string()];
        let err = parse_env_args(&args).unwrap_err().to_string();
        assert!(err.contains("KEY=VALUE"), "unexpected error: {err}");
    }

    #[test]
    fn parse_env_args_empty_key() {
        let args = vec!["=value".to_string()];
        let err = parse_env_args(&args).unwrap_err().to_string();
        assert!(err.contains("empty key"), "unexpected error: {err}");
    }

    #[test]
    fn parse_env_args_equals_in_value() {
        let args = vec!["URL=http://host:8080/path?a=1".to_string()];
        let map = parse_env_args(&args).unwrap();
        assert_eq!(map.get("URL").unwrap(), "http://host:8080/path?a=1");
    }

    #[test]
    fn check_flag_valid_pman() {
        let dir = tempfile::tempdir().unwrap();
        let path = dir.path().join("test.pman");
        std::fs::write(&path, r#"job web { run "echo hello" }"#).unwrap();
        let config_path = path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        assert!(result.is_ok());
    }

    #[test]
    fn check_flag_invalid_pman() {
        let dir = tempfile::tempdir().unwrap();
        let path = dir.path().join("bad.pman");
        std::fs::write(&path, "this is not valid pman syntax !!!").unwrap();
        let config_path = path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        assert!(result.is_err());
    }

    #[test]
    fn check_flag_with_imports() {
        let dir = tempfile::tempdir().unwrap();
        let db_path = dir.path().join("db.pman");
        std::fs::write(&db_path, r#"job migrate { run "migrate" }"#).unwrap();

        let root_path = dir.path().join("root.pman");
        std::fs::write(
            &root_path,
            r#"
            import "db.pman" as db
            service api {
                wait { after @db::migrate }
                run "serve"
            }
            "#,
        )
        .unwrap();

        let config_path = root_path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        assert!(result.is_ok(), "got: {}", result.unwrap_err());
    }

    #[test]
    fn check_flag_with_parameterized_imports() {
        let dir = tempfile::tempdir().unwrap();
        let db_path = dir.path().join("db.pman");
        std::fs::write(
            &db_path,
            r#"
            arg url { type = string }
            job migrate {
                env { DATABASE_URL = args.url }
                run "migrate"
            }
            "#,
        )
        .unwrap();

        let root_path = dir.path().join("root.pman");
        std::fs::write(
            &root_path,
            r#"
            import "db.pman" as db { url = "postgres://localhost/mydb" }
            service api {
                wait { after @db::migrate }
                run "serve"
            }
            "#,
        )
        .unwrap();

        let config_path = root_path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        assert!(result.is_ok(), "got: {}", result.unwrap_err());
    }

    #[test]
    fn check_flag_with_unbound_import_arg_from_cli() {
        let dir = tempfile::tempdir().unwrap();
        let db_path = dir.path().join("db.pman");
        std::fs::write(
            &db_path,
            r#"
            arg url { type = string }
            job migrate {
                env { DATABASE_URL = args.url }
                run "migrate"
            }
            "#,
        )
        .unwrap();

        let root_path = dir.path().join("root.pman");
        std::fs::write(
            &root_path,
            r#"
            import "db.pman" as db
            service api {
                wait { after @db::migrate }
                run "serve"
            }
            "#,
        )
        .unwrap();

        let config_path = root_path.to_str().unwrap().to_string();
        let user_args = vec![
            "--db::url".to_string(),
            "postgres://localhost/mydb".to_string(),
        ];
        let result = run_supervisor(config_path, HashMap::new(), user_args, vec![], false, true);
        assert!(result.is_ok(), "got: {}", result.unwrap_err());
    }

    #[test]
    fn check_flag_with_unbound_import_arg_missing() {
        let dir = tempfile::tempdir().unwrap();
        let db_path = dir.path().join("db.pman");
        std::fs::write(
            &db_path,
            r#"
            arg url { type = string }
            job migrate { run "migrate" }
            "#,
        )
        .unwrap();

        let root_path = dir.path().join("root.pman");
        std::fs::write(
            &root_path,
            r#"
            import "db.pman" as db
            job web { run "serve" }
            "#,
        )
        .unwrap();

        let config_path = root_path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        let err = result.unwrap_err().to_string();
        assert!(
            err.contains("required argument --db::url not provided"),
            "unexpected error: {err}"
        );
    }

    #[test]
    fn check_flag_with_task() {
        let dir = tempfile::tempdir().unwrap();
        let path = dir.path().join("test.pman");
        std::fs::write(&path, r#"task test_a { run "echo hello" }"#).unwrap();
        let config_path = path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        assert!(result.is_ok());
    }

    #[test]
    fn unknown_task_name_errors() {
        let dir = tempfile::tempdir().unwrap();
        let path = dir.path().join("test.pman");
        std::fs::write(&path, r#"task test_a { run "echo hello" }"#).unwrap();
        let config_path = path.to_str().unwrap().to_string();
        let result = run_supervisor(
            config_path,
            HashMap::new(),
            vec![],
            vec!["nonexistent".to_string()],
            false,
            false,
        );
        assert!(result.is_err());
        let err = result.unwrap_err().to_string();
        assert!(err.contains("unknown task"), "got: {err}");
    }

    #[test]
    fn check_flag_with_args_in_import_path() {
        let dir = tempfile::tempdir().unwrap();
        let sub = dir.path().join("deps");
        std::fs::create_dir(&sub).unwrap();
        std::fs::write(sub.join("db.pman"), r#"job migrate { run "migrate" }"#).unwrap();

        let root_path = dir.path().join("root.pman");
        std::fs::write(
            &root_path,
            r#"
            arg dep_dir { type = string }
            import "${args.dep_dir}/db.pman" as db
            service api {
                wait { after @db::migrate }
                run "serve"
            }
            "#,
        )
        .unwrap();

        let config_path = root_path.to_str().unwrap().to_string();
        let user_args = vec!["--dep-dir".to_string(), "deps".to_string()];
        let result = run_supervisor(config_path, HashMap::new(), user_args, vec![], false, true);
        assert!(result.is_ok(), "got: {}", result.unwrap_err());
    }

    #[test]
    fn check_flag_with_parameterized_import_no_args() {
        let dir = tempfile::tempdir().unwrap();
        let root_path = dir.path().join("root.pman");
        std::fs::write(
            &root_path,
            r#"
            arg dep_dir { type = string }
            import "${args.dep_dir}/db.pman" as db
            job web { run "serve" }
            "#,
        )
        .unwrap();

        // --check without providing --dep-dir should succeed (skip parameterized import)
        let config_path = root_path.to_str().unwrap().to_string();
        let result = run_supervisor(config_path, HashMap::new(), vec![], vec![], false, true);
        assert!(result.is_ok(), "got: {}", result.unwrap_err());
    }
}