wrangler 1.21.0

Command-line interface for all things Cloudflare Workers
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

use notify::DebouncedEvent;
use std::{
    path::PathBuf,
    sync::mpsc::{Receiver, Sender},
    time::Duration,
};

use anyhow::{anyhow, Result};

use crate::terminal::message::{Message, StdOut};
use log::info;

// Add cooldown for all types of events to watching logic
pub fn wait_for_changes(
    rx: &Receiver<DebouncedEvent>,
    check_channel: Option<Sender<Option<()>>>,
    cooldown: Duration,
) -> Result<PathBuf> {
    loop {
        let event = rx.recv()?;
        // Sending a None to the channel will only succeed if there is a
        // receiver and return from this fn otherwise
        if let Some(check_channel) = &check_channel {
            check_channel.send(None)?;
        }
        match get_changed_path_from_event(event) {
            Ok(Some(path)) => {
                StdOut::working("Detected changes...");
                // wait for cooldown
                while rx.recv_timeout(cooldown).is_ok() {}
                return Ok(path);
            }
            Ok(None) => {
                continue; // was an event type we don't care about, continue
            }
            Err(error) => {
                StdOut::user_error(&format!("WatchError {:?}", error));
                continue;
            }
        };
    }
}

fn get_changed_path_from_event(event: DebouncedEvent) -> Result<Option<PathBuf>> {
    info!("Detected Event {:?}", event);
    match event {
        DebouncedEvent::Error(error, _) => Err(anyhow!(error)),
        DebouncedEvent::NoticeWrite(path) => Ok(Some(path)),
        DebouncedEvent::Write(path) => Ok(Some(path)),
        DebouncedEvent::NoticeRemove(path) => Ok(Some(path)),
        DebouncedEvent::Remove(path) => Ok(Some(path)),
        DebouncedEvent::Create(path) => Ok(Some(path)),
        _ => Ok(None),
    }
}