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

use crate::app::Task;
use crate::app::{ExternalMsg, MsgIn};
use anyhow::Result;
use notify::{watcher, RecursiveMode, Watcher};
use std::sync::mpsc::{channel, Receiver, Sender};
use std::thread;
use std::time::Duration;

pub fn keep_watching(
    pwd: &str,
    tx_msg_in: Sender<Task>,
    rx_pwd_watcher: Receiver<String>,
) -> Result<()> {
    let (tx, rx) = channel();
    let mut watcher = watcher(tx, Duration::from_secs(1))?;
    watcher.watch(pwd, RecursiveMode::NonRecursive)?;

    let mut last_pwd = pwd.to_string();
    thread::spawn(move || loop {
        if let Ok(new_pwd) = rx_pwd_watcher.try_recv() {
            watcher.unwatch(&last_pwd).unwrap_or_else(|e| {
                tx_msg_in
                    .send(Task::new(
                        MsgIn::External(ExternalMsg::LogError(e.to_string())),
                        None,
                    ))
                    .unwrap();
            });
            watcher
                .watch(&new_pwd, RecursiveMode::NonRecursive)
                .unwrap_or_else(|e| {
                    tx_msg_in
                        .send(Task::new(
                            MsgIn::External(ExternalMsg::LogError(e.to_string())),
                            None,
                        ))
                        .unwrap();
                });
            last_pwd = new_pwd;
        } else {
            thread::sleep(Duration::from_secs(1));
        }

        if rx.try_recv().is_ok() {
            let msg = MsgIn::External(ExternalMsg::Explore);
            tx_msg_in.send(Task::new(msg, None)).unwrap();
        } else {
            thread::sleep(Duration::from_secs(1));
        }
    });
    Ok(())
}