krik 0.1.21

A fast static site generator written in Rust with internationalization, theming, and modern web features
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

use notify::{Watcher, RecursiveMode, Event, EventKind};
use std::path::PathBuf;
use tokio::sync::mpsc::Sender;
use tracing::{debug, error};
use std::time::Duration;

pub async fn start_watcher(
    input_dir: PathBuf,
    theme_dir: Option<PathBuf>,
    tx: Sender<Event>,
) {
    tokio::task::spawn_blocking(move || {
        let mut watcher = match notify::recommended_watcher(move |res: Result<Event, notify::Error>| {
            if let Ok(event) = res {
                if matches!(event.kind, EventKind::Create(_) | EventKind::Modify(_) | EventKind::Remove(_)) {
                    debug!("notify event captured: kind={:?}, paths={:?}", event.kind, event.paths);
                    let _ = tx.blocking_send(event);
                }
            }
        }) {
            Ok(w) => w,
            Err(e) => {
                error!("file watcher creation failed: {}", e);
                return;
            }
        };

        if let Err(e) = watcher.watch(&input_dir, RecursiveMode::Recursive) {
            error!("failed to watch input directory {}: {}", input_dir.display(), e);
            return;
        }
        if let Some(ref theme_dir) = theme_dir {
            if let Err(e) = watcher.watch(theme_dir, RecursiveMode::Recursive) {
                error!("failed to watch theme directory {}: {}", theme_dir.display(), e);
            }
        }

        // Block this thread; notify uses blocking callbacks
        loop { std::thread::sleep(Duration::from_secs(3600)); }
    });
}