.rustfmt.toml

@@ -0,0 +1 @@
+max_width = 120

client/Cargo.toml

@@ -1,9 +1,9 @@
 [package]
 edition = "2021"
 name = "stat_client"
-version = "1.5.2"
+version = "1.5.3"
 
-rust-version = "1.60"
+rust-version = "1.62"
 
 authors = ["doge <doge.py@gmail.com>"]
 categories = ["monitoring-tools"]

client/src/grpc.rs

@@ -16,10 +16,7 @@ use crate::INTERVAL_MS;
 // TODO TLS
 
 pub async fn report(args: &Args, stat_base: &mut StatRequest) -> anyhow::Result<()> {
-    if !vec![stat_base.online4, stat_base.online6]
-        .iter()
-        .any(|&x| x)
-    {
+    if !vec![stat_base.online4, stat_base.online6].iter().any(|&x| x) {
         eprintln!("try get target network...");
         let addr = args.addr.replace("grpc://", "");
         let sock_addr = addr.to_socket_addrs()?.next().unwrap();
@@ -44,19 +41,16 @@ pub async fn report(args: &Args, stat_base: &mut StatRequest) -> anyhow::Result<
     }
     let token = MetadataValue::try_from(format!("{}@_@{}", auth_user, args.pass))?;
 
-    let channel = Channel::from_shared(args.addr.to_string())?
-        .connect()
-        .await?;
+    let channel = Channel::from_shared(args.addr.to_string())?.connect().await?;
     let timeout_channel = Timeout::new(channel, Duration::from_millis(3000));
 
-    let grpc_client =
-        ServerStatusClient::with_interceptor(timeout_channel, move |mut req: Request<()>| {
-            req.metadata_mut().insert("authorization", token.clone());
-            req.metadata_mut()
-                .insert("ssr-auth", MetadataValue::try_from(ssr_auth).unwrap());
+    let grpc_client = ServerStatusClient::with_interceptor(timeout_channel, move |mut req: Request<()>| {
+        req.metadata_mut().insert("authorization", token.clone());
+        req.metadata_mut()
+            .insert("ssr-auth", MetadataValue::try_from(ssr_auth).unwrap());
 
-            Ok(req)
-        });
+        Ok(req)
+    });
 
     loop {
         let stat_rt = sample_all(args, stat_base);