From 754b064570c06f773fb47d335bf08cc92afffa31 Mon Sep 17 00:00:00 2001
From: Razvan Dimescu <ssaricu@gmail.com>
Date: Fri, 20 Mar 2026 15:07:42 +0200
Subject: [PATCH] fix rustfmt formatting

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 src/api.rs   | 15 +++++++++------
 src/proxy.rs | 12 +++---------
 2 files changed, 12 insertions(+), 15 deletions(-)

diff --git a/src/api.rs b/src/api.rs
index 467041b..a90ece0 100644
--- a/src/api.rs
+++ b/src/api.rs
@@ -604,7 +604,10 @@ async fn list_services(State(ctx): State<Arc<ServerCtx>>) -> Json<Vec<ServiceRes
     let tld = &ctx.proxy_tld;
 
     // Run all health checks concurrently
-    let health_futures: Vec<_> = entries.iter().map(|(_, port)| check_health(*port)).collect();
+    let health_futures: Vec<_> = entries
+        .iter()
+        .map(|(_, port)| check_health(*port))
+        .collect();
     let health_results = futures::future::join_all(health_futures).await;
 
     let results: Vec<_> = entries
@@ -628,7 +631,10 @@ async fn create_service(
 
     // Validate name: alphanumeric + hyphens only, 1-63 chars
     if name.is_empty() || name.len() > 63 {
-        return Err((StatusCode::BAD_REQUEST, "name must be 1-63 characters".into()));
+        return Err((
+            StatusCode::BAD_REQUEST,
+            "name must be 1-63 characters".into(),
+        ));
     }
     if !name.chars().all(|c| c.is_ascii_alphanumeric() || c == '-') {
         return Err((
@@ -655,10 +661,7 @@ async fn create_service(
     ))
 }
 
-async fn remove_service(
-    State(ctx): State<Arc<ServerCtx>>,
-    Path(name): Path<String>,
-) -> StatusCode {
+async fn remove_service(State(ctx): State<Arc<ServerCtx>>, Path(name): Path<String>) -> StatusCode {
     if name.eq_ignore_ascii_case("numa") {
         return StatusCode::FORBIDDEN;
     }
diff --git a/src/proxy.rs b/src/proxy.rs
index 53a7b37..9298483 100644
--- a/src/proxy.rs
+++ b/src/proxy.rs
@@ -48,9 +48,7 @@ pub async fn start_proxy(ctx: Arc<ServerCtx>, port: u16, tld: &str) {
         tld_suffix: format!(".{}", tld),
     };
 
-    let app = Router::new()
-        .fallback(any(proxy_handler))
-        .with_state(state);
+    let app = Router::new().fallback(any(proxy_handler)).with_state(state);
 
     axum::serve(listener, app).await.unwrap();
 }
@@ -62,10 +60,7 @@ fn extract_host(req: &Request) -> Option<String> {
         .map(|h| h.split(':').next().unwrap_or(h).to_lowercase())
 }
 
-async fn proxy_handler(
-    State(state): State<ProxyState>,
-    req: Request,
-) -> axum::response::Response {
+async fn proxy_handler(State(state): State<ProxyState>, req: Request) -> axum::response::Response {
     let hostname = match extract_host(&req) {
         Some(h) => h,
         None => {
@@ -179,8 +174,7 @@ async fn handle_upgrade(
     });
 
     // Return 101 to client with the backend's upgrade headers
-    let mut resp = axum::response::Response::builder()
-        .status(StatusCode::SWITCHING_PROTOCOLS);
+    let mut resp = axum::response::Response::builder().status(StatusCode::SWITCHING_PROTOCOLS);
     for (key, value) in &resp_headers {
         resp = resp.header(key, value);
     }