mnem-cli 0.1.3

Command-line interface for mnem - git for knowledge graphs.
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

use super::*;

use crate::global::{self, RepoRegistry};

/// `mnem repos` subcommand - flat Subcommand enum matching the RemoteCmd/BranchCmd pattern.
#[derive(clap::Subcommand, Debug)]
pub(crate) enum ReposCmd {
    /// List all registered repos.
    List,
    /// Mark a repo path as the default for `mnem` without -R.
    SetDefault {
        /// Path to the repo directory (the parent of `.mnem/`).
        path: std::path::PathBuf,
    },
    /// Remove registry entries whose paths no longer exist on disk.
    Prune,
}

pub(crate) fn run(_override: Option<&Path>, cmd: ReposCmd) -> Result<()> {
    let global_dir = global::default_dir();

    match cmd {
        ReposCmd::List => cmd_list(&global_dir),
        ReposCmd::SetDefault { path } => cmd_set_default(&global_dir, &path),
        ReposCmd::Prune => cmd_prune(&global_dir),
    }
}

fn cmd_list(global_dir: &Path) -> Result<()> {
    if !global_dir.exists() {
        println!("No global mnem config found. Run `mnem integrate` to set one up.");
        return Ok(());
    }
    let reg = RepoRegistry::load(global_dir)?;
    if reg.repos.is_empty() {
        println!("No repos registered yet. Run `mnem init <path>` to register one.");
        return Ok(());
    }
    println!("Registered repos ({}):", reg.repos.len());
    for entry in &reg.repos {
        let marker = if entry.default { " *" } else { "  " };
        let label = entry
            .label
            .as_deref()
            .map(|l| format!("  [{l}]"))
            .unwrap_or_default();
        let exists = if entry.path.exists() {
            ""
        } else {
            "  (missing)"
        };
        println!("{marker} {}{label}{exists}", entry.path.display());
    }
    if let Some(d) = reg.default_repo() {
        println!("\n* = default ({})", d.path.display());
    }
    Ok(())
}

fn cmd_set_default(global_dir: &Path, path: &Path) -> Result<()> {
    if !global_dir.exists() {
        bail!(
            "No global mnem config found at {}. Run `mnem integrate` first.",
            global_dir.display()
        );
    }
    let mut reg = RepoRegistry::load(global_dir)?;
    let canon = path
        .canonicalize()
        .with_context(|| format!("resolving path {}", path.display()))?;
    reg.register(&canon, true);
    reg.save(global_dir)?;
    println!("Default repo set to: {}", canon.display());
    Ok(())
}

fn cmd_prune(global_dir: &Path) -> Result<()> {
    if !global_dir.exists() {
        println!("No global mnem config found. Nothing to prune.");
        return Ok(());
    }
    let mut reg = RepoRegistry::load(global_dir)?;
    let removed = reg.prune();
    if removed.is_empty() {
        println!("All registered repos still exist. Nothing pruned.");
    } else {
        reg.save(global_dir)?;
        println!(
            "Pruned {} stale entr{}:",
            removed.len(),
            if removed.len() == 1 { "y" } else { "ies" }
        );
        for p in &removed {
            println!("  - {}", p.display());
        }
    }
    Ok(())
}