watchmend 0.0.1

Watchmen is a daemon process manager that for you manage and keep your application online 24/7
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

use std::error::Error;

use crate::common::handle::{Command, Request, Response};
use tracing::info;

use crate::global;

pub async fn handle_exec(request: Request) -> Result<Response, Box<dyn Error>> {
    let req = request.clone();
    info!("Receive request: {:?}", req);
    let r = match request.command {
        Command::Run(task) => global::run(task).await,
        Command::Add(task) => global::add(task).await,
        Command::Reload(task) => global::reload(task).await,
        Command::Start(tf) => global::start(tf).await,
        Command::Restart(tf) => global::restart(tf).await,
        Command::Stop(tf) => global::stop(tf, true).await,
        Command::Remove(tf) => global::remove(tf, true).await,
        Command::Write(tf, data) => global::write(tf, data).await,
        Command::Pause(tf) => global::pause(tf).await,
        Command::Resume(tf) => global::resume(tf).await,
        Command::List(condition) => global::list(condition).await,
    };
    match r {
        Ok(res) => {
            info!("Request success: {:?}", req);
            Ok(res)
        }
        Err(e) => {
            info!("Request failed: {:?}, {}", req, e);
            Ok(Response::failed(e.to_string()))
        }
    }
}