alive 0.1.4

use mysql to check is service alive
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

use aok::{Result, OK};
use mysql_macro::exe;

use crate::{Kind, Watch};

pub async fn ok(
  kind: &Kind,
  watch: &Watch,
  host: impl AsRef<str>,
  txt_gen: impl FnOnce() -> String, // txt
  url: impl AsRef<str>,
) -> Result<()> {
  let mut sql = vec!["UPDATE watch SET "];
  if watch.err > kind.warnErr as u32 {
    let host = host.as_ref();
    let url = url.as_ref();
    let txt = txt_gen();
    let dns_type = watch.dns_type;
    let kind_v = &kind.v;
    let err_duration = crate::err_duration(watch.id).await?;
    let title = format!("{kind_v} ✅ {host} ( IPV{dns_type} 恢复正常, 耗时 {err_duration})");
    hi::send(title, txt, url).await;
    sql.push("err=0,");
  }
  let wid = format!(
    "ts={} WHERE id={}",
    sts::sec() + kind.duration as u64,
    watch.id
  );
  sql.push(&wid);
  exe!(sql.join(""));
  OK
}