Struct MockInterceptor 

pub struct MockInterceptor { /* private fields */ }

A StepInterceptor built from closures.

Built by TestEngine; a step kind with no mock attached falls through to the real executor.

Examples

use ironflow_engine::config::{ShellConfig, StepConfig};
use ironflow_engine::executor::StepInterceptor;
use ironflow_engine::testing::{MockInterceptor, MockShellOutput};

let interceptor = MockInterceptor::new().shell(|_cfg| Ok(MockShellOutput::ok("mocked")));
let config = StepConfig::Shell(ShellConfig::new("./deploy.sh"));

let output = interceptor
    .intercept(&config)
    .expect("shell steps are mocked")
    .expect("the mock succeeded");
assert_eq!(output.stdout(), "mocked");

Implementations

impl MockInterceptor

pub fn new() -> Self

An interceptor that mocks nothing.

Examples

use ironflow_engine::config::{ShellConfig, StepConfig};
use ironflow_engine::executor::StepInterceptor;
use ironflow_engine::testing::MockInterceptor;

let interceptor = MockInterceptor::new();
let config = StepConfig::Shell(ShellConfig::new("echo hi"));
assert!(interceptor.intercept(&config).is_none());

pub fn shell( self, f: impl Fn(&ShellConfig) -> Result<MockShellOutput, OperationError> + Send + Sync + 'static, ) -> Self

Answer every shell step with f.

Examples

use ironflow_engine::testing::{MockInterceptor, MockShellOutput};

let interceptor = MockInterceptor::new()
    .shell(|cfg| Ok(MockShellOutput::ok(&format!("ran {}", cfg.command))));

pub fn http( self, f: impl Fn(&HttpConfig) -> Result<MockHttpResponse, OperationError> + Send + Sync + 'static, ) -> Self

Answer every HTTP step with f.

Examples

use ironflow_engine::testing::{MockHttpResponse, MockInterceptor};
use serde_json::json;

let interceptor = MockInterceptor::new()
    .http(|_cfg| Ok(MockHttpResponse::ok(&json!({"ok": true}))));

pub fn approval(self, outcome: ApprovalOutcome) -> Self

Resolve every approval gate with outcome.

Examples

use ironflow_engine::testing::{ApprovalOutcome, MockInterceptor};

let interceptor = MockInterceptor::new().approval(ApprovalOutcome::Approved);

pub fn human_input( self, f: impl Fn(&str, &HumanInputConfig) -> HumanInputOutcome + Send + Sync + 'static, ) -> Self

Answer every human input step with f.

Examples

use ironflow_engine::testing::{HumanInputOutcome, MockInterceptor};
use serde_json::json;

let interceptor = MockInterceptor::new()
    .human_input(|_name, _cfg| HumanInputOutcome::Provided(json!({"answers": ["yes"]})));

Trait Implementations

impl Clone for MockInterceptor

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MockInterceptor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MockInterceptor

fn default() -> Self

Returns the “default value” for a type.

impl StepInterceptor for MockInterceptor

fn intercept( &self, config: &StepConfig, ) -> Option<Result<StepOutput, EngineError>>

Return Some(result) to short-circuit this step, None to execute it for real.

fn intercept_approval( &self, _name: &str, _config: &ApprovalConfig, ) -> Option<ApprovalOutcome>

Resolve an approval gate instead of suspending the run.

fn intercept_human_input( &self, name: &str, config: &HumanInputConfig, _schema: &Value, ) -> Option<HumanInputOutcome>

Answer a human input step instead of suspending the run.