mdfried 0.22.0

A markdown viewer for the terminal that renders images and big headers
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

use std::{
    cell::Cell,
    fs,
    path::PathBuf,
    sync::mpsc::Sender,
    time::{Duration, SystemTime},
};

use notify::{RecommendedWatcher, RecursiveMode};
use notify_debouncer_mini::{DebounceEventResult, Debouncer, new_debouncer};

use crate::{Event, error::Error};

// Should take `tx: Sender<Event>` but that complains about some weird lifetime stuff.
pub fn watch(
    path: &PathBuf,
    tx: Sender<Event>,
    debounce_milliseconds: u64,
) -> Result<Debouncer<RecommendedWatcher>, Error> {
    let parent = path
        .parent()
        .ok_or(Error::Watch("cannot watch without path".to_owned()))?
        .to_owned();
    let filename = path
        .file_name()
        .ok_or(Error::Watch(
            "could not get filename part of path".to_owned(),
        ))?
        .to_owned();

    let mtime = Some(fs::metadata(path).and_then(|m| m.modified())?);
    let last_mtime: Cell<Option<SystemTime>> = Cell::new(mtime);
    let mtime_path = path.clone();

    // I can't believe we need to do this mtime check!
    // mtime resolution by platform heuristics:
    // - NTFS (Windows): 100ns - fine
    // - FAT32:          2s    - two quick saves could collapse
    // - APFS (macOS):   1ns   - fine
    // - HFS+ (old mac): 1s    - rare edge case
    // - ext4 (Linux):   1ns   - fine
    // - NFS/SMB:        varies, can lag on network mounts

    let mut debouncer = new_debouncer(
        Duration::from_millis(debounce_milliseconds),
        move |res: DebounceEventResult| match res {
            Ok(events) => {
                let dominated = events.iter().any(|e| e.path.file_name() == Some(&filename));
                if !dominated {
                    return;
                }

                let mtime = fs::metadata(&mtime_path).and_then(|m| m.modified()).ok();
                if mtime == last_mtime.get() {
                    return;
                }
                last_mtime.set(mtime);
                log::warn!("watch mtime changed, Cmd::FileChanged");
                if let Err(err) = tx.send(Event::FileChanged) {
                    log::error!("Failed to send Cmd::FileChanged: {err}");
                }
            }
            Err(err) => {
                log::error!("DebounceEventResult error: {err}");
            }
        },
    )?;
    log::info!("notify is watching {path:?}");
    debouncer
        .watcher()
        .watch(&parent, RecursiveMode::NonRecursive)?;
    Ok(debouncer)
}