ewe_devserver 0.0.2

The devserver implementation that allows easy wrapping of a reverse proxy server
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use derive_more::derive::From;
use tokio::sync::broadcast;

use crate::operators::Operator;
use ewe_watch_utils::watch_path;

#[derive(Debug, From)]
pub enum DirectoryWatcherError {
    FailedToFinishedCorrectly,
}

impl std::error::Error for DirectoryWatcherError {}

impl core::fmt::Display for DirectoryWatcherError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "{self:?}")
    }
}

pub struct DirectoryWatcher {
    pub directory: String,
    pub file_change_sender: broadcast::Sender<()>,
}

// -- Core Details

impl Operator for DirectoryWatcher {
    fn run(&self, mut cancel_signal: broadcast::Receiver<()>) -> crate::types::JoinHandle<()> {
        let sender_copy = self.file_change_sender.clone();
        let watch_callback = move |_, _, _, _| {
            sender_copy.send(()).expect("should deliver notification");
            Ok(())
        };

        let watcher_handler = watch_path(300, self.directory.clone(), true, watch_callback)
            .expect("should create watcher");

        let _ = tokio::spawn(async move {
            let _ = cancel_signal.recv().await;
            watcher_handler.1.stop();
        });

        tokio::task::spawn_blocking(move || match watcher_handler.0.join() {
            Ok(_) => Ok(()),
            Err(err) => {
                ewe_trace::error!("Failed to correct destroy directory watcher: {:?}", err);
                Err(Box::new(DirectoryWatcherError::FailedToFinishedCorrectly).into())
            }
        })
    }
}

// -- Constructors

impl DirectoryWatcher {
    pub fn new<S>(directory: S, file_change_sender: broadcast::Sender<()>) -> Self
    where
        S: Into<String>,
    {
        Self {
            directory: directory.into(),
            file_change_sender,
        }
    }
}