getdozer / dozer / 5869050642

pub fn watch(state: Arc<LiveState>, shutdown: ShutdownReceiver) -> Result<(), LiveError> {

    // setup debouncer

    let (tx, rx) = std::sync::mpsc::channel();

    let dir: std::path::PathBuf = std::env::current_dir()?;

    let mut debouncer = new_debouncer(Duration::from_millis(500), None, tx)?;

    let watcher = debouncer.watcher();

    watcher.watch(dir.as_path(), RecursiveMode::Recursive)?;

    debouncer

        .cache()

        .add_root(dir.as_path(), RecursiveMode::Recursive);

    let running = shutdown.get_running_flag().clone();

    loop {

        let event = rx.recv_timeout(Duration::from_millis(100));

        match event {

            Ok(result) => match result {

                Ok(_events) => {

                    build(state.clone())?;

                }

                Err(errors) => errors.iter().for_each(|error| info!("{error:?}")),

            },

            Err(e) => {

                if !running.load(std::sync::atomic::Ordering::Relaxed) {

                    break;

                }

                if e == std::sync::mpsc::RecvTimeoutError::Disconnected {

                    break;

                }

            }

        }

    }

    Ok(())

}

pub fn build(state: Arc<LiveState>) -> Result<(), LiveError> {

    state.set_dozer(None);

    state.broadcast()?;

    if let Err(res) = state.build() {

        state.set_error_message(Some(res.to_string()));

    } else {

        state.set_error_message(None);

    }

    state.broadcast()

}