fix: cargo fmt and CI version check for v2.6.1

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: Darth-Hidious

.github/workflows/integration-test.yml

@@ -154,7 +154,7 @@ jobs:
           grep -q "Fe" /tmp/graph.out
 
       - name: Test version flag
-        run: ./target/debug/prism --version 2>&1 | grep "prism 2.6.0"
+        run: ./target/debug/prism --version 2>&1 | grep "prism 2.6.1"
 
       - name: Test node probe
         run: |

crates/agent/src/agent_loop.rs

@@ -215,26 +215,32 @@ fn summarize_tool_result(
                                     .unwrap_or("deployment");
                                 return format!("{tool_name}: {deployment_id} ({status})");
                             }
-                            if let Some(healthy) =
-                                parsed_stdout.get("healthy").and_then(|value| value.as_bool())
+                            if let Some(healthy) = parsed_stdout
+                                .get("healthy")
+                                .and_then(|value| value.as_bool())
                             {
                                 return format!("{tool_name}: healthy={healthy}");
                             }
                         }
                         "discourse" => {
-                            if let Some(items) =
-                                parsed_stdout.get("specs").and_then(|value| value.as_array())
+                            if let Some(items) = parsed_stdout
+                                .get("specs")
+                                .and_then(|value| value.as_array())
                             {
                                 return format!("{tool_name}: {} specs", items.len());
                             }
-                            if let Some(events) =
-                                parsed_stdout.get("events").and_then(|value| value.as_array())
+                            if let Some(events) = parsed_stdout
+                                .get("events")
+                                .and_then(|value| value.as_array())
                             {
                                 let instance_id = parsed_stdout
                                     .get("instance_id")
                                     .and_then(|value| value.as_str())
                                     .unwrap_or("instance");
-                                return format!("{tool_name}: {instance_id} ({} events)", events.len());
+                                return format!(
+                                    "{tool_name}: {instance_id} ({} events)",
+                                    events.len()
+                                );
                             }
                             if let Some(status) =
                                 parsed_stdout.get("status").and_then(|value| value.as_str())
@@ -245,8 +251,9 @@ fn summarize_tool_result(
                                     .unwrap_or("instance");
                                 return format!("{tool_name}: {instance_id} ({status})");
                             }
-                            if let Some(turns) =
-                                parsed_stdout.get("turns").and_then(|value| value.as_array())
+                            if let Some(turns) = parsed_stdout
+                                .get("turns")
+                                .and_then(|value| value.as_array())
                             {
                                 return format!("{tool_name}: {} turns", turns.len());
                             }
@@ -574,7 +581,9 @@ pub async fn run_turn(
                     tool_args: args.clone(),
                     call_id: call_id.clone(),
                     tool_description: tool_meta.map(|tool| tool.description.clone()),
-                    requires_approval: tool_meta.map(|tool| tool.requires_approval).unwrap_or(false),
+                    requires_approval: tool_meta
+                        .map(|tool| tool.requires_approval)
+                        .unwrap_or(false),
                     permission_mode: tool_meta
                         .map(|tool| tool.permission_mode.as_str().to_string())
                         .unwrap_or_else(|| "workspace-write".to_string()),
@@ -626,10 +635,13 @@ pub async fn run_turn(
                     &args,
                     policy.as_deref_mut(),
                 )
-                    .await
-                    .map(|value| serde_json::json!({ "result": value }))
+                .await
+                .map(|value| serde_json::json!({ "result": value }))
             } else {
-                tool_server.call_tool(tool_name, args.clone()).await.map_err(Into::into)
+                tool_server
+                    .call_tool(tool_name, args.clone())
+                    .await
+                    .map_err(Into::into)
             };
             let elapsed_ms = start.elapsed().as_millis() as u64;
 

crates/agent/src/prompts.rs

@@ -180,7 +180,10 @@ pub fn append_runtime_tool_guidance(base_prompt: &str, tools: &ToolCatalog) -> S
         );
     }
 
-    if tools.iter().any(|tool| tool.source.as_deref() == Some("mcp")) {
+    if tools
+        .iter()
+        .any(|tool| tool.source.as_deref() == Some("mcp"))
+    {
         bullets.push(
             "Some loaded tools come from external MCP servers. Treat them as remote capabilities: inspect their descriptions carefully, prefer read-only discovery first, and expect approval before mutation or execution."
                 .to_string(),

crates/agent/src/protocol.rs

@@ -2027,7 +2027,12 @@ fn format_tool_entry(tool_name: &str, tools: &ToolCatalog) -> String {
                 }
             }
 
-            format!("{} · {}\n  {}", tool.name, meta.join(" · "), tool.description)
+            format!(
+                "{} · {}\n  {}",
+                tool.name,
+                meta.join(" · "),
+                tool.description
+            )
         }
         None => tool_name.to_string(),
     }

crates/core/src/config.rs

@@ -176,20 +176,23 @@ impl LlmSection {
     /// Resolve the ingest/search model, allowing platform-backed providers to
     /// fall back to the hosted Gemini default when no explicit model is set.
     pub fn resolve_model_or_platform_default(&self) -> Result<String> {
-        self.model.clone().or_else(|| {
-            if is_platform_llm_provider(&self.provider) {
-                Some(PLATFORM_INGEST_MODEL.to_string())
-            } else {
-                None
-            }
-        }).ok_or_else(|| {
-            anyhow::anyhow!(
-                "No LLM model configured. Set one with:\n  \
+        self.model
+            .clone()
+            .or_else(|| {
+                if is_platform_llm_provider(&self.provider) {
+                    Some(PLATFORM_INGEST_MODEL.to_string())
+                } else {
+                    None
+                }
+            })
+            .ok_or_else(|| {
+                anyhow::anyhow!(
+                    "No LLM model configured. Set one with:\n  \
                  prism configure --model <name>\n\
                  Or pass --model explicitly for this command.\n\
                  Example: prism configure --model gemma-4-E4B-it --url http://localhost:8080"
-            )
-        })
+                )
+            })
     }
 
     /// Resolve the embedding model, defaulting platform-backed flows to the
@@ -629,7 +632,9 @@ api_key_env = "ANTHROPIC_API_KEY"
             "gemini-3.1-flash-preview"
         );
         assert_eq!(
-            section.resolve_embedding_model_or_platform_default().as_deref(),
+            section
+                .resolve_embedding_model_or_platform_default()
+                .as_deref(),
             Some("gemini-embedding-2")
         );
     }
@@ -645,7 +650,9 @@ api_key_env = "ANTHROPIC_API_KEY"
             Some("gemini-3.1-flash-preview")
         );
         assert_eq!(
-            section.resolve_embedding_model_or_platform_default().as_deref(),
+            section
+                .resolve_embedding_model_or_platform_default()
+                .as_deref(),
             Some("gemini-embedding-2")
         );
     }