style: run cargo fmt

Author: ZhiXiao-Lin

core/examples/default_implementations.rs

@@ -4,10 +4,10 @@
 //! context providers, and HITL confirmation.
 
 use a3s_code_core::{
-    Agent, SessionOptions,
     context::{FileSystemContextConfig, FileSystemContextProvider},
-    security::{DefaultSecurityProvider, DefaultSecurityConfig, SecurityProvider},
     hitl::{ConfirmationManager, ConfirmationPolicy},
+    security::{DefaultSecurityConfig, DefaultSecurityProvider, SecurityProvider},
+    Agent, SessionOptions,
 };
 use std::sync::Arc;
 use tokio::sync::broadcast;
@@ -60,12 +60,15 @@ async fn main() -> anyhow::Result<()> {
     println!("  - Timeout action: Reject\n");
 
     // 5. Create session with all default implementations
-    let session = agent.session(".", Some(
-        SessionOptions::new()
-            .with_security_provider(security_provider.clone())
-            .with_context_provider(fs_provider)
-            .with_confirmation_manager(confirmation_manager.clone())
-    ))?;
+    let session = agent.session(
+        ".",
+        Some(
+            SessionOptions::new()
+                .with_security_provider(security_provider.clone())
+                .with_context_provider(fs_provider)
+                .with_confirmation_manager(confirmation_manager.clone()),
+        ),
+    )?;
 
     println!("✓ Session created with all default implementations\n");
 
@@ -99,7 +102,9 @@ async fn main() -> anyhow::Result<()> {
         let pending = confirmation_manager_clone.pending_confirmations().await;
         if let Some((tool_id, tool_name, _)) = pending.first() {
             println!("  → User approved: {}", tool_name);
-            let _ = confirmation_manager_clone.confirm(tool_id, true, None).await;
+            let _ = confirmation_manager_clone
+                .confirm(tool_id, true, None)
+                .await;
         }
     });
 

core/examples/integration_tests.rs

@@ -31,7 +31,9 @@ async fn main() -> Result<()> {
                 .map(|p| p.join(".a3s/config.hcl"));
             project_root.filter(|p| p.exists())
         })
-        .expect("Config file not found. Please create ~/.a3s/config.hcl or use project .a3s/config.hcl");
+        .expect(
+            "Config file not found. Please create ~/.a3s/config.hcl or use project .a3s/config.hcl",
+        );
 
     println!("📄 Using config: {}", config_path.display());
     println!("{}", "=".repeat(80));
@@ -61,8 +63,12 @@ async fn main() -> Result<()> {
     // Test 7: Queue Configuration
     test_queue_config(&agent).await?;
 
-    println!("{}", "
-".repeat(2));
+    println!(
+        "{}",
+        "
+"
+        .repeat(2)
+    );
     println!("{}", "=".repeat(80));
     println!("✅ All integration tests completed successfully!");
     println!("{}", "=".repeat(80));
@@ -78,7 +84,9 @@ async fn test_basic_tools(agent: &Agent) -> Result<()> {
     let session = agent.session(".", None)?;
 
     println!("Testing: List current directory...");
-    let result = session.send("List the files in the current directory using ls", None).await?;
+    let result = session
+        .send("List the files in the current directory using ls", None)
+        .await?;
     println!("✓ Result preview: {}", truncate(&result.text, 200));
 
     println!("\nTesting: Read a file...");
@@ -94,17 +102,18 @@ async fn test_builtin_skills(agent: &Agent) -> Result<()> {
     println!("\n🧠 Test 2: Built-in Skills (7 skills)");
     println!("{}", "-".repeat(80));
 
-    let session = agent.session(".", Some(
-        SessionOptions::new()
-            .with_builtin_skills()
-    ))?;
+    let session = agent.session(".", Some(SessionOptions::new().with_builtin_skills()))?;
 
     println!("Testing: code-search skill...");
-    let result = session.send("Search for all functions named 'new' in Rust files", None).await?;
+    let result = session
+        .send("Search for all functions named 'new' in Rust files", None)
+        .await?;
     println!("✓ Result preview: {}", truncate(&result.text, 200));
 
     println!("\nTesting: builtin-tools skill...");
-    let result = session.send("What tools are available for file operations?", None).await?;
+    let result = session
+        .send("What tools are available for file operations?", None)
+        .await?;
     println!("✓ Result preview: {}", truncate(&result.text, 200));
 
     println!("\n✅ Test 2 passed: Built-in skills work correctly");
@@ -126,14 +135,18 @@ async fn test_file_operations(agent: &Agent) -> Result<()> {
     println!("✓ Result: {}", truncate(&result.text, 200));
 
     println!("\nTesting: Read the test file...");
-    let result = session.send("Read the file test_integration.txt", None).await?;
+    let result = session
+        .send("Read the file test_integration.txt", None)
+        .await?;
     println!("✓ Result: {}", truncate(&result.text, 200));
 
     println!("\nTesting: Edit the test file...");
-    let result = session.send(
-        "Edit test_integration.txt and replace 'Hello' with 'Greetings'",
-        None
-    ).await?;
+    let result = session
+        .send(
+            "Edit test_integration.txt and replace 'Hello' with 'Greetings'",
+            None,
+        )
+        .await?;
     println!("✓ Result: {}", truncate(&result.text, 200));
 
     println!("\nCleaning up: Remove test file...");
@@ -151,17 +164,18 @@ async fn test_search_operations(agent: &Agent) -> Result<()> {
     let session = agent.session(".", None)?;
 
     println!("Testing: grep search...");
-    let result = session.send(
-        "Search for the word 'Agent' in all Rust files using grep",
-        None
-    ).await?;
+    let result = session
+        .send(
+            "Search for the word 'Agent' in all Rust files using grep",
+            None,
+        )
+        .await?;
     println!("✓ Result preview: {}", truncate(&result.text, 200));
 
     println!("\nTesting: glob pattern matching...");
-    let result = session.send(
-        "Find all .rs files in the src directory using glob",
-        None
-    ).await?;
+    let result = session
+        .send("Find all .rs files in the src directory using glob", None)
+        .await?;
     println!("✓ Result preview: {}", truncate(&result.text, 200));
 
     println!("\n✅ Test 4 passed: Search operations work correctly");
@@ -200,11 +214,14 @@ async fn test_planning_mode(agent: &Agent) -> Result<()> {
     println!("\n🎯 Test 6: Planning Mode");
     println!("{}", "-".repeat(80));
 
-    let session = agent.session(".", Some(
-        SessionOptions::new()
-            .with_planning(true)
-            .with_goal_tracking(true)
-    ))?;
+    let session = agent.session(
+        ".",
+        Some(
+            SessionOptions::new()
+                .with_planning(true)
+                .with_goal_tracking(true),
+        ),
+    )?;
 
     println!("Testing: Multi-step task with planning...");
     let result = session.send(
@@ -225,7 +242,7 @@ async fn test_queue_config(agent: &Agent) -> Result<()> {
     println!("\n⚡ Test 7: Queue Configuration (A3S Lane v0.4.0)");
     println!("{}", "-".repeat(80));
 
-    use a3s_code_core::queue::{SessionQueueConfig, RetryPolicyConfig};
+    use a3s_code_core::queue::{RetryPolicyConfig, SessionQueueConfig};
 
     let queue_config = SessionQueueConfig {
         query_max_concurrency: 5,
@@ -241,16 +258,18 @@ async fn test_queue_config(agent: &Agent) -> Result<()> {
         ..Default::default()
     };
 
-    let session = agent.session(".", Some(
-        SessionOptions::new()
-            .with_queue_config(queue_config)
-    ))?;
+    let session = agent.session(
+        ".",
+        Some(SessionOptions::new().with_queue_config(queue_config)),
+    )?;
 
     println!("Testing: Parallel query operations with queue...");
-    let result = session.send(
-        "List all .rs files and count how many contain the word 'async'",
-        None
-    ).await?;
+    let result = session
+        .send(
+            "List all .rs files and count how many contain the word 'async'",
+            None,
+        )
+        .await?;
     println!("✓ Result preview: {}", truncate(&result.text, 200));
 
     println!("\n✅ Test 7 passed: Queue configuration works correctly");

core/examples/sdk_chat.rs

@@ -208,8 +208,7 @@ async fn main() -> anyhow::Result<()> {
     // ── 8. Per-session agent_dirs ────────────────────────────
     println!("\n--- Session with per-session agent_dirs ---");
     let tmp4 = tempfile::tempdir()?;
-    let opts2 = SessionOptions::new()
-        .with_agent_dir("/tmp/my-agents");
+    let opts2 = SessionOptions::new().with_agent_dir("/tmp/my-agents");
     match agent.session(tmp4.path().display().to_string(), Some(opts2)) {
         Ok(_session) => {
             println!("[ok] Session created with custom agent_dirs");

core/examples/session_workspace.rs

@@ -113,10 +113,7 @@ fn main() {
         "  Tokens: {} in / {} out / {} total",
         result.usage.prompt_tokens, result.usage.completion_tokens, result.usage.total_tokens
     );
-    println!(
-        "  Tool calls: {}",
-        result.tool_calls_count
-    );
+    println!("  Tool calls: {}", result.tool_calls_count);
     // The LLM should have used the read tool and found the number
     if result.text.contains("7742") {
         println!("  [ok] Magic number correctly extracted\n");
@@ -201,15 +198,24 @@ fn main() {
     println!();
     handle.abort();
 
-    println!("  Events: start={}, tool_use={}, end={}", saw_start, saw_tool, saw_end);
+    println!(
+        "  Events: start={}, tool_use={}, end={}",
+        saw_start, saw_tool, saw_end
+    );
     assert!(saw_start, "should receive Start event");
     assert!(saw_end, "should receive End event");
     let lower = stream_text.to_lowercase();
     if lower.contains("pineapple") {
         println!("  [ok] Secret word correctly extracted via streaming\n");
     } else {
-        println!("  [warn] Streaming response didn't contain 'pineapple', got: {}", stream_text.trim());
-        println!("  (Workspace is still wired — tool_use event: {})\n", saw_tool);
+        println!(
+            "  [warn] Streaming response didn't contain 'pineapple', got: {}",
+            stream_text.trim()
+        );
+        println!(
+            "  (Workspace is still wired — tool_use event: {})\n",
+            saw_tool
+        );
     }
 
     println!("=== All workspace checks passed ===");

core/examples/skills_demo.rs

@@ -3,7 +3,7 @@
 //! Demonstrates the Claude Code-compatible skill system.
 
 use a3s_code_core::{
-    skills::{Skill, SkillRegistry, builtin_skills},
+    skills::{builtin_skills, Skill, SkillRegistry},
     SessionOptions,
 };
 use std::sync::Arc;
@@ -106,7 +106,8 @@ You are a custom code analyzer. Look for specific patterns in the codebase.
 1. Use grep to search for patterns
 2. Read files to verify matches
 3. Report findings with file paths and line numbers
-"#.to_string(),
+"#
+        .to_string(),
         tags: vec!["analysis".to_string(), "custom".to_string()],
         version: Some("1.0.0".to_string()),
     };
@@ -136,19 +137,16 @@ You are a custom code analyzer. Look for specific patterns in the codebase.
     println!("------------------------------");
 
     // Method 1: Use built-in skills
-    let _options1 = SessionOptions::new()
-        .with_builtin_skills();
+    let _options1 = SessionOptions::new().with_builtin_skills();
     println!("✓ Created SessionOptions with built-in skills");
 
     // Method 2: Use custom registry
     let custom_registry = Arc::new(SkillRegistry::with_builtins());
-    let _options2 = SessionOptions::new()
-        .with_skill_registry(custom_registry);
+    let _options2 = SessionOptions::new().with_skill_registry(custom_registry);
     println!("✓ Created SessionOptions with custom registry");
 
     // Method 3: Load from directory
-    let _options3 = SessionOptions::new()
-        .with_skills_from_dir("core/skills");
+    let _options3 = SessionOptions::new().with_skills_from_dir("core/skills");
     println!("✓ Created SessionOptions with skills from directory");
     println!();