cargo fmt

Author: monatis

src/agent/mod.rs

@@ -221,7 +221,12 @@ fn repair_tool_call_context(context: &mut Vec<crate::utils::ChatMessage>) {
         for id in missing {
             context.insert(
                 j,
-                crate::utils::ChatMessage::tool("[Cancelled — tool execution interrupted]", &id, None),            );
+                crate::utils::ChatMessage::tool(
+                    "[Cancelled — tool execution interrupted]",
+                    &id,
+                    None,
+                ),
+            );
             j += 1;
         }
 
@@ -1617,10 +1622,14 @@ impl AgentLogic {
                         }
                     }
                 }
-                
-                mem.add_message(crate::utils::ChatMessage::tool(&inbound.content, id, tool_name_for_resume.as_deref()))
-                    .await
-                    .map_err(|e| format!("Failed to inject tool response into memory: {}", e))?;
+
+                mem.add_message(crate::utils::ChatMessage::tool(
+                    &inbound.content,
+                    id,
+                    tool_name_for_resume.as_deref(),
+                ))
+                .await
+                .map_err(|e| format!("Failed to inject tool response into memory: {}", e))?;
             } else {
                 return Err(format!("Failed to get session {}", session_key));
             }
@@ -2271,8 +2280,12 @@ impl AgentLogic {
                         };
                         let _ = outbound_tx.send(BusMessage::Telemetry(tfin.clone())).await;
                         hook_observe_telemetry(hook_tool_ctx.as_ref(), &inbound, is_subagent, tfin);
-                        mem.add_message(crate::utils::ChatMessage::tool(&tool_result_text, &tc.id, Some(tool_name.as_str())))
-                            .await?;
+                        mem.add_message(crate::utils::ChatMessage::tool(
+                            &tool_result_text,
+                            &tc.id,
+                            Some(tool_name.as_str()),
+                        ))
+                        .await?;
                     }
                     tool_invoked = true;
                 } else {
@@ -2370,8 +2383,12 @@ impl AgentLogic {
                         let _ = outbound_tx.send(BusMessage::Telemetry(tfin.clone())).await;
                         hook_observe_telemetry(hook_tool_ctx.as_ref(), &inbound, is_subagent, tfin);
 
-                        mem.add_message(crate::utils::ChatMessage::tool(&tool_result_text, &tc.id, Some(tool_name.as_str())))
-                            .await?;
+                        mem.add_message(crate::utils::ChatMessage::tool(
+                            &tool_result_text,
+                            &tc.id,
+                            Some(tool_name.as_str()),
+                        ))
+                        .await?;
                         tool_invoked = true;
                     }
                 }

src/channels/terminal_ui/run.rs

@@ -2198,7 +2198,10 @@ pub(crate) fn run_ratatui_main(config: RatatuiMainConfig) -> io::Result<()> {
                             let selected_id = if app.ui_focus == TerminalUiFocus::Conversations {
                                 if let Some(idx) = app.conversations_selected_idx {
                                     if idx < app.conversations_items.len() {
-                                        Some((app.conversations_items[idx].thread_id.clone(), false))
+                                        Some((
+                                            app.conversations_items[idx].thread_id.clone(),
+                                            false,
+                                        ))
                                     } else {
                                         None
                                     }
@@ -2218,7 +2221,11 @@ pub(crate) fn run_ratatui_main(config: RatatuiMainConfig) -> io::Result<()> {
 
                             if let Some((target_id, is_chat_id)) = selected_id {
                                 let (thread_id, new_cid) = if is_chat_id {
-                                    let tid = crate::bus::clarification_session_key(channel_name.as_str(), &target_id, None);
+                                    let tid = crate::bus::clarification_session_key(
+                                        channel_name.as_str(),
+                                        &target_id,
+                                        None,
+                                    );
                                     (tid, target_id)
                                 } else {
                                     let cid = match chat_id_from_root_thread_id(