Run cargo fmt

Author: Yogthos

src/agent/builder.rs

@@ -180,10 +180,9 @@ pub async fn build_agent_inner<M: CompletionModel + 'static>(
             .map(|tx| Box::new(tools::QuestionTool::new(tx)) as Box<dyn rig::tool::ToolDyn>);
 
         let plan_tools = plan_tx.map(|tx| {
-            let enter = Box::new(tools::PlanEnterTool::new(tx.clone()))
-                as Box<dyn rig::tool::ToolDyn>;
-            let exit = Box::new(tools::PlanExitTool::new(tx))
-                as Box<dyn rig::tool::ToolDyn>;
+            let enter =
+                Box::new(tools::PlanEnterTool::new(tx.clone())) as Box<dyn rig::tool::ToolDyn>;
+            let exit = Box::new(tools::PlanExitTool::new(tx)) as Box<dyn rig::tool::ToolDyn>;
             vec![enter, exit]
         });
 

src/agent/tools/plan.rs

@@ -73,13 +73,13 @@ impl Tool for PlanEnterTool {
             .map_err(|_| ToolError::Msg("plan system unavailable".to_string()))?;
 
         match reply_rx.await {
-            Ok(PlanSwitchResponse::Accepted) => {
-                Ok("plan mode activated".to_string())
-            }
+            Ok(PlanSwitchResponse::Accepted) => Ok("plan mode activated".to_string()),
             Ok(PlanSwitchResponse::Rejected) => {
                 Err(ToolError::Msg("user declined plan mode".to_string()))
             }
-            Err(_) => Err(ToolError::Msg("plan channel closed unexpectedly".to_string())),
+            Err(_) => Err(ToolError::Msg(
+                "plan channel closed unexpectedly".to_string(),
+            )),
         }
     }
 }
@@ -131,13 +131,13 @@ impl Tool for PlanExitTool {
             .map_err(|_| ToolError::Msg("plan system unavailable".to_string()))?;
 
         match reply_rx.await {
-            Ok(PlanSwitchResponse::Accepted) => {
-                Ok("switched to implementation mode".to_string())
-            }
+            Ok(PlanSwitchResponse::Accepted) => Ok("switched to implementation mode".to_string()),
             Ok(PlanSwitchResponse::Rejected) => {
                 Err(ToolError::Msg("user declined mode switch".to_string()))
             }
-            Err(_) => Err(ToolError::Msg("plan channel closed unexpectedly".to_string())),
+            Err(_) => Err(ToolError::Msg(
+                "plan channel closed unexpectedly".to_string(),
+            )),
         }
     }
 }

src/main.rs

@@ -311,7 +311,7 @@ async fn main() -> anyhow::Result<()> {
                 permission,
                 ask_tx,
                 question_tx.clone(),
-            plan_tx.clone(),
+                plan_tx.clone(),
                 sandbox.clone(),
                 #[cfg(feature = "mcp")]
                 mcp_manager.as_ref(),