teaql-tool-extra 0.1.0

Heavy-dependency extra utilities for the TeaQL Tool ecosystem.
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

use teaql_tool_core::{Result, TeaQLToolError};
use notify::{Watcher, RecursiveMode};
use std::sync::mpsc::channel;

#[derive(Debug, Clone)]
pub struct WatcherTool;

impl WatcherTool {
    pub fn new() -> Self { Self }

    pub fn watch<F>(&self, path: &str, callback: F) -> Result<()> 
    where
        F: Fn(&str) + Send + Sync + 'static,
    {
        let (tx, rx) = channel();
        let mut watcher = notify::recommended_watcher(tx).map_err(|e| TeaQLToolError::ExecutionError(e.to_string()))?;
        
        watcher.watch(std::path::Path::new(path), RecursiveMode::Recursive)
            .map_err(|e| TeaQLToolError::ExecutionError(e.to_string()))?;
            
        println!("Watching path: {}", path);
        
        for res in rx {
            match res {
                Ok(event) => {
                    for p in event.paths {
                        callback(&p.to_string_lossy());
                    }
                },
                Err(e) => println!("Watch error: {:?}", e),
            }
        }
        
        Ok(())
    }
}

impl Default for WatcherTool {
    fn default() -> Self { Self::new() }
}