Fix compilation errors: add Vec::new() to all chat_stream_with_tools calls and run cargo fmt

Co-authored-by: yiwang <142937+yiwang@users.noreply.github.com>

Author: Copilot

crates/cli/src/cli/chat.rs

@@ -467,16 +467,20 @@ pub async fn run(args: ChatArgs, agent_id: &str) -> Result<()> {
 
                     if !approved_calls.is_empty() {
                         match agent
-                            .execute_streaming_tool_calls(&full_response, approved_calls, |name, args| {
-                                // Print tool call as it starts (including recursive calls)
-                                let detail = extract_tool_detail(name, args);
-                                if let Some(ref d) = detail {
-                                    println!("\n[{}: {}]", name, d);
-                                } else {
-                                    println!("\n[{}]", name);
-                                }
-                                let _ = stdout.flush();
-                            })
+                            .execute_streaming_tool_calls(
+                                &full_response,
+                                approved_calls,
+                                |name, args| {
+                                    // Print tool call as it starts (including recursive calls)
+                                    let detail = extract_tool_detail(name, args);
+                                    if let Some(ref d) = detail {
+                                        println!("\n[{}: {}]", name, d);
+                                    } else {
+                                        println!("\n[{}]", name);
+                                    }
+                                    let _ = stdout.flush();
+                                },
+                            )
                             .await
                         {
                             Ok((follow_up, warnings)) => {

crates/cli/src/desktop/worker.rs

@@ -114,7 +114,7 @@ async fn worker_loop(
         match msg {
             UiMessage::Chat(message) => {
                 // Stream response with tool support
-                match agent.chat_stream_with_tools(&message).await {
+                match agent.chat_stream_with_tools(&message, Vec::new()).await {
                     Ok(stream) => {
                         let mut stream = pin!(stream);
                         let mut pending_tools: Vec<ToolCall> = Vec::new();

crates/core/src/agent/mod.rs

@@ -639,7 +639,7 @@ impl Agent {
                 for call in &calls {
                     // Notify caller that tool is starting
                     on_tool_start(&call.name, &call.arguments);
-                    
+
                     debug!(
                         "Executing tool: {} with args: {}",
                         call.name, call.arguments
@@ -1168,7 +1168,7 @@ impl Agent {
         for call in &tool_calls {
             // Notify caller that tool is starting
             on_tool_start(&call.name, &call.arguments);
-            
+
             debug!(
                 "Executing tool: {} with args: {}",
                 call.name, call.arguments
@@ -1208,7 +1208,9 @@ impl Agent {
             .await?;
 
         // Handle the response (may have more tool calls)
-        let final_response = self.handle_response_with_callback(response, &mut on_tool_start).await?;
+        let final_response = self
+            .handle_response_with_callback(response, &mut on_tool_start)
+            .await?;
 
         // Add final response to session
         self.session.add_message(Message {

crates/server/src/http.rs

@@ -792,7 +792,7 @@ async fn chat_stream(
         entry.dirty = true;
 
         // Use streaming with tools
-        match entry.agent.chat_stream_with_tools(&message).await {
+        match entry.agent.chat_stream_with_tools(&message, Vec::new()).await {
             Ok(event_stream) => {
                 use futures::StreamExt;
 

crates/server/src/telegram.rs

@@ -693,7 +693,7 @@ async fn handle_chat(
     entry.last_accessed = Instant::now();
 
     // Use streaming with tools
-    let response = match entry.agent.chat_stream_with_tools(text).await {
+    let response = match entry.agent.chat_stream_with_tools(text, Vec::new()).await {
         Ok(event_stream) => {
             use futures::StreamExt;