diff --git a/src/main.rs b/src/main.rs index a6f9d69..84da415 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,12 +1,16 @@ mod typing; -use axum::{routing::{get, post}, Router, Json}; use axum::http::StatusCode; +use axum::{ + routing::{get, post}, + Json, Router, +}; use typing::EventMessage; - -async fn event_rcv_handle(Json(form_data): Json) -> Result { +async fn event_rcv_handle( + Json(form_data): Json, +) -> Result { tokio::spawn(async move { println!("收到告警,向飞书推送消息"); reqwest::get(format!("https://www.feishu.cn/flow/api/trigger-webhook/31f13dead0bf78fc4bdb51ba23abba9f?title={}&content={}", &form_data.method, &form_data.params.send_time)).await @@ -22,6 +26,8 @@ async fn main() { .route("/eventRcv", post(event_rcv_handle)); // run our app with hyper, listening globally on port 3000 - let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap(); + let listener = tokio::net::TcpListener::bind("0.0.0.0:13000") + .await + .unwrap(); axum::serve(listener, app).await.unwrap(); } diff --git a/src/typing.rs b/src/typing.rs index ab6865d..989adce 100644 --- a/src/typing.rs +++ b/src/typing.rs @@ -39,4 +39,4 @@ pub struct Params { pub struct EventMessage { pub method: String, pub params: Params, -} \ No newline at end of file +}