style: cargo fmt

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

Author: hikejs

core/src/config.rs

@@ -611,10 +611,7 @@ fn eval_func_call(func_call: &hcl::expr::FuncCall) -> JsonValue {
                 let var_name = match arg {
                     hcl::Expression::String(s) => s.as_str(),
                     _ => {
-                        tracing::warn!(
-                            "env() expects a string argument, got: {:?}",
-                            arg
-                        );
+                        tracing::warn!("env() expects a string argument, got: {:?}", arg);
                         return JsonValue::Null;
                     }
                 };
@@ -1790,8 +1787,14 @@ mod tests {
         assert_eq!(env.get("SIMPLE").unwrap().as_str().unwrap(), "value");
 
         // These mangled keys must NOT exist
-        assert!(env.get("apiKey").is_none(), "env var key should not be camelCase'd");
-        assert!(env.get("APIKEY").is_none(), "env var key should not have underscores stripped");
+        assert!(
+            env.get("apiKey").is_none(),
+            "env var key should not be camelCase'd"
+        );
+        assert!(
+            env.get("APIKEY").is_none(),
+            "env var key should not have underscores stripped"
+        );
         assert!(env.get("anthropicApiKey").is_none());
 
         std::env::remove_var("A3S_TEST_SECRET");
@@ -1821,7 +1824,10 @@ mod tests {
 
         assert_eq!(env.get("MY_VAR").unwrap().as_str().unwrap(), "hello");
         assert_eq!(env.get("OTHER_VAR").unwrap().as_str().unwrap(), "world");
-        assert!(env.get("myVar").is_none(), "block env keys should not be camelCase'd");
+        assert!(
+            env.get("myVar").is_none(),
+            "block env keys should not be camelCase'd"
+        );
     }
 
     #[test]

core/src/security/default.rs

@@ -146,7 +146,11 @@ impl DefaultSecurityProvider {
 
         // Add custom patterns (user-provided — log and skip invalid regexes)
         for p in &config.custom_patterns {
-            match SensitivePattern::try_new(p.name.clone(), p.regex.as_str(), p.redaction_label.clone()) {
+            match SensitivePattern::try_new(
+                p.name.clone(),
+                p.regex.as_str(),
+                p.redaction_label.clone(),
+            ) {
                 Ok(pattern) => patterns.push(pattern),
                 Err(e) => tracing::warn!(
                     "Skipping invalid custom security pattern '{}': {}",

core/src/session/compaction.rs

@@ -70,7 +70,9 @@ pub(crate) async fn compact_messages(
             KEEP_RECENT_MESSAGES
         );
         let mut result = messages[..KEEP_INITIAL_MESSAGES.min(total)].to_vec();
-        let recent_start = total.saturating_sub(KEEP_RECENT_MESSAGES).max(KEEP_INITIAL_MESSAGES);
+        let recent_start = total
+            .saturating_sub(KEEP_RECENT_MESSAGES)
+            .max(KEEP_INITIAL_MESSAGES);
         result.extend_from_slice(&messages[recent_start..]);
         return Ok(Some(result));
     }

core/src/subagent.rs

@@ -670,7 +670,8 @@ permissions:
         // Verify rules are functional
         assert!(agent.permissions.allow[0].matches("read", &serde_json::json!({})));
         assert!(agent.permissions.allow[1].matches("grep", &serde_json::json!({})));
-        assert!(agent.permissions.allow[2].matches("Bash", &serde_json::json!({"command": "cargo build"})));
+        assert!(agent.permissions.allow[2]
+            .matches("Bash", &serde_json::json!({"command": "cargo build"})));
         assert!(agent.permissions.deny[0].matches("write", &serde_json::json!({})));
     }
 

core/src/tools/mod.rs

@@ -170,10 +170,7 @@ impl ToolExecutor {
                         .parent()
                         .and_then(|p| p.canonicalize().ok())
                         .ok_or_else(|| {
-                            std::io::Error::new(
-                                std::io::ErrorKind::NotFound,
-                                "parent not found",
-                            )
+                            std::io::Error::new(std::io::ErrorKind::NotFound, "parent not found")
                         })
                 });
 

core/src/tools/process.rs

@@ -14,19 +14,13 @@ pub(crate) async fn read_process_output(
     let stdout = match child.stdout.take() {
         Some(s) => s,
         None => {
-            return (
-                "Internal error: child stdout not piped".to_string(),
-                false,
-            );
+            return ("Internal error: child stdout not piped".to_string(), false);
         }
     };
     let stderr = match child.stderr.take() {
         Some(s) => s,
         None => {
-            return (
-                "Internal error: child stderr not piped".to_string(),
-                false,
-            );
+            return ("Internal error: child stderr not piped".to_string(), false);
         }
     };
 

core/src/tools/task.rs

@@ -132,8 +132,10 @@ impl TaskExecutor {
         // Register MCP tools so child agents can access MCP servers.
         if let Some(ref mcp) = self.mcp_manager {
             let all_tools = mcp.get_all_tools().await;
-            let mut by_server: std::collections::HashMap<String, Vec<crate::mcp::protocol::McpTool>> =
-                std::collections::HashMap::new();
+            let mut by_server: std::collections::HashMap<
+                String,
+                Vec<crate::mcp::protocol::McpTool>,
+            > = std::collections::HashMap::new();
             for (server, tool) in all_tools {
                 by_server.entry(server).or_default().push(tool);
             }