Merge pull request #426 from CortexLM/feature/update-all-dependencies

feat: update all cargo dependencies to latest versions

Author: echobt

Cargo.lock

@@ -134,7 +134,7 @@ simd-json = "0.14"
 toml = "0.8"
 
 # HTTP client
-reqwest = { version = "0.12", features = ["json", "stream", "rustls-tls", "cookies"], default-features = false }
+reqwest = { version = "0.13", features = ["json", "stream", "rustls", "cookies", "form", "multipart", "query"], default-features = false }
 
 # Error handling
 thiserror = "2.0"
@@ -143,10 +143,10 @@ anyhow = "1.0"
 # Tracing & Observability
 tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
-tracing-opentelemetry = "0.28"
-opentelemetry = "0.27"
-opentelemetry_sdk = { version = "0.27", features = ["rt-tokio"] }
-opentelemetry-otlp = { version = "0.27", features = ["tonic"] }
+tracing-opentelemetry = "0.31"
+opentelemetry = "0.31"
+opentelemetry_sdk = { version = "0.31", features = ["rt-tokio"] }
+opentelemetry-otlp = { version = "0.31", features = ["tonic"] }
 
 # Utilities
 uuid = { version = "1.16", features = ["v4", "serde"] }
@@ -277,10 +277,10 @@ tracing-appender = "0.2"
 log = "0.4"
 
 # CLI - Parsing
-pulldown-cmark = "0.10"
-tree-sitter = "0.25"
+pulldown-cmark = "0.13"
+tree-sitter = "0.26"
 tree-sitter-bash = "0.25"
-tree-sitter-highlight = "0.25"
+tree-sitter-highlight = "0.26"
 regex-lite = "0.1"
 
 # CLI - Sandbox & Security (Linux)
@@ -354,8 +354,8 @@ tokio-test = "0.4"
 wiremock = "0.6"
 
 # CLI - OpenTelemetry
-opentelemetry-semantic-conventions = "0.30"
-opentelemetry-appender-tracing = "0.30"
+opentelemetry-semantic-conventions = "0.31"
+opentelemetry-appender-tracing = "0.31"
 
 # CLI - TypeScript bindings
 ts-rs = { version = "11", features = ["uuid-impl", "serde-json-impl", "no-serde-warnings"] }

Cargo.toml

@@ -7,9 +7,10 @@ use serde::{Deserialize, Serialize};
 use std::time::{Duration, Instant};
 
 /// Status of a background agent.
-#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
 pub enum AgentStatus {
     /// Agent is being initialized.
+    #[default]
     Initializing,
     /// Agent is currently running.
     Running,
@@ -23,12 +24,6 @@ pub enum AgentStatus {
     TimedOut,
 }
 
-impl Default for AgentStatus {
-    fn default() -> Self {
-        AgentStatus::Initializing
-    }
-}
-
 impl std::fmt::Display for AgentStatus {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         match self {

cortex-agents/src/background/events.rs

@@ -149,6 +149,7 @@ pub struct BackgroundAgent {
     /// Tokio task handle.
     handle: JoinHandle<AgentResult>,
     /// Status receiver for updates.
+    #[allow(dead_code)]
     status_rx: mpsc::Receiver<AgentStatus>,
     /// Cancel signal sender.
     cancel_tx: Option<oneshot::Sender<()>>,

cortex-agents/src/background/executor.rs

@@ -281,7 +281,7 @@ impl AgentMailbox {
     /// Returns true if there are pending messages.
     pub fn has_messages(&mut self) -> bool {
         // Try to peek without consuming
-        matches!(self.inbox.try_recv(), Ok(_))
+        self.inbox.try_recv().is_ok()
     }
 }
 

cortex-agents/src/background/messaging.rs

@@ -115,7 +115,7 @@ pub async fn handle(
     control
         .shutdown_agent(agent_id)
         .await
-        .map_err(|e| CollabError::ControlError(e))?;
+        .map_err(CollabError::ControlError)?;
 
     // Log the closure
     tracing::info!(

cortex-agents/src/collab/close.rs

@@ -146,7 +146,7 @@ pub async fn handle(
     control
         .set_status(agent_id, AgentThreadStatus::Running)
         .await
-        .map_err(|e| CollabError::ControlError(e))?;
+        .map_err(CollabError::ControlError)?;
 
     // Log spawn (without sensitive content)
     tracing::info!(

cortex-agents/src/collab/spawn.rs

@@ -24,7 +24,7 @@ use std::collections::HashSet;
 use std::path::PathBuf;
 
 /// Mode for dispatching tasks to agents.
-#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
+#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Serialize, Deserialize)]
 pub enum DispatchMode {
     /// Run tasks in parallel.
     /// Best for: 3+ unrelated tasks, no shared state, read-only operations.
@@ -40,15 +40,10 @@ pub enum DispatchMode {
 
     /// Run as a single task.
     /// Best for: Single task or tightly coupled operations.
+    #[default]
     Single,
 }
 
-impl Default for DispatchMode {
-    fn default() -> Self {
-        DispatchMode::Single
-    }
-}
-
 impl std::fmt::Display for DispatchMode {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         match self {

cortex-agents/src/routing.rs

@@ -8,7 +8,7 @@ use serde::{Deserialize, Serialize};
 use tokio::sync::oneshot;
 
 /// Decision made by the user on a spec plan.
-#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
 #[serde(rename_all = "snake_case")]
 pub enum ApprovalDecision {
     /// Plan approved as-is
@@ -18,6 +18,7 @@ pub enum ApprovalDecision {
     /// Plan rejected with reason
     Rejected(String),
     /// Decision deferred (user wants to think about it)
+    #[default]
     Deferred,
 }
 
@@ -43,12 +44,6 @@ impl ApprovalDecision {
     }
 }
 
-impl Default for ApprovalDecision {
-    fn default() -> Self {
-        ApprovalDecision::Deferred
-    }
-}
-
 /// A request for user approval of a spec plan.
 pub struct ApprovalRequest {
     /// The plan awaiting approval

cortex-agents/src/spec/approval.rs

@@ -84,7 +84,7 @@ pub fn parse_unified_diff(patch: &str) -> PatchResult<Vec<FileChange>> {
         let line = lines[i];
 
         // Detect file header: --- path
-        if line.starts_with("--- ") {
+        if let Some(old_str) = line.strip_prefix("--- ") {
             // Save previous file change if exists
             if let Some(mut change) = current_change.take() {
                 if let Some(hunk) = current_hunk.take() {
@@ -95,18 +95,19 @@ pub fn parse_unified_diff(patch: &str) -> PatchResult<Vec<FileChange>> {
                 }
             }
 
-            let old_path = parse_file_path(&line[4..]);
+            let old_path = parse_file_path(old_str);
 
             // Look for +++ line
-            if i + 1 < lines.len() && lines[i + 1].starts_with("+++ ") {
-                let new_path = parse_file_path(&lines[i + 1][4..]);
-                current_change = Some(FileChange::new(old_path, new_path));
-                i += 2;
-                continue;
-            } else {
-                // Malformed patch, but try to continue
-                current_change = Some(FileChange::new(old_path, None));
+            if i + 1 < lines.len() {
+                if let Some(new_str) = lines[i + 1].strip_prefix("+++ ") {
+                    let new_path = parse_file_path(new_str);
+                    current_change = Some(FileChange::new(old_path, new_path));
+                    i += 2;
+                    continue;
+                }
             }
+            // Malformed patch, but try to continue
+            current_change = Some(FileChange::new(old_path, None));
             i += 1;
             continue;
         }
@@ -201,37 +202,37 @@ pub fn parse_git_diff(patch: &str) -> PatchResult<Vec<FileChange>> {
 
         // Handle git-specific metadata
         if let Some(ref mut change) = current_change {
-            if line.starts_with("old mode ") {
-                change.old_mode = Some(line[9..].to_string());
+            if let Some(mode) = line.strip_prefix("old mode ") {
+                change.old_mode = Some(mode.to_string());
                 i += 1;
                 continue;
             }
-            if line.starts_with("new mode ") {
-                change.new_mode = Some(line[9..].to_string());
+            if let Some(mode) = line.strip_prefix("new mode ") {
+                change.new_mode = Some(mode.to_string());
                 i += 1;
                 continue;
             }
-            if line.starts_with("new file mode ") {
+            if let Some(mode) = line.strip_prefix("new file mode ") {
                 change.is_new_file = true;
-                change.new_mode = Some(line[14..].to_string());
+                change.new_mode = Some(mode.to_string());
                 i += 1;
                 continue;
             }
-            if line.starts_with("deleted file mode ") {
+            if let Some(mode) = line.strip_prefix("deleted file mode ") {
                 change.is_deleted = true;
-                change.old_mode = Some(line[18..].to_string());
+                change.old_mode = Some(mode.to_string());
                 i += 1;
                 continue;
             }
-            if line.starts_with("rename from ") {
+            if let Some(path) = line.strip_prefix("rename from ") {
                 change.is_rename = true;
-                change.old_path = Some(PathBuf::from(&line[12..]));
+                change.old_path = Some(PathBuf::from(path));
                 i += 1;
                 continue;
             }
-            if line.starts_with("rename to ") {
+            if let Some(path) = line.strip_prefix("rename to ") {
                 change.is_rename = true;
-                change.new_path = Some(PathBuf::from(&line[10..]));
+                change.new_path = Some(PathBuf::from(path));
                 i += 1;
                 continue;
             }
@@ -251,9 +252,9 @@ pub fn parse_git_diff(patch: &str) -> PatchResult<Vec<FileChange>> {
         }
 
         // Standard unified diff parts
-        if line.starts_with("--- ") {
+        if let Some(path_str) = line.strip_prefix("--- ") {
             if let Some(ref mut change) = current_change {
-                let old_path = parse_file_path(&line[4..]);
+                let old_path = parse_file_path(path_str);
                 if old_path
                     .as_ref()
                     .is_some_and(|p| p.as_os_str() == "/dev/null")
@@ -268,9 +269,9 @@ pub fn parse_git_diff(patch: &str) -> PatchResult<Vec<FileChange>> {
             continue;
         }
 
-        if line.starts_with("+++ ") {
+        if let Some(path_str) = line.strip_prefix("+++ ") {
             if let Some(ref mut change) = current_change {
-                let new_path = parse_file_path(&line[4..]);
+                let new_path = parse_file_path(path_str);
                 if new_path
                     .as_ref()
                     .is_some_and(|p| p.as_os_str() == "/dev/null")