gTickCheckerRust 0.1.2

TickChecker is a simple management tool for server cloud computing in any field to check whether the target service has survived.
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

use crate::action_factory::{ActionTrait, ActionData};
use log::*;
use simple_error::*;
use crate::action_do::{executor_fail, executor_recover};
use std::process::Command;

pub struct ActionPing {
    task:ActionData
}

impl ActionPing {
    fn ping_command(&self) -> String {
        let task_conf = &self.task.task_action;
        let r = if cfg!(target_os = "windows") {
            let ping_ms = task_conf.timeout.to_string();
            Command::new("cmd")
                .args(&["/C", "chcp 437","&&","ping","-w",&ping_ms,
                    task_conf.target.as_str()])
                .output()
        } else {
            let ping_timeout:f32 = (task_conf.timeout as f32 / 1000f32);
            let ping_timeout = ping_timeout.to_string();
            Command::new("sh")
                .arg("-c")
                .args(&["ping","-c4", "-w",&ping_timeout, task_conf.target.as_str()])
                .output()
        };

        match r {
            Ok(e) => {
                let rutf8 = String::from_utf8_lossy(e.stdout.as_slice());
                let to_str = rutf8.to_string();
                if cfg!(target_os = "windows") {
                    if to_str.contains("Request timed out") {
                        String::from("failed:Request timed out.")
                    }else {
                        to_str.replace("Active code page: 437", "")
                    }
                }else {
                    if to_str.contains("100% packet loss") {
                        String::from("failed:Request timed out.")
                    }else {
                        to_str
                    }
                }
            },
            Err(e) => {
                let error = format!("run command error:{}",e);
                error
            }
        }
    }
}

impl ActionTrait for ActionPing {
    fn id(&self) -> i32 {
        self.task.id
    }

    fn name(&self) -> &str {
        self.task.name.as_str()
    }

    fn append_data(&mut self, data: ActionData) {
        self.task = data;
    }

    fn executor(&mut self) {
        info!("start ping action:{} id:{}...",self.task.id,self.task.name);

        let task_conf = &self.task.task_action;
        // 开始PING
        let output = String::from(self.ping_command());
        if output.len() >= 0 && task_conf.output_result {
            if output.contains("failed") {
                warn!("ping task failed,run failed...");
                self.task.do_failed();
            }else {
                info!("ping result:{}",output);
                self.task.do_recover();
            }
        }
    }
}

pub fn new_ping(data: ActionData) -> ActionPing {
    ActionPing { task:data }
}