Style: Apply cargo fmt formatting

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: Tyler Gray

src-tauri/Cargo.lock

@@ -78,7 +78,10 @@ pub fn get_mcp(db: State<'_, Arc<Mutex<Database>>>, id: i64) -> Result<Mcp, Stri
 }
 
 #[tauri::command]
-pub fn create_mcp(db: State<'_, Arc<Mutex<Database>>>, mcp: CreateMcpRequest) -> Result<Mcp, String> {
+pub fn create_mcp(
+    db: State<'_, Arc<Mutex<Database>>>,
+    mcp: CreateMcpRequest,
+) -> Result<Mcp, String> {
     info!("[MCP] Creating new MCP: {}", mcp.name);
     let db_guard = db.lock().map_err(|e| {
         error!("[MCP] Failed to acquire database lock: {}", e);

src-tauri/src/commands/mcp.rs

@@ -120,20 +120,15 @@ pub fn get_gateway_connection_config(
 
 /// Get all MCPs configured for the gateway
 #[tauri::command]
-pub fn get_gateway_mcps(
-    db: State<'_, Arc<Mutex<Database>>>,
-) -> Result<Vec<GatewayMcp>, String> {
+pub fn get_gateway_mcps(db: State<'_, Arc<Mutex<Database>>>) -> Result<Vec<GatewayMcp>, String> {
     info!("[GatewayCmd] Getting gateway MCPs");
     let db = db.lock().map_err(|e| e.to_string())?;
     db.get_gateway_mcps().map_err(|e| e.to_string())
 }
 
 /// Add an MCP to the gateway
 #[tauri::command]
-pub fn add_mcp_to_gateway(
-    db: State<'_, Arc<Mutex<Database>>>,
-    mcp_id: i64,
-) -> Result<(), String> {
+pub fn add_mcp_to_gateway(db: State<'_, Arc<Mutex<Database>>>, mcp_id: i64) -> Result<(), String> {
     info!("[GatewayCmd] Adding MCP {} to gateway", mcp_id);
     let db = db.lock().map_err(|e| e.to_string())?;
     db.add_gateway_mcp(mcp_id).map_err(|e| e.to_string())
@@ -157,9 +152,13 @@ pub fn toggle_gateway_mcp(
     mcp_id: i64,
     enabled: bool,
 ) -> Result<(), String> {
-    info!("[GatewayCmd] Toggling gateway MCP {} to {}", mcp_id, enabled);
+    info!(
+        "[GatewayCmd] Toggling gateway MCP {} to {}",
+        mcp_id, enabled
+    );
     let db = db.lock().map_err(|e| e.to_string())?;
-    db.toggle_gateway_mcp(mcp_id, enabled).map_err(|e| e.to_string())
+    db.toggle_gateway_mcp(mcp_id, enabled)
+        .map_err(|e| e.to_string())
 }
 
 /// Set auto-restart for a gateway MCP
@@ -169,17 +168,18 @@ pub fn set_gateway_mcp_auto_restart(
     mcp_id: i64,
     auto_restart: bool,
 ) -> Result<(), String> {
-    info!("[GatewayCmd] Setting gateway MCP {} auto_restart to {}", mcp_id, auto_restart);
+    info!(
+        "[GatewayCmd] Setting gateway MCP {} auto_restart to {}",
+        mcp_id, auto_restart
+    );
     let db = db.lock().map_err(|e| e.to_string())?;
-    db.set_gateway_mcp_auto_restart(mcp_id, auto_restart).map_err(|e| e.to_string())
+    db.set_gateway_mcp_auto_restart(mcp_id, auto_restart)
+        .map_err(|e| e.to_string())
 }
 
 /// Check if an MCP is in the gateway
 #[tauri::command]
-pub fn is_mcp_in_gateway(
-    db: State<'_, Arc<Mutex<Database>>>,
-    mcp_id: i64,
-) -> Result<bool, String> {
+pub fn is_mcp_in_gateway(db: State<'_, Arc<Mutex<Database>>>, mcp_id: i64) -> Result<bool, String> {
     let db = db.lock().map_err(|e| e.to_string())?;
     db.is_mcp_in_gateway(mcp_id).map_err(|e| e.to_string())
 }

src-tauri/src/commands/mcp_gateway.rs

@@ -120,9 +120,7 @@ pub fn add_self_mcp_to_library(
 
 /// Remove the Tool Manager MCP from the library
 #[tauri::command]
-pub fn remove_self_mcp_from_library(
-    db: State<'_, Arc<Mutex<Database>>>,
-) -> Result<(), String> {
+pub fn remove_self_mcp_from_library(db: State<'_, Arc<Mutex<Database>>>) -> Result<(), String> {
     info!("[McpServerCmd] Removing Tool Manager MCP from library");
 
     let db = db.lock().map_err(|e| e.to_string())?;
@@ -136,11 +134,10 @@ pub fn remove_self_mcp_from_library(
 
 /// Check if the Tool Manager MCP is in the library
 #[tauri::command]
-pub fn is_self_mcp_in_library(
-    db: State<'_, Arc<Mutex<Database>>>,
-) -> Result<bool, String> {
+pub fn is_self_mcp_in_library(db: State<'_, Arc<Mutex<Database>>>) -> Result<bool, String> {
     let db = db.lock().map_err(|e| e.to_string())?;
-    let exists = db.get_mcp_by_name("Tool Manager MCP")
+    let exists = db
+        .get_mcp_by_name("Tool Manager MCP")
         .map(|opt| opt.is_some())
         .unwrap_or(false);
     Ok(exists)

src-tauri/src/commands/mcp_server.rs

@@ -86,7 +86,10 @@ pub fn start_mcp_session(
     // System MCPs (Tool Manager and Gateway) use Streamable HTTP transport
     if source == "system" {
         let mcp_url = url.ok_or_else(|| "System MCP requires a URL".to_string())?;
-        info!("[MCP Session] Starting Streamable HTTP session for system MCP: {}", name);
+        info!(
+            "[MCP Session] Starting Streamable HTTP session for system MCP: {}",
+            name
+        );
         return manager
             .start_streamable_http_session(mcp_id, &name, &mcp_url, headers.as_ref(), 60)
             .map_err(|e| e.to_string());

src-tauri/src/commands/mcp_session.rs

@@ -71,8 +71,15 @@ pub fn test_mcp(db: State<'_, Arc<Mutex<Database>>>, mcp_id: i64) -> Result<McpT
     // async SSE handling for full protocol test
     if source == "system" {
         let mcp_url = url.ok_or_else(|| "System MCP requires a URL".to_string())?;
-        info!("[MCP Test] Testing system MCP with Streamable HTTP: {}", mcp_url);
-        return Ok(mcp_client::test_streamable_http_mcp(&mcp_url, headers.as_ref(), 30));
+        info!(
+            "[MCP Test] Testing system MCP with Streamable HTTP: {}",
+            mcp_url
+        );
+        return Ok(mcp_client::test_streamable_http_mcp(
+            &mcp_url,
+            headers.as_ref(),
+            30,
+        ));
     }
 
     // Now the database lock is released, perform the test

src-tauri/src/commands/mcp_test.rs

@@ -259,7 +259,10 @@ pub fn toggle_project_mcp(
 }
 
 #[tauri::command]
-pub fn sync_project_config(db: State<'_, Arc<Mutex<Database>>>, project_id: i64) -> Result<(), String> {
+pub fn sync_project_config(
+    db: State<'_, Arc<Mutex<Database>>>,
+    project_id: i64,
+) -> Result<(), String> {
     use crate::services::opencode_config;
     use crate::utils::paths::get_claude_paths;
 

src-tauri/src/commands/projects.rs

@@ -108,7 +108,11 @@ pub fn remove_repo(db: State<'_, Arc<Mutex<Database>>>, id: i64) -> Result<(), S
 
 /// Toggle repository enabled status
 #[tauri::command]
-pub fn toggle_repo(db: State<'_, Arc<Mutex<Database>>>, id: i64, enabled: bool) -> Result<(), String> {
+pub fn toggle_repo(
+    db: State<'_, Arc<Mutex<Database>>>,
+    id: i64,
+    enabled: bool,
+) -> Result<(), String> {
     let db = db.lock().map_err(|e| e.to_string())?;
 
     db.conn()

src-tauri/src/commands/repos.rs

@@ -206,7 +206,10 @@ pub fn add_global_skill(db: State<'_, Arc<Mutex<Database>>>, skill_id: i64) -> R
 }
 
 #[tauri::command]
-pub fn remove_global_skill(db: State<'_, Arc<Mutex<Database>>>, skill_id: i64) -> Result<(), String> {
+pub fn remove_global_skill(
+    db: State<'_, Arc<Mutex<Database>>>,
+    skill_id: i64,
+) -> Result<(), String> {
     let db_guard = db.lock().map_err(|e| e.to_string())?;
 
     // Get the skill for file deletion

src-tauri/src/commands/skills.rs

@@ -167,7 +167,9 @@ pub fn delete_subagent(db: State<'_, Arc<Mutex<Database>>>, id: i64) -> Result<(
 
 // Global Sub-Agents
 #[tauri::command]
-pub fn get_global_subagents(db: State<'_, Arc<Mutex<Database>>>) -> Result<Vec<GlobalSubAgent>, String> {
+pub fn get_global_subagents(
+    db: State<'_, Arc<Mutex<Database>>>,
+) -> Result<Vec<GlobalSubAgent>, String> {
     let db = db.lock().map_err(|e| e.to_string())?;
     let mut stmt = db
         .conn()
@@ -197,7 +199,10 @@ pub fn get_global_subagents(db: State<'_, Arc<Mutex<Database>>>) -> Result<Vec<G
 }
 
 #[tauri::command]
-pub fn add_global_subagent(db: State<'_, Arc<Mutex<Database>>>, subagent_id: i64) -> Result<(), String> {
+pub fn add_global_subagent(
+    db: State<'_, Arc<Mutex<Database>>>,
+    subagent_id: i64,
+) -> Result<(), String> {
     let db_guard = db.lock().map_err(|e| e.to_string())?;
 
     // Get the subagent details for file writing