litvc 1.2.1

Lit - The agentic-first distributed version control system. A complete Git replacement designed for AI agents first and humans second.
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
111
112
113
114
115
116
117
118
119
120
121
122
123
124

use crate::core::find_repo_root;
use crate::response::{WatchEvent, WatchResponse};
use std::collections::HashMap;
use std::fs;
use std::path::Path;
use std::time::SystemTime;
use walkdir::WalkDir;

pub fn execute(
    debounce_ms: u64,
    filter: Option<String>,
) -> Result<WatchResponse, crate::errors::LitError> {
    let repo_root = find_repo_root()?;

    // Build initial file state snapshot
    let mut last_state = scan_files(&repo_root, filter.as_deref())?;

    let debounce = std::time::Duration::from_millis(debounce_ms);

    eprintln!(
        "Watching {} for changes (Ctrl+C to stop)...",
        repo_root.display()
    );

    // Emit a start event as JSON on stdout
    let start_event = WatchEvent {
        event_type: "start".to_string(),
        path: repo_root.to_string_lossy().to_string(),
        timestamp: chrono::Utc::now().timestamp(),
    };
    println!(
        "{}",
        serde_json::to_string(&start_event).unwrap_or_default()
    );

    loop {
        std::thread::sleep(debounce);

        let current_state = scan_files(&repo_root, filter.as_deref())?;
        let mut events = Vec::new();

        // Detect modifications and creations
        for (path, mtime) in &current_state {
            match last_state.get(path) {
                Some(old_mtime) if old_mtime != mtime => {
                    events.push(WatchEvent {
                        event_type: "modified".to_string(),
                        path: path.clone(),
                        timestamp: chrono::Utc::now().timestamp(),
                    });
                }
                None => {
                    events.push(WatchEvent {
                        event_type: "created".to_string(),
                        path: path.clone(),
                        timestamp: chrono::Utc::now().timestamp(),
                    });
                }
                _ => {}
            }
        }

        // Detect deletions
        for path in last_state.keys() {
            if !current_state.contains_key(path) {
                events.push(WatchEvent {
                    event_type: "deleted".to_string(),
                    path: path.clone(),
                    timestamp: chrono::Utc::now().timestamp(),
                });
            }
        }

        // Emit events as JSONL
        for event in &events {
            println!("{}", serde_json::to_string(event).unwrap_or_default());
        }

        last_state = current_state;
    }
}

/// Scan files and return map of relative_path -> last_modified_timestamp
fn scan_files(repo_root: &Path, filter: Option<&str>) -> Result<HashMap<String, u64>, String> {
    let mut files = HashMap::new();

    for entry in WalkDir::new(repo_root).into_iter().filter_entry(|e| {
        let name = e.file_name().to_string_lossy();
        !name.starts_with('.') && name != "target" && name != "node_modules"
    }) {
        let entry = entry.map_err(|e| format!("Walk error: {}", e))?;
        if !entry.file_type().is_file() {
            continue;
        }
        let path = entry.path();
        if path.starts_with(repo_root.join(".lit")) {
            continue;
        }

        let rel_path = path
            .strip_prefix(repo_root)
            .unwrap_or(path)
            .to_string_lossy()
            .replace('\\', "/");

        // Apply filter if present
        if let Some(f) = filter {
            if !rel_path.contains(f) {
                continue;
            }
        }

        let mtime = fs::metadata(path)
            .and_then(|m| m.modified())
            .unwrap_or(SystemTime::UNIX_EPOCH)
            .duration_since(SystemTime::UNIX_EPOCH)
            .unwrap_or_default()
            .as_secs();

        files.insert(rel_path, mtime);
    }

    Ok(files)
}