Run cargo fmt to fix formatting across codebase

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

Author: haasonsaas

.claude/worktrees/agent-a85b36dc

@@ -0,0 +1 @@
+Subproject commit 41717c3cf1d84d80b850946c956e3f32d1c9a3c3

src/adapters/anthropic.rs

@@ -81,7 +81,6 @@ impl AnthropicAdapter {
             retry_config,
         })
     }
-
 }
 
 #[async_trait]
@@ -407,4 +406,3 @@ mod tests {
         assert!(result.is_ok());
     }
 }
-

src/adapters/common.rs

@@ -47,7 +47,10 @@ where
                 let status = response.status();
                 let body = response.text().await.unwrap_or_default();
                 if is_retryable_status(status) && attempt < max_retries {
-                    sleep(Duration::from_millis(base_delay_ms.saturating_mul(attempt as u64 + 1))).await;
+                    sleep(Duration::from_millis(
+                        base_delay_ms.saturating_mul(attempt as u64 + 1),
+                    ))
+                    .await;
                     continue;
                 }
 
@@ -62,7 +65,10 @@ where
             }
             Err(err) => {
                 if attempt < max_retries {
-                    sleep(Duration::from_millis(base_delay_ms.saturating_mul(attempt as u64 + 1))).await;
+                    sleep(Duration::from_millis(
+                        base_delay_ms.saturating_mul(attempt as u64 + 1),
+                    ))
+                    .await;
                     continue;
                 }
                 return Err(err.into());
@@ -126,7 +132,7 @@ fn is_private_or_loopback(ip: IpAddr) -> bool {
             v4.is_loopback()          // 127.0.0.0/8
                 || v4.is_unspecified() // 0.0.0.0
                 || v4.is_private()     // 10.0.0.0/8, 172.16.0.0/12, 192.168.0.0/16
-                || v4.is_link_local()  // 169.254.0.0/16
+                || v4.is_link_local() // 169.254.0.0/16
         }
         IpAddr::V6(v6) => {
             v6.is_loopback()           // ::1

src/adapters/ollama.rs

@@ -138,7 +138,13 @@ impl OllamaAdapter {
             name: self.model_name_bare().to_string(),
         };
 
-        let response = self.client.post(&url).json(&show_request).send().await.ok()?;
+        let response = self
+            .client
+            .post(&url)
+            .json(&show_request)
+            .send()
+            .await
+            .ok()?;
 
         if !response.status().is_success() {
             return None;
@@ -296,7 +302,12 @@ mod tests {
             .mock("POST", "/api/chat")
             .with_status(200)
             .with_header("content-type", "application/json")
-            .with_body(chat_response_body_with_usage("test response", "codellama", 10, 5))
+            .with_body(chat_response_body_with_usage(
+                "test response",
+                "codellama",
+                10,
+                5,
+            ))
             .create_async()
             .await;
 
@@ -328,8 +339,7 @@ mod tests {
             .create_async()
             .await;
 
-        let adapter =
-            OllamaAdapter::new(test_config(&server.url(), "ollama:codellama")).unwrap();
+        let adapter = OllamaAdapter::new(test_config(&server.url(), "ollama:codellama")).unwrap();
         let result = adapter.complete(test_request()).await;
 
         assert!(result.is_ok());
@@ -599,8 +609,7 @@ mod tests {
             .create_async()
             .await;
 
-        let adapter =
-            OllamaAdapter::new(test_config(&server.url(), "ollama:codellama")).unwrap();
+        let adapter = OllamaAdapter::new(test_config(&server.url(), "ollama:codellama")).unwrap();
         let result = adapter.detect_context_window().await;
 
         assert_eq!(result, Some(8192));
@@ -723,10 +732,7 @@ mod tests {
 
     #[test]
     fn test_parse_num_ctx_missing() {
-        assert_eq!(
-            parse_num_ctx(Some("temperature 0.8\nstop [INST]")),
-            None
-        );
+        assert_eq!(parse_num_ctx(Some("temperature 0.8\nstop [INST]")), None);
     }
 
     #[test]

src/adapters/openai.rs

@@ -125,7 +125,6 @@ impl OpenAIAdapter {
             retry_config,
         })
     }
-
 }
 
 #[async_trait]

src/commands/doctor.rs

@@ -43,9 +43,7 @@ pub async fn doctor_command(config: Config) -> Result<()> {
 
     // Endpoint reachability
     print!("Checking endpoint {}... ", base_url);
-    let client = Client::builder()
-        .timeout(Duration::from_secs(5))
-        .build()?;
+    let client = Client::builder().timeout(Duration::from_secs(5)).build()?;
 
     // Try Ollama /api/tags first
     let ollama_url = format!("{}/api/tags", base_url);
@@ -136,7 +134,10 @@ pub async fn doctor_command(config: Config) -> Result<()> {
                 if let Some(ctx_size) =
                     detect_model_context_window(&client, &base_url, &recommended.name).await
                 {
-                    println!("  Context window: {} tokens (detected from model)", ctx_size);
+                    println!(
+                        "  Context window: {} tokens (detected from model)",
+                        ctx_size
+                    );
                 }
             }
 
@@ -154,9 +155,7 @@ pub async fn doctor_command(config: Config) -> Result<()> {
             // Test inference
             let recommended_name = recommended.name.clone();
             print!("\nTesting model {}... ", recommended_name);
-            let test_client = Client::builder()
-                .timeout(Duration::from_secs(10))
-                .build()?;
+            let test_client = Client::builder().timeout(Duration::from_secs(10)).build()?;
             let test_start = std::time::Instant::now();
             let test_result =
                 test_model_inference(&test_client, &base_url, &recommended_name, endpoint_type)
@@ -165,8 +164,7 @@ pub async fn doctor_command(config: Config) -> Result<()> {
 
             match test_result {
                 Ok(response) => {
-                    let tokens_per_sec =
-                        estimate_tokens(&response) as f64 / elapsed.as_secs_f64();
+                    let tokens_per_sec = estimate_tokens(&response) as f64 / elapsed.as_secs_f64();
                     println!(
                         "OK ({:.1}s, ~{:.0} tok/s)",
                         elapsed.as_secs_f64(),
@@ -369,7 +367,10 @@ fn check_system_resources() {
                 let cpu = String::from_utf8_lossy(&output.stdout);
                 let cpu = cpu.trim();
                 if cpu.contains("Apple") {
-                    println!("  Chip: {} (unified memory, GPU acceleration available)", cpu);
+                    println!(
+                        "  Chip: {} (unified memory, GPU acceleration available)",
+                        cpu
+                    );
                 }
             }
         }
@@ -592,7 +593,8 @@ mod tests {
     #[tokio::test]
     async fn test_detect_context_window_from_parameters() {
         // Simulate Ollama /api/show response with parameters field
-        let json = r#"{"parameters":"stop [INST]\nstop [/INST]\nnum_ctx 4096\nrepeat_penalty 1.1"}"#;
+        let json =
+            r#"{"parameters":"stop [INST]\nstop [/INST]\nnum_ctx 4096\nrepeat_penalty 1.1"}"#;
         let value: serde_json::Value = serde_json::from_str(json).unwrap();
         let mut result = None;
         if let Some(params) = value.get("parameters").and_then(|p| p.as_str()) {

src/commands/eval.rs

@@ -779,13 +779,21 @@ impl EvalPattern {
         }
 
         if let Some(severity) = &self.severity {
-            if !comment.severity.to_string().eq_ignore_ascii_case(severity.trim()) {
+            if !comment
+                .severity
+                .to_string()
+                .eq_ignore_ascii_case(severity.trim())
+            {
                 return false;
             }
         }
 
         if let Some(category) = &self.category {
-            if !comment.category.to_string().eq_ignore_ascii_case(category.trim()) {
+            if !comment
+                .category
+                .to_string()
+                .eq_ignore_ascii_case(category.trim())
+            {
                 return false;
             }
         }

src/commands/misc.rs

@@ -211,10 +211,7 @@ pub async fn feedback_command(
     Ok(())
 }
 
-fn apply_feedback_accept(
-    store: &mut review::FeedbackStore,
-    comments: &[core::Comment],
-) -> usize {
+fn apply_feedback_accept(store: &mut review::FeedbackStore, comments: &[core::Comment]) -> usize {
     let mut updated = 0;
     for comment in comments {
         let is_new = store.accept.insert(comment.id.clone());
@@ -229,10 +226,7 @@ fn apply_feedback_accept(
     updated
 }
 
-fn apply_feedback_reject(
-    store: &mut review::FeedbackStore,
-    comments: &[core::Comment],
-) -> usize {
+fn apply_feedback_reject(store: &mut review::FeedbackStore, comments: &[core::Comment]) -> usize {
     let mut updated = 0;
     for comment in comments {
         let is_new = store.suppress.insert(comment.id.clone());
@@ -428,7 +422,9 @@ mod tests {
             apply_feedback_accept(&mut store, &comments);
         }
 
-        let key = review::classify_comment_type(&comments[0]).as_str().to_string();
+        let key = review::classify_comment_type(&comments[0])
+            .as_str()
+            .to_string();
         let stats = &store.by_comment_type[&key];
         assert_eq!(
             stats.accepted, 1,

src/commands/mod.rs

@@ -1,17 +1,15 @@
-mod review;
-mod smart_review;
-mod git;
-mod pr;
+mod doctor;
 mod eval;
+mod git;
 mod misc;
-mod doctor;
+mod pr;
+mod review;
+mod smart_review;
 
-pub use review::{review_command, check_command, compare_command};
-pub use smart_review::smart_review_command;
+pub use doctor::doctor_command;
+pub use eval::{eval_command, EvalRunOptions};
 pub use git::{git_command, GitCommands};
+pub use misc::{changelog_command, discuss_command, feedback_command, lsp_check_command};
 pub use pr::pr_command;
-pub use eval::{eval_command, EvalRunOptions};
-pub use misc::{
-    changelog_command, feedback_command, discuss_command, lsp_check_command,
-};
-pub use doctor::doctor_command;
+pub use review::{check_command, compare_command, review_command};
+pub use smart_review::smart_review_command;

src/commands/pr.rs

@@ -99,7 +99,8 @@ pub async fn pr_command(
         return Ok(());
     }
 
-    let comments = review::review_diff_content_raw(&diff_content, config.clone(), &repo_root).await?;
+    let comments =
+        review::review_diff_content_raw(&diff_content, config.clone(), &repo_root).await?;
 
     if post_comments {
         info!("Posting {} comments to PR", comments.len());