ironflow_engine/executor/
agent.rs

1//! Agent step executor.
2
3use std::sync::Arc;
4use std::time::Instant;
5
6use rust_decimal::Decimal;
7use serde_json::json;
8use tracing::info;
9
10use ironflow_core::operations::agent::{Agent, PermissionMode};
11use ironflow_core::provider::AgentProvider;
12
13use crate::config::AgentStepConfig;
14use crate::error::EngineError;
15
16use super::{StepExecutor, StepOutput};
17
18/// Executor for agent (AI) steps.
19///
20/// Runs an AI agent with the given prompt and configuration, capturing
21/// the response value, cost, and token counts.
22pub struct AgentExecutor<'a> {
23    config: &'a AgentStepConfig,
24}
25
26impl<'a> AgentExecutor<'a> {
27    /// Create a new agent executor from a config reference.
28    pub fn new(config: &'a AgentStepConfig) -> Self {
29        Self { config }
30    }
31}
32
33impl StepExecutor for AgentExecutor<'_> {
34    async fn execute(&self, provider: &Arc<dyn AgentProvider>) -> Result<StepOutput, EngineError> {
35        let start = Instant::now();
36
37        let mut agent = Agent::new().prompt(&self.config.prompt);
38
39        if let Some(ref sp) = self.config.system_prompt {
40            agent = agent.system_prompt(sp);
41        }
42        if let Some(ref model_str) = self.config.model {
43            agent = agent.model(model_str.clone());
44        }
45        if let Some(budget) = self.config.max_budget_usd {
46            agent = agent.max_budget_usd(budget);
47        }
48        if let Some(turns) = self.config.max_turns {
49            agent = agent.max_turns(turns);
50        }
51        if !self.config.allowed_tools.is_empty() {
52            let tool_refs: Vec<&str> = self
53                .config
54                .allowed_tools
55                .iter()
56                .map(|s| s.as_str())
57                .collect();
58            agent = agent.allowed_tools(&tool_refs);
59        }
60        if let Some(ref dir) = self.config.working_dir {
61            agent = agent.working_dir(dir);
62        }
63        if let Some(ref mode) = self.config.permission_mode {
64            let pm = parse_permission_mode(mode);
65            agent = agent.permission_mode(pm);
66        }
67
68        let result = agent.run(provider.as_ref()).await?;
69        let duration_ms = start.elapsed().as_millis() as u64;
70        let cost = Decimal::try_from(result.cost_usd().unwrap_or(0.0)).unwrap_or(Decimal::ZERO);
71        let input_tokens = result.input_tokens();
72        let output_tokens = result.output_tokens();
73
74        info!(
75            step_kind = "agent",
76            model = ?self.config.model,
77            cost_usd = %cost,
78            input_tokens = ?input_tokens,
79            output_tokens = ?output_tokens,
80            duration_ms,
81            "agent step completed"
82        );
83
84        Ok(StepOutput {
85            output: json!({
86                "value": result.value(),
87                "model": result.model(),
88            }),
89            duration_ms,
90            cost_usd: cost,
91            input_tokens,
92            output_tokens,
93        })
94    }
95}
96
97/// Parse a permission mode string into a [`PermissionMode`] enum.
98///
99/// Unknown values default to [`PermissionMode::Default`].
100fn parse_permission_mode(s: &str) -> PermissionMode {
101    match s.to_lowercase().as_str() {
102        "auto" => PermissionMode::Auto,
103        "dont_ask" | "dontask" => PermissionMode::DontAsk,
104        "bypass" | "bypass_permissions" => PermissionMode::BypassPermissions,
105        _ => PermissionMode::Default,
106    }
107}
108
109#[cfg(test)]
110mod tests {
111    use super::*;
112
113    #[test]
114    fn parse_permission_mode_auto() {
115        let result = parse_permission_mode("auto");
116        assert!(matches!(result, PermissionMode::Auto));
117    }
118
119    #[test]
120    fn parse_permission_mode_dont_ask() {
121        let result = parse_permission_mode("dont_ask");
122        assert!(matches!(result, PermissionMode::DontAsk));
123    }
124
125    #[test]
126    fn parse_permission_mode_dont_ask_alt() {
127        let result = parse_permission_mode("dontask");
128        assert!(matches!(result, PermissionMode::DontAsk));
129    }
130
131    #[test]
132    fn parse_permission_mode_bypass() {
133        let result = parse_permission_mode("bypass");
134        assert!(matches!(result, PermissionMode::BypassPermissions));
135    }
136
137    #[test]
138    fn parse_permission_mode_bypass_alt() {
139        let result = parse_permission_mode("bypass_permissions");
140        assert!(matches!(result, PermissionMode::BypassPermissions));
141    }
142
143    #[test]
144    fn parse_permission_mode_unknown_defaults() {
145        let result = parse_permission_mode("unknown");
146        assert!(matches!(result, PermissionMode::Default));
147    }
148
149    #[test]
150    fn parse_permission_mode_case_insensitive() {
151        assert!(matches!(
152            parse_permission_mode("AUTO"),
153            PermissionMode::Auto
154        ));
155        assert!(matches!(
156            parse_permission_mode("DONT_ASK"),
157            PermissionMode::DontAsk
158        ));
159        assert!(matches!(
160            parse_permission_mode("BYPASS"),
161            PermissionMode::BypassPermissions
162        ));
163    }
164}
ironflow_engine/executor/agent.rs

ironflow_engine/executor/
agent.rs
