style: rustfmt reflow after client-mapping reconciliation port

Mechanical line-wrap changes from cargo fmt --all — resolver.resolve()
calls now exceed the 100-char width after the extra param added across
Phases 1-4 of the upstream-client-mapping-reconciliation port. No logic
changes.

Signed-off-by: crimsonsunset <jsangio1@gmail.com>

Author: crimsonsunset

apps/desktop/src-tauri/src/commands/oauth.rs

@@ -768,9 +768,7 @@ pub async fn register_api_key_client(
         .as_deref()
         .map(str::trim)
         .filter(|s| !s.is_empty())
-        .map(|s| {
-            uuid::Uuid::parse_str(s).map_err(|_| format!("Invalid locked_space_id: {s}"))
-        })
+        .map(|s| uuid::Uuid::parse_str(s).map_err(|_| format!("Invalid locked_space_id: {s}")))
         .transpose()?;
     if let Some(space_id) = locked_space {
         repo.set_locked_space(&client_id, Some(space_id))

apps/desktop/src-tauri/src/commands/workspace_binding.rs

@@ -8,9 +8,9 @@ use std::collections::{HashMap, HashSet};
 use std::sync::Arc;
 
 use mcpmux_core::{
-    normalize_optional_metadata, validate_workspace_root as validate_root, BindingType, DomainEvent,
-    FeatureSet, FeatureSetType, MemberMode, MemberType, ServerFeature, WorkspaceBinding,
-    WorkspaceRootValidation,
+    normalize_optional_metadata, validate_workspace_root as validate_root, BindingType,
+    DomainEvent, FeatureSet, FeatureSetType, MemberMode, MemberType, ServerFeature,
+    WorkspaceBinding, WorkspaceRootValidation,
 };
 use serde::{Deserialize, Serialize};
 use tauri::State;
@@ -411,8 +411,7 @@ pub async fn create_workspace_binding(
         .await
         .map_err(|e| e.to_string())?;
     if existing.iter().any(|b| {
-        b.binding_type == binding_type
-            && binding_scope_conflicts(b, &normalized, machine_id, None)
+        b.binding_type == binding_type && binding_scope_conflicts(b, &normalized, machine_id, None)
     }) {
         let noun = if binding_type == BindingType::Id {
             "client mapping"

crates/mcpmux-core/src/application/user_space_sync.rs

@@ -381,7 +381,11 @@ mod tests {
             fail_ids.extend(server_ids.iter().map(|id| (*id).to_string()));
         }
 
-        async fn get_server_by_server_id(&self, space_id: &str, server_id: &str) -> Option<InstalledServer> {
+        async fn get_server_by_server_id(
+            &self,
+            space_id: &str,
+            server_id: &str,
+        ) -> Option<InstalledServer> {
             self.servers
                 .read()
                 .await
@@ -401,7 +405,10 @@ mod tests {
             Ok(self.servers.read().await.clone())
         }
 
-        async fn list_for_space(&self, space_id: &str) -> crate::repository::RepoResult<Vec<InstalledServer>> {
+        async fn list_for_space(
+            &self,
+            space_id: &str,
+        ) -> crate::repository::RepoResult<Vec<InstalledServer>> {
             Ok(self
                 .servers
                 .read()
@@ -470,7 +477,10 @@ mod tests {
             Ok(())
         }
 
-        async fn list_enabled(&self, space_id: &str) -> crate::repository::RepoResult<Vec<InstalledServer>> {
+        async fn list_enabled(
+            &self,
+            space_id: &str,
+        ) -> crate::repository::RepoResult<Vec<InstalledServer>> {
             Ok(self
                 .servers
                 .read()
@@ -617,7 +627,10 @@ mod tests {
                 file_path: file_path.clone()
             }
         );
-        assert_eq!(adopted.server_name.as_deref(), Some("Home Assistant Config"));
+        assert_eq!(
+            adopted.server_name.as_deref(),
+            Some("Home Assistant Config")
+        );
     }
 
     #[tokio::test]

crates/mcpmux-gateway/src/admin/command_bridge/read.rs

@@ -428,12 +428,7 @@ pub async fn get_workspace_effective_features(
             binding.space_id,
             binding.feature_set_ids,
         ),
-        None => (
-            "unbound".to_string(),
-            None,
-            default_space.id,
-            vec![],
-        ),
+        None => ("unbound".to_string(), None, default_space.id, vec![]),
     };
 
     let space = ctx

crates/mcpmux-gateway/src/admin/handlers/read.rs

@@ -405,14 +405,10 @@ pub async fn get_workspace_effective_features(
     State(state): State<AdminState>,
     Query(query): Query<EffectiveFeaturesQuery>,
 ) -> Result<Json<Value>, ApiError> {
-    bridge::get_workspace_effective_features(
-        &state.bridge,
-        query.workspace_root,
-        query.machine_id,
-    )
-    .await
-    .map(ok)
-    .map_err(ApiError::from_bridge)
+    bridge::get_workspace_effective_features(&state.bridge, query.workspace_root, query.machine_id)
+        .await
+        .map(ok)
+        .map_err(ApiError::from_bridge)
 }
 
 pub async fn list_workspace_appearances(

crates/mcpmux-gateway/src/public_base_url.rs

@@ -33,8 +33,7 @@ pub fn normalize_public_url(url: &str) -> Result<String, String> {
     }
     if parsed.path() != "/" && !parsed.path().is_empty() {
         return Err(
-            "Public gateway URL must be an origin only, for example https://mcp.example.com"
-                .into(),
+            "Public gateway URL must be an origin only, for example https://mcp.example.com".into(),
         );
     }
 

crates/mcpmux-gateway/src/services/meta_tools/bind_workspace.rs

@@ -16,7 +16,9 @@ use super::registry::{MetaTool, MetaToolCall, MetaToolError};
 pub struct BindCurrentWorkspaceTool;
 
 /// Machine identity for this bind — header, then OAuth client machine, then gateway local.
-async fn effective_machine_for_bind(call: &MetaToolCall<'_>) -> Result<Option<Uuid>, MetaToolError> {
+async fn effective_machine_for_bind(
+    call: &MetaToolCall<'_>,
+) -> Result<Option<Uuid>, MetaToolError> {
     call.ctx
         .resolver
         .effective_machine_id(Some(call.client_id), call.request_machine_id)
@@ -39,11 +41,7 @@ async fn find_existing_binding_for_bind(
             .map_err(|e| MetaToolError::Internal(e.to_string()));
     }
     binding_repo
-        .find_longest_prefix_match(
-            space_id,
-            Some(client_id),
-            &[normalized.to_string()],
-        )
+        .find_longest_prefix_match(space_id, Some(client_id), &[normalized.to_string()])
         .await
         .map_err(|e| MetaToolError::Internal(e.to_string()))
 }
@@ -73,10 +71,7 @@ async fn bind_tool_result(input: BindToolResultInput<'_>) -> Result<CallToolResu
         )
         .await
         .map_err(|e| MetaToolError::Internal(e.to_string()))?;
-    let active = resolved
-        .feature_set_ids
-        .iter()
-        .any(|id| id == &fs_id_str);
+    let active = resolved.feature_set_ids.iter().any(|id| id == &fs_id_str);
 
     let mut body = json!({
         "ok": true,

crates/mcpmux-gateway/src/services/meta_tools/meta_tool_common.rs

@@ -58,7 +58,11 @@ pub(crate) async fn caller_space_id(call: &MetaToolCall<'_>) -> Result<Uuid, Met
     let resolved = call
         .ctx
         .resolver
-        .resolve(call.session_id, Some(call.client_id), call.request_machine_id)
+        .resolve(
+            call.session_id,
+            Some(call.client_id),
+            call.request_machine_id,
+        )
         .await?;
     if let Some(space_id) = resolved.space_id {
         return Ok(space_id);
@@ -76,7 +80,11 @@ pub(crate) async fn caller_resolution(
 ) -> Result<ResolvedFeatureSet, MetaToolError> {
     call.ctx
         .resolver
-        .resolve(call.session_id, Some(call.client_id), call.request_machine_id)
+        .resolve(
+            call.session_id,
+            Some(call.client_id),
+            call.request_machine_id,
+        )
         .await
         .map_err(|e| MetaToolError::Internal(e.to_string()))
 }

crates/mcpmux-gateway/src/services/meta_tools/set_workspace_root.rs

@@ -77,7 +77,11 @@ impl MetaTool for SetWorkspaceRootTool {
         let resolved = call
             .ctx
             .resolver
-            .resolve(Some(session_id), Some(call.client_id), call.request_machine_id)
+            .resolve(
+                Some(session_id),
+                Some(call.client_id),
+                call.request_machine_id,
+            )
             .await?;
 
         let space_id = resolved

crates/mcpmux-storage/src/repositories/workspace_binding_repository.rs

@@ -316,9 +316,10 @@ impl WorkspaceBindingRepository for SqliteWorkspaceBindingRepository {
         // Exact match only — no ancestor/prefix inheritance. A folder resolves
         // to a binding for THAT exact root, or to nothing.
         for root in candidate_roots {
-            if let Some(b) = bindings.iter().find(|b| {
-                b.binding_type == BindingType::Path && &b.workspace_root == root
-            }) {
+            if let Some(b) = bindings
+                .iter()
+                .find(|b| b.binding_type == BindingType::Path && &b.workspace_root == root)
+            {
                 return Ok(Some(b.clone()));
             }
         }