fmt

bin/src/main.rs

@@ -117,11 +117,11 @@ fn main() {
                         let stream = hyper_util::rt::TokioIo::new(stream);
 
                         // Hyper has also its own `Service` trait and doesn't use tower. We can use
-                        // `hyper::service::service_fn` to create a hyper `Service` that calls our app through
-                        // `tower::Service::call`.
+                        // `hyper::service::service_fn` to create a hyper `Service` that calls our app
+                        // through `tower::Service::call`.
                         let hyper_service = hyper::service::service_fn(move |request: Request<Incoming>| {
-                            // We have to clone `tower_service` because hyper's `Service` uses `&self` whereas
-                            // tower's `Service` requires `&mut self`.
+                            // We have to clone `tower_service` because hyper's `Service` uses `&self`
+                            // whereas tower's `Service` requires `&mut self`.
                             //
                             // We don't need to call `poll_ready` since `Router` is always ready.
                             tower_service.clone().call(request)

db/src/common/res.rs

@@ -30,7 +30,7 @@ pub struct Res<T> {
 }
 
 /// 填入到extensions中的数据
-#[derive(Debug,Clone)]
+#[derive(Debug, Clone)]
 pub struct ResJsonString(pub String);
 
 #[allow(unconditional_recursion)]

middleware-fn/src/auth.rs

@@ -1,5 +1,5 @@
 use app_service::service_utils::ApiUtils;
-use axum::{http::StatusCode, middleware::Next, response::Response, extract::Request};
+use axum::{extract::Request, http::StatusCode, middleware::Next, response::Response};
 use configs::CFG;
 use db::common::ctx::{ReqCtx, UserInfoCtx};
 

middleware-fn/src/cache.rs

@@ -7,9 +7,10 @@ use std::{
 
 use app_service::service_utils::api_utils::ALL_APIS;
 use axum::{
+    extract::Request,
     http::StatusCode,
     middleware::Next,
-    response::{IntoResponse, Response}, extract::Request,
+    response::{IntoResponse, Response},
 };
 use configs::CFG;
 use db::common::{

middleware-fn/src/cache_skytable.rs

@@ -3,9 +3,10 @@ use std::{collections::BTreeMap, sync::Arc, time::Instant};
 
 use app_service::service_utils::api_utils::ALL_APIS;
 use axum::{
+    extract::Request,
     http::StatusCode,
     middleware::Next,
-    response::{IntoResponse, Response}, extract::Request,
+    response::{IntoResponse, Response},
 };
 use configs::CFG;
 use db::common::{

service/src/service_utils/jwt.rs

@@ -3,14 +3,13 @@ use axum::{
     // headers::{authorization::Bearer, Authorization},
     http::{request::Parts, StatusCode},
     response::{IntoResponse, Response},
-    Json, RequestPartsExt,
+    Json,
+    RequestPartsExt,
 };
 use axum_extra::TypedHeader;
-use headers::Authorization;
-use headers::authorization::Bearer;
-
 use chrono::{Duration, Local};
 use db::common::ctx::UserInfoCtx;
+use headers::{authorization::Bearer, Authorization};
 use jsonwebtoken::{decode, encode, errors::ErrorKind, DecodingKey, EncodingKey, Header, Validation};
 use once_cell::sync::Lazy;
 use serde::{Deserialize, Serialize};