hi 0.1.18

hi with mail & wxpusher
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use std::{future::Future, pin::Pin};

use aok::Void;
use futures::{stream::FuturesUnordered, FutureExt, StreamExt};
pub mod lark;

genv::s!(HI_MAILTO, HI_NAME);

#[static_init::dynamic]
static WX_TOKEN_TOPIC_ID: (String, u64) =
  sonic_rs::from_slice(std::env::var("WxPush").expect("miss env WxPush").as_bytes())
    .expect("env WxPush invalid");

pub async fn send(title: impl AsRef<str>, txt: impl AsRef<str>, url: impl AsRef<str>) {
  let name: &str = HI_NAME.as_ref();
  let title = title.as_ref();
  let txt = txt.as_ref();
  let url = url.as_ref();

  let mut futures: FuturesUnordered<Pin<Box<dyn Future<Output = Void> + Send + 'static>>> =
    FuturesUnordered::new();

  futures.push(Box::pin(xsmtp::send(
    name,
    HI_MAILTO.as_ref(),
    title.to_owned(),
    if url.is_empty() {
      txt.to_owned()
    } else {
      url.to_owned() + "\n\n" + &txt
    },
    "",
  )));

  futures.push(
    wxpush::send(
      &WX_TOKEN_TOPIC_ID.0,
      [(&*WX_TOKEN_TOPIC_ID).1],
      title.to_owned(),
      txt.to_owned(),
      url.to_owned(),
    )
    .boxed(),
  );

  futures.push(lark::send(title.to_owned(), txt.to_owned(), url.to_owned()).boxed());

  while let Some(result) = futures.next().await {
    match result {
      Ok(_) => {}
      Err(err) => tracing::error!("{err}"),
    }
  }
}