From 386be756584fe77bff3cd0528c9d5c24bf1fe98a Mon Sep 17 00:00:00 2001
From: iamdoubz <>
Date: Tue, 7 Jul 2026 00:29:52 -0500
Subject: [PATCH] style(mcp): rustfmt

---
 src-tauri/src/mcp/http_transport.rs | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/src-tauri/src/mcp/http_transport.rs b/src-tauri/src/mcp/http_transport.rs
index c831710..396b1a3 100644
--- a/src-tauri/src/mcp/http_transport.rs
+++ b/src-tauri/src/mcp/http_transport.rs
@@ -54,7 +54,11 @@ impl HttpServerHandle {
 /// routing) on an already-bound loopback listener. Every request must present
 /// `Authorization: Bearer <token>` matching the stored token (constant-time
 /// compare, `mcp::token::verify`) or it never reaches `rmcp`.
-pub(crate) fn serve(listener: TcpListener, expected_token: String, handler: WaMcpHandler) -> HttpServerHandle {
+pub(crate) fn serve(
+    listener: TcpListener,
+    expected_token: String,
+    handler: WaMcpHandler,
+) -> HttpServerHandle {
     let local_addr = listener
         .local_addr()
         .expect("a just-bound TcpListener has a local addr");
@@ -65,11 +69,7 @@ pub(crate) fn serve(listener: TcpListener, expected_token: String, handler: WaMc
         ..Default::default()
     };
     let session_manager = Arc::new(LocalSessionManager::default());
-    let service = StreamableHttpService::new(
-        move || Ok(handler.clone()),
-        session_manager,
-        config,
-    );
+    let service = StreamableHttpService::new(move || Ok(handler.clone()), session_manager, config);
 
     let accept_ct = shutdown.clone();
     let join = tokio::spawn(async move {
@@ -99,7 +99,11 @@ pub(crate) fn serve(listener: TcpListener, expected_token: String, handler: WaMc
         }
     });
 
-    HttpServerHandle { local_addr, shutdown, join }
+    HttpServerHandle {
+        local_addr,
+        shutdown,
+        join,
+    }
 }
 
 async fn handle_request(