gw: cargo fmt

Author: kvinwang

gateway/src/proxy/port_attrs.rs

@@ -39,9 +39,7 @@ pub(crate) async fn should_send_pp(state: &Proxy, instance_id: &str, port: u16)
 async fn lazy_fetch(state: &Proxy, instance_id: &str) -> Result<BTreeMap<u16, PortFlags>> {
     let (ip, agent_port) = {
         let guard = state.lock();
-        let ip = guard
-            .instance_ip(instance_id)
-            .context("unknown instance")?;
+        let ip = guard.instance_ip(instance_id).context("unknown instance")?;
         (ip, guard.config.proxy.agent_port)
     };
 
@@ -59,10 +57,7 @@ async fn lazy_fetch(state: &Proxy, instance_id: &str) -> Result<BTreeMap<u16, Po
 async fn fetch_port_attrs(ip: Ipv4Addr, agent_port: u16) -> Result<BTreeMap<u16, PortFlags>> {
     let url = format!("http://{ip}:{agent_port}/prpc");
     let client = DstackGuestClient::new(PrpcClient::new(url));
-    let info = client
-        .info()
-        .await
-        .context("agent Info() rpc failed")?;
+    let info = client.info().await.context("agent Info() rpc failed")?;
     if info.tcb_info.is_empty() {
         // Legacy CVM with public_tcbinfo=false; we cannot inspect app-compose
         // remotely. Cache an empty map so we don't keep retrying.

gateway/src/proxy/tls_terminate.rs

@@ -13,8 +13,8 @@ use hyper::server::conn::http1;
 use hyper::service::service_fn;
 use hyper::{Request, Response, StatusCode};
 use hyper_util::rt::tokio::TokioIo;
-use rustls::version::{TLS12, TLS13};
 use proxy_protocol::ProxyHeader;
+use rustls::version::{TLS12, TLS13};
 use serde::Serialize;
 use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt as _, ReadBuf};
 use tokio::net::TcpStream;