hni 0.0.3

ni-compatible package manager command router with node shim
Documentation 
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

use std::{path::Path, process::Command, thread};

use crate::{
    core::{
        detect::detect,
        resolve::{ResolveContext, version_command_for_pm},
    },
    platform::node::{REAL_NODE_ENV, path_with_real_node_priority, resolve_real_node_path},
};

pub fn print_versions(ctx: &ResolveContext) {
    println!("hni       v{}", env!("CARGO_PKG_VERSION"));

    let real_node = resolve_real_node_path().ok();
    let cwd = ctx.cwd().to_path_buf();
    let detected_cwd = cwd.clone();
    let detected_config = ctx.config.clone();
    let global = ctx.config.global_package_manager;

    let node_version_task = {
        let cwd = cwd.clone();
        let real_node = real_node.clone();
        thread::spawn(move || {
            real_node.as_ref().and_then(|path| {
                run_version(
                    path.to_string_lossy().to_string(),
                    vec!["--version".into()],
                    &cwd,
                    real_node.as_deref(),
                )
            })
        })
    };

    let detected_agent_task = {
        let real_node = real_node.clone();
        thread::spawn(move || {
            detect(&detected_cwd, &detected_config)
                .ok()
                .and_then(|detected| detected.agent.map(|agent| (agent, detected.source)))
                .map(|(agent, _)| {
                    let (program, args) = version_command_for_pm(agent);
                    let version = run_version(program, args, &detected_cwd, real_node.as_deref());
                    (agent, version)
                })
        })
    };

    let global_version_task = {
        let cwd = cwd.clone();
        let real_node = real_node.clone();
        thread::spawn(move || {
            let (program, args) = version_command_for_pm(global);
            run_version(program, args, &cwd, real_node.as_deref())
        })
    };

    let node_version = node_version_task.join().ok().flatten();
    if let Some(version) = node_version {
        println!("node       {version}");
    }

    match detected_agent_task.join().ok().flatten() {
        Some((agent, Some(version))) => {
            println!("agent      {} ({version})", agent.display_name());
        }
        Some((agent, None)) => {
            println!("agent      {}", agent.display_name());
        }
        None => {
            println!("agent      none");
        }
    }

    if let Some(version) = global_version_task.join().ok().flatten() {
        println!("global     {} ({version})", global.display_name());
    } else {
        println!("global     {}", global.display_name());
    }
}

fn run_version(
    program: String,
    args: Vec<String>,
    cwd: &Path,
    real_node: Option<&Path>,
) -> Option<String> {
    let mut command = Command::new(program);
    command.args(args).current_dir(cwd);

    if let Some(real_node) = real_node {
        command.env(REAL_NODE_ENV, real_node);
        if let Some(path) = path_with_real_node_priority(real_node, std::env::var_os("PATH")) {
            command.env("PATH", path);
        }
    }

    let output = command.output().ok()?;

    if !output.status.success() {
        return None;
    }

    let stdout = String::from_utf8_lossy(&output.stdout).trim().to_string();
    if stdout.is_empty() {
        None
    } else {
        Some(stdout)
    }
}