fsmon 0.3.2

Lightweight High-Performance File System Change Tracking Tool
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

use anyhow::{Result, bail};
use fsmon::config::Config;
use fsmon::monitored::{CMD_GLOBAL, Monitored};
use fsmon::socket::{self, SocketCmd};
use std::path::PathBuf;

pub fn cmd_remove(cmd: Option<String>, paths: Vec<PathBuf>) -> Result<()> {
    let mut cfg = Config::load()?;
    cfg.resolve_paths()?;

    let mut store = Monitored::load(&cfg.monitored.path)?;

    // CMD is required. Use '_global' for global monitoring.
    let cmd_str = cmd.as_deref().ok_or_else(|| {
        anyhow::anyhow!(
            "CMD is required. Use '{}' for global monitoring.",
            CMD_GLOBAL
        )
    })?;

    match paths.as_slice() {
        // fsmon remove bash (no --path) → remove entire cmd group
        &[] => {
            if !store.remove_cmd_group(Some(cmd_str)) {
                bail!("Cmd group '{}' not found", cmd_str);
            }
        }
        // fsmon remove bash --path /a --path /b → remove from that cmd group
        ps => {
            // Atomic: check all paths exist first
            for p in ps {
                if !store.has_entry(p, Some(cmd_str)) {
                    bail!("Path '{}' not found under cmd '{}'", p.display(), cmd_str);
                }
            }
            let mut removed_any = false;
            for p in ps {
                if store.remove_entry(p, Some(cmd_str)) {
                    removed_any = true;
                }
            }
            if !removed_any {
                bail!("No entries removed (cmd group '{}')", cmd_str);
            }
        }
    }

    store.save(&cfg.monitored.path)?;
    eprintln!("Entry removed");

    // Try live update via socket (non-fatal if fails)
    let socket_path = cfg.socket.path.clone();
    for p in &paths {
        if socket::send_cmd(
            &socket_path,
            &SocketCmd {
                cmd: "remove".to_string(),
                path: Some(p.clone()),
                recursive: None,
                types: None,
                size: None,
                track_cmd: Some(cmd_str.to_string()),
            },
        )
        .is_err()
        {
            break;
        }
    }
    Ok(())
}