ironflow_store/
error.rs

1//! Storage error types.
2//!
3//! [`StoreError`] covers all failure modes for [`RunStore`](crate::store::RunStore)
4//! implementations, from missing records to invalid FSM transitions.
5
6use thiserror::Error;
7use uuid::Uuid;
8
9use crate::entities::{ConcurrencyLimitError, RunStatus};
10
11/// Errors produced by [`RunStore`](crate::store::RunStore) operations.
12///
13/// # Examples
14///
15/// ```
16/// use ironflow_store::error::StoreError;
17/// use uuid::Uuid;
18///
19/// let err = StoreError::RunNotFound(Uuid::nil());
20/// assert!(err.to_string().contains("run not found"));
21/// ```
22#[derive(Debug, Error)]
23pub enum StoreError {
24    /// The requested run does not exist.
25    #[error("run not found: {0}")]
26    RunNotFound(Uuid),
27
28    /// The requested step does not exist.
29    #[error("step not found: {0}")]
30    StepNotFound(Uuid),
31
32    /// Attempted an illegal FSM transition.
33    #[error("invalid status transition: {from} -> {to}")]
34    InvalidTransition {
35        /// Current status.
36        from: RunStatus,
37        /// Attempted target status.
38        to: RunStatus,
39    },
40
41    /// Email is already taken by another user.
42    #[error("email already exists: {0}")]
43    DuplicateEmail(String),
44
45    /// Username is already taken by another user.
46    #[error("username already exists: {0}")]
47    DuplicateUsername(String),
48
49    /// The requested user does not exist.
50    #[error("user not found: {0}")]
51    UserNotFound(Uuid),
52
53    /// The worker no longer holds the lease on this run.
54    ///
55    /// Either another worker took it over after the lease expired, or the run
56    /// left the `Running` state (cancelled, failed, awaiting approval).
57    #[error("lease lost on run {run_id}")]
58    LeaseLost {
59        /// Run whose lease was lost.
60        run_id: Uuid,
61        /// Worker currently holding the lease, if any.
62        held_by: Option<String>,
63    },
64
65    /// The step already holds an artifact with this name.
66    #[error("artifact {name:?} already exists on step {step_id}")]
67    DuplicateArtifact {
68        /// Step that already owns the name.
69        step_id: Uuid,
70        /// The conflicting artifact name.
71        name: String,
72    },
73
74    /// Another non-terminal run already holds this concurrency key.
75    #[error("concurrency key {key:?} is held by active run {run_id}")]
76    ConcurrencyConflict {
77        /// The contested key.
78        key: String,
79        /// The run holding it.
80        run_id: Uuid,
81    },
82
83    /// The concurrency limits of a run are invalid.
84    #[error("invalid concurrency limit: {0}")]
85    InvalidConcurrencyLimit(#[from] ConcurrencyLimitError),
86
87    /// The requested schedule does not exist.
88    #[error("schedule not found: {0}")]
89    ScheduleNotFound(Uuid),
90
91    /// The requested approval delegation does not exist.
92    #[error("approval delegation not found: {0}")]
93    DelegationNotFound(Uuid),
94
95    /// The requested provider account does not exist.
96    #[error("provider account not found: {0}")]
97    ProviderAccountNotFound(Uuid),
98
99    /// A provider account with this name already exists.
100    #[error("provider account already exists: {0}")]
101    DuplicateProviderAccount(String),
102
103    /// A database or I/O error from the backing store.
104    #[error("database error: {0}")]
105    Database(String),
106
107    /// JSON serialization or deserialization failed.
108    #[error("serialization error: {0}")]
109    Serialization(#[from] serde_json::Error),
110
111    /// A cryptographic operation failed (encryption or decryption).
112    #[error("crypto error: {0}")]
113    Crypto(String),
114}
115
116#[cfg(test)]
117mod tests {
118    use super::*;
119
120    #[test]
121    fn run_not_found_display() {
122        let id = Uuid::nil();
123        let err = StoreError::RunNotFound(id);
124        assert_eq!(err.to_string(), format!("run not found: {id}"));
125    }
126
127    #[test]
128    fn step_not_found_display() {
129        let id = Uuid::nil();
130        let err = StoreError::StepNotFound(id);
131        assert_eq!(err.to_string(), format!("step not found: {id}"));
132    }
133
134    #[test]
135    fn invalid_transition_display() {
136        let err = StoreError::InvalidTransition {
137            from: RunStatus::Pending,
138            to: RunStatus::Completed,
139        };
140        assert!(err.to_string().contains("Pending"));
141        assert!(err.to_string().contains("Completed"));
142    }
143
144    #[test]
145    fn concurrency_conflict_display() {
146        let run_id = Uuid::now_v7();
147        let err = StoreError::ConcurrencyConflict {
148            key: "issue:12".to_string(),
149            run_id,
150        };
151        let message = err.to_string();
152        assert!(message.contains("issue:12"));
153        assert!(message.contains(&run_id.to_string()));
154    }
155
156    #[test]
157    fn invalid_concurrency_limit_display() {
158        let err = StoreError::from(ConcurrencyLimitError::EmptyGroup);
159        assert_eq!(
160            err.to_string(),
161            "invalid concurrency limit: concurrency group must not be empty"
162        );
163    }
164
165    #[test]
166    fn delegation_not_found_display() {
167        let id = Uuid::nil();
168        let err = StoreError::DelegationNotFound(id);
169        assert_eq!(
170            err.to_string(),
171            format!("approval delegation not found: {id}")
172        );
173    }
174
175    #[test]
176    fn database_error_display() {
177        let err = StoreError::Database("connection refused".to_string());
178        assert!(err.to_string().contains("connection refused"));
179    }
180
181    #[test]
182    fn serialization_error_from_serde() {
183        let serde_err = serde_json::from_str::<String>("not json").unwrap_err();
184        let err = StoreError::from(serde_err);
185        assert!(err.to_string().contains("serialization error"));
186    }
187}
ironflow_store/error.rs

ironflow_store/
error.rs
