watchctl 0.4.0

Process supervisor with wait, watch, and retry phases
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

use super::{Check, CheckFuture};
use std::path::PathBuf;

pub struct FileCheck {
    path: PathBuf,
    description: String,
}

impl FileCheck {
    pub fn new(path: impl Into<PathBuf>) -> Self {
        let path = path.into();
        let description = format!("file:{}", path.display());
        Self { path, description }
    }
}

impl Check for FileCheck {
    fn check(&self) -> CheckFuture<'_> {
        Box::pin(async move {
            if tokio::fs::metadata(&self.path).await.is_ok() {
                Ok(())
            } else {
                Err(format!("file {} does not exist", self.path.display()))
            }
        })
    }

    fn description(&self) -> &str {
        &self.description
    }
}