vig 0.4.0

Git TUI side-by-side diff viewer
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

use crate::core::event::Event;
use anyhow::Result;
use std::path::Path;
use std::sync::mpsc::Sender;
use std::time::Duration;

/// Debounce interval for filesystem change notifications.
const FS_DEBOUNCE: Duration = Duration::from_millis(500);

pub struct FsWatcher {
    _debouncer: notify_debouncer_mini::Debouncer<notify::RecommendedWatcher>,
}

impl FsWatcher {
    pub fn new(watch_path: &Path, tx: Sender<Event>) -> Result<Self> {
        let debouncer = notify_debouncer_mini::new_debouncer(
            FS_DEBOUNCE,
            move |events: Result<Vec<notify_debouncer_mini::DebouncedEvent>, notify::Error>| {
                if let Ok(events) = events {
                    let dominated_by_git_internal = events.iter().all(|e| {
                        let in_git = e.path.components().any(|c| c.as_os_str() == ".git");
                        let is_index = e.path.ends_with(".git/index");
                        let is_refs = e
                            .path
                            .components()
                            .zip(e.path.components().skip(1))
                            .any(|(a, b)| a.as_os_str() == ".git" && b.as_os_str() == "refs");
                        let is_packed_refs = e.path.ends_with("packed-refs");
                        in_git && !is_index && !is_refs && !is_packed_refs
                    });
                    // Skip if ALL events are .git-internal (except index changes)
                    if !dominated_by_git_internal {
                        let _ = tx.send(Event::FsChange);
                    }
                }
            },
        )?;

        let mut debouncer = debouncer;
        debouncer
            .watcher()
            .watch(watch_path, notify::RecursiveMode::Recursive)?;

        Ok(Self {
            _debouncer: debouncer,
        })
    }
}