chore: apply auto-fixes (fmt + clippy)

Author: zk

crates/aionui-ai-agent/src/factory/acp.rs

@@ -622,8 +622,8 @@ mod tests {
             "conv-acp",
             Arc::new(BroadcastEventBus::new(16)),
         )
-            .await
-            .expect("resolved command spec");
+        .await
+        .expect("resolved command spec");
 
         let expected = std::fs::canonicalize(runtime.path().join("bin").join("npx")).expect("canonical path");
         assert_eq!(spec.command, expected);

crates/aionui-ai-agent/src/factory/aionrs.rs

@@ -9,8 +9,8 @@ use aionui_api_types::{
 use aionui_common::AppError;
 use aionui_db::IMcpServerRepository;
 use aionui_db::models::McpServerRow;
-use aionui_runtime::ensure_runtime_command_with_reporter;
 use aionui_realtime::EventBroadcaster;
+use aionui_runtime::ensure_runtime_command_with_reporter;
 use tracing::{debug, info, warn};
 
 use crate::agent_task::AgentInstance;
@@ -59,14 +59,13 @@ pub(super) async fn build(
 
     let mut extra_mcp_servers = resolve_mcp_servers(&overrides, &ctx.conversation_id);
     if let Some(repo) = deps.mcp_server_repo.as_ref() {
-        for (name, config) in
-            load_user_mcp_servers(
-                repo.as_ref(),
-                overrides.mcp_server_ids.as_deref(),
-                &ctx.conversation_id,
-                deps.broadcaster.clone(),
-            )
-            .await
+        for (name, config) in load_user_mcp_servers(
+            repo.as_ref(),
+            overrides.mcp_server_ids.as_deref(),
+            &ctx.conversation_id,
+            deps.broadcaster.clone(),
+        )
+        .await
         {
             extra_mcp_servers.entry(name).or_insert(config);
         }
@@ -443,7 +442,8 @@ async fn session_server_to_mcp_server_config(
                 return Err("stdio: missing command".to_owned());
             }
             let entries: Vec<(String, String)> = env.iter().map(|(k, v)| (k.clone(), v.clone())).collect();
-            let (command, args, env) = ensure_stdio_launch(command, args, &entries, conversation_id, broadcaster).await?;
+            let (command, args, env) =
+                ensure_stdio_launch(command, args, &entries, conversation_id, broadcaster).await?;
             Ok(McpServerConfig {
                 transport: TransportType::Stdio,
                 command: Some(command),
@@ -621,9 +621,9 @@ fn guide_mcp_to_config(
 #[cfg(test)]
 mod tests {
     use super::*;
+    use aionui_realtime::BroadcastEventBus;
     use std::ffi::OsString;
     use std::sync::{Mutex, OnceLock};
-    use aionui_realtime::BroadcastEventBus;
 
     fn path_test_lock() -> &'static Mutex<()> {
         static LOCK: OnceLock<Mutex<()>> = OnceLock::new();

crates/aionui-ai-agent/src/runtime_status.rs

@@ -5,9 +5,7 @@ use aionui_api_types::{
     RuntimeStatusScopeKind, WebSocketMessage,
 };
 use aionui_realtime::EventBroadcaster;
-use aionui_runtime::{
-    NodeRuntimeFailureKind, NodeRuntimeProgress, SharedNodeRuntimeProgressReporter,
-};
+use aionui_runtime::{NodeRuntimeFailureKind, NodeRuntimeProgress, SharedNodeRuntimeProgressReporter};
 
 pub(crate) fn conversation_runtime_reporter(
     broadcaster: Arc<dyn EventBroadcaster>,

crates/aionui-mcp/src/routes.rs

@@ -145,7 +145,11 @@ async fn test_connection(
     let transport = McpServerTransport::from(req.transport);
     let result = state
         .connection_test_service
-        .test_connection_with_runtime_scope(&req.name, &transport, req.runtime_scope_id.as_deref().or(req.id.as_deref()))
+        .test_connection_with_runtime_scope(
+            &req.name,
+            &transport,
+            req.runtime_scope_id.as_deref().or(req.id.as_deref()),
+        )
         .await;
     if let Some(server_id) = req.id.as_deref() {
         state.config_service.persist_test_result(server_id, &result).await?;

crates/aionui-runtime/src/node_runtime/managed.rs

@@ -66,10 +66,7 @@ pub async fn install_and_validate_with_reporter(
     let spec = platform_spec().inspect_err(|error| {
         emit_progress(
             reporter,
-            NodeRuntimeProgress::failed(
-                NodeRuntimeFailureKind::UnsupportedPlatform,
-                error.to_string(),
-            ),
+            NodeRuntimeProgress::failed(NodeRuntimeFailureKind::UnsupportedPlatform, error.to_string()),
         );
     })?;
     let runtime_root = cache::node_runtime_root()
@@ -322,7 +319,10 @@ async fn install_archive(
 
     emit_progress(
         reporter,
-        NodeRuntimeProgress::extracting(format!("extracting managed Node runtime into {}", runtime_root.display())),
+        NodeRuntimeProgress::extracting(format!(
+            "extracting managed Node runtime into {}",
+            runtime_root.display()
+        )),
     );
     match spec.archive_ext {
         "tar.gz" => extract_tar_gz(&archive_path, runtime_root)?,
@@ -551,10 +551,7 @@ fn reqwest_error(stage: &str, url: &str, error: &reqwest::Error) -> NodeRuntimeE
 }
 
 fn timeout_error(stage: &str, url: &str, timeout: Duration) -> NodeRuntimeError {
-    NodeRuntimeError::managed_invalid(format!(
-        "{stage} timed out after {}s for {url}",
-        timeout.as_secs()
-    ))
+    NodeRuntimeError::managed_invalid(format!("{stage} timed out after {}s for {url}", timeout.as_secs()))
 }
 
 fn download_progress_message(url: &str, downloaded_bytes: u64, total_bytes: Option<u64>) -> String {
@@ -583,7 +580,8 @@ fn classify_error(error: &NodeRuntimeError) -> (NodeRuntimeFailureKind, Option<u
     if message.contains("unsupported") {
         return (NodeRuntimeFailureKind::UnsupportedPlatform, None);
     }
-    if message.contains("validate") || message.contains("executable missing") || message.contains("entrypoint missing") {
+    if message.contains("validate") || message.contains("executable missing") || message.contains("entrypoint missing")
+    {
         return (NodeRuntimeFailureKind::ValidationFailed, None);
     }
     if message.contains("download") || message.contains("extract") || message.contains("connect failed") {
@@ -595,17 +593,11 @@ fn classify_error(error: &NodeRuntimeError) -> (NodeRuntimeFailureKind, Option<u
 fn parse_http_status(message: &str) -> Option<u16> {
     let marker = "http ";
     let start = message.find(marker)? + marker.len();
-    let digits: String = message[start..]
-        .chars()
-        .take_while(|ch| ch.is_ascii_digit())
-        .collect();
+    let digits: String = message[start..].chars().take_while(|ch| ch.is_ascii_digit()).collect();
     digits.parse::<u16>().ok()
 }
 
-fn install_error(
-    error: NodeRuntimeError,
-    reporter: Option<&dyn NodeRuntimeProgressReporter>,
-) -> NodeRuntimeError {
+fn install_error(error: NodeRuntimeError, reporter: Option<&dyn NodeRuntimeProgressReporter>) -> NodeRuntimeError {
     let (kind, status_code) = classify_error(&error);
     emit_progress(
         reporter,
@@ -617,10 +609,7 @@ fn install_error(
     error
 }
 
-fn validation_error(
-    error: NodeRuntimeError,
-    reporter: Option<&dyn NodeRuntimeProgressReporter>,
-) -> NodeRuntimeError {
+fn validation_error(error: NodeRuntimeError, reporter: Option<&dyn NodeRuntimeProgressReporter>) -> NodeRuntimeError {
     emit_progress(
         reporter,
         NodeRuntimeProgress::failed(NodeRuntimeFailureKind::ValidationFailed, error.to_string()),

crates/aionui-runtime/src/node_runtime/mod.rs

@@ -158,9 +158,7 @@ async fn cached_managed_runtime_unreported() -> Option<ResolvedNodeRuntime> {
     cached_managed_runtime(None).await
 }
 
-async fn cached_managed_runtime(
-    reporter: Option<&dyn NodeRuntimeProgressReporter>,
-) -> Option<ResolvedNodeRuntime> {
+async fn cached_managed_runtime(reporter: Option<&dyn NodeRuntimeProgressReporter>) -> Option<ResolvedNodeRuntime> {
     let cached = managed_runtime_cache().lock().await.clone()?;
 
     match managed::validate_managed_runtime(&cached.root, reporter).await {

crates/aionui-system/src/lib.rs

@@ -4,8 +4,8 @@ pub mod client_pref;
 pub mod model_fetcher;
 pub mod protocol;
 pub mod provider;
-pub mod runtime_prepare;
 pub mod routes;
+pub mod runtime_prepare;
 pub mod settings;
 pub mod sysinfo;
 pub mod version;
@@ -15,7 +15,7 @@ pub use client_pref::ClientPrefService;
 pub use model_fetcher::ModelFetchService;
 pub use protocol::ProtocolDetectionService;
 pub use provider::ProviderService;
-pub use runtime_prepare::RuntimePrepareService;
 pub use routes::{SystemRouterState, settings_routes, system_routes};
+pub use runtime_prepare::RuntimePrepareService;
 pub use settings::SettingsService;
 pub use version::VersionCheckService;

crates/aionui-system/src/runtime_prepare.rs

@@ -21,10 +21,7 @@ impl RuntimePrepareService {
         Self { broadcaster }
     }
 
-    pub async fn ensure_node_runtime(
-        &self,
-        scope: RuntimeStatusScope,
-    ) -> Result<EnsureNodeRuntimeResponse, AppError> {
+    pub async fn ensure_node_runtime(&self, scope: RuntimeStatusScope) -> Result<EnsureNodeRuntimeResponse, AppError> {
         let reporter = self.runtime_reporter(scope);
         ensure_node_runtime_with_reporter(Some(reporter.as_ref()))
             .await

crates/aionui-system/tests/model_fetch_routes.rs

@@ -20,8 +20,8 @@ use aionui_db::{
 };
 use aionui_realtime::BroadcastEventBus;
 use aionui_system::{
-    ClientPrefService, ModelFetchService, ProtocolDetectionService, ProviderService, SettingsService,
-    RuntimePrepareService, SystemRouterState, VersionCheckService, system_routes,
+    ClientPrefService, ModelFetchService, ProtocolDetectionService, ProviderService, RuntimePrepareService,
+    SettingsService, SystemRouterState, VersionCheckService, system_routes,
 };
 
 // ---------------------------------------------------------------------------

crates/aionui-system/tests/protocol_detection_routes.rs

@@ -18,8 +18,8 @@ use aionui_db::{
     SqliteClientPreferenceRepository, SqliteProviderRepository, SqliteSettingsRepository, init_database_memory,
 };
 use aionui_system::{
-    ClientPrefService, ModelFetchService, ProtocolDetectionService, ProviderService, SettingsService,
-    RuntimePrepareService, SystemRouterState, VersionCheckService, system_routes,
+    ClientPrefService, ModelFetchService, ProtocolDetectionService, ProviderService, RuntimePrepareService,
+    SettingsService, SystemRouterState, VersionCheckService, system_routes,
 };
 
 // ---------------------------------------------------------------------------