ironflow_engine/
error.rs

1//! Engine error types.
2
3use thiserror::Error;
4
5use ironflow_core::error::OperationError;
6use ironflow_store::error::StoreError;
7
8/// Errors produced by the workflow engine.
9#[derive(Debug, Error)]
10pub enum EngineError {
11    /// An operation (Shell, Http, Agent) failed during step execution.
12    #[error("operation failed: {0}")]
13    Operation(#[from] OperationError),
14
15    /// The backing store returned an error.
16    #[error("store error: {0}")]
17    Store(#[from] StoreError),
18
19    /// The workflow definition is invalid.
20    #[error("invalid workflow: {0}")]
21    InvalidWorkflow(String),
22
23    /// A step configuration could not be deserialized for execution.
24    #[error("step config error: {0}")]
25    StepConfig(String),
26
27    /// JSON serialization error.
28    #[error("serialization error: {0}")]
29    Serialization(#[from] serde_json::Error),
30}
31
32#[cfg(test)]
33mod tests {
34    use super::*;
35
36    #[test]
37    fn invalid_workflow_display() {
38        let err = EngineError::InvalidWorkflow("unknown-handler".to_string());
39        assert!(err.to_string().contains("invalid workflow"));
40        assert!(err.to_string().contains("unknown-handler"));
41    }
42
43    #[test]
44    fn step_config_display() {
45        let err = EngineError::StepConfig("bad shell config".to_string());
46        assert!(err.to_string().contains("step config error"));
47        assert!(err.to_string().contains("bad shell config"));
48    }
49
50    #[test]
51    fn store_error_from_conversion() {
52        let store_err = StoreError::RunNotFound(uuid::Uuid::nil());
53        let engine_err = EngineError::from(store_err);
54        assert!(engine_err.to_string().contains("store error"));
55    }
56
57    #[test]
58    fn serialization_error_from_conversion() {
59        let serde_err = serde_json::from_str::<String>("not json").unwrap_err();
60        let engine_err = EngineError::from(serde_err);
61        assert!(engine_err.to_string().contains("serialization error"));
62    }
63}
ironflow_engine/error.rs

ironflow_engine/
error.rs
