resticular 0.1.12

use std::time::Duration;

use crate::error::Error;
use hotwatch::{
    blocking::{Flow, Hotwatch},
    Event,
};

use crate::{
    core::{
        config::Config,
        http::{ws::WsHandler, MsgHandler},
    },
    handle_thread_error, handle_thread_error_with_error, sub_process,
};

pub fn watch() -> Result<(), Error> {
    let config = Config::read_config()?;
    let mut hotwatch =
        Hotwatch::new_with_custom_delay(Duration::from_secs(1)).expect("Error hotwatch");
    hotwatch.watch(config.source, |event: Event| {
        let conf = Config::read_config().unwrap();
        let msg = MsgHandler::new();
        let ws = WsHandler::new("http://0.0.0.0:4200/");
        match event {
            Event::Create(e) => {
                println!("New: {}", e.to_str().unwrap());
                handle_thread_error_with_error!(
                    msg.send(crate::EyeKeeper::Changed),
                    Error::MsgError
                );
                handle_thread_error!(sub_process(&conf.source));
                ws.out();
                Flow::Continue
            }
            Event::Write(e) => {
                println!("Changed: {}", e.to_str().unwrap());

                handle_thread_error_with_error!(
                    msg.send(crate::EyeKeeper::Changed),
                    Error::MsgError
                );
                handle_thread_error!(sub_process(&conf.source));
                Flow::Continue
            }
            _ => Flow::Continue,
        }
    })?;
    hotwatch.run();
    Ok(())
}