ironflow_api/entities/
step.rs

1//! Step-related DTOs.
2
3use chrono::{DateTime, Utc};
4use ironflow_store::models::{Step, StepKind, StepStatus};
5use rust_decimal::Decimal;
6use serde::{Deserialize, Serialize};
7use serde_json::Value;
8use uuid::Uuid;
9
10/// Step response DTO — public API representation of a step.
11///
12/// # Examples
13///
14/// ```
15/// use ironflow_store::models::Step;
16/// use ironflow_api::entities::StepResponse;
17/// ```
18#[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
19#[derive(Debug, Serialize, Deserialize)]
20pub struct StepResponse {
21    /// Unique step identifier.
22    pub id: Uuid,
23    /// Parent run ID.
24    pub run_id: Uuid,
25    /// Step name.
26    pub name: String,
27    /// Step operation type.
28    #[cfg_attr(feature = "openapi", schema(value_type = String))]
29    pub kind: StepKind,
30    /// Execution order (0-based).
31    pub position: u32,
32    /// Current status.
33    pub status: StepStatus,
34    /// Input configuration.
35    #[cfg_attr(feature = "openapi", schema(value_type = Option<std::collections::HashMap<String, serde_json::Value>>))]
36    pub input: Option<Value>,
37    /// Step output.
38    #[cfg_attr(feature = "openapi", schema(value_type = Option<std::collections::HashMap<String, serde_json::Value>>))]
39    pub output: Option<Value>,
40    /// Optional error message.
41    pub error: Option<String>,
42    /// Execution duration in milliseconds.
43    pub duration_ms: u64,
44    /// Cost in USD.
45    #[cfg_attr(feature = "openapi", schema(value_type = f64))]
46    pub cost_usd: Decimal,
47    /// Input token count (agent steps).
48    pub input_tokens: Option<u64>,
49    /// Output token count (agent steps).
50    pub output_tokens: Option<u64>,
51    /// When created.
52    pub created_at: DateTime<Utc>,
53    /// When updated.
54    pub updated_at: DateTime<Utc>,
55    /// When execution started.
56    pub started_at: Option<DateTime<Utc>>,
57    /// When execution completed.
58    pub completed_at: Option<DateTime<Utc>>,
59    /// IDs of steps this step depends on (direct dependencies).
60    pub dependencies: Vec<Uuid>,
61}
62
63impl StepResponse {
64    /// Build a response from a step entity with pre-resolved dependencies.
65    pub fn with_dependencies(step: Step, dependencies: Vec<Uuid>) -> Self {
66        StepResponse {
67            id: step.id,
68            run_id: step.run_id,
69            name: step.name,
70            kind: step.kind,
71            position: step.position,
72            status: step.status.state,
73            input: step.input,
74            output: step.output,
75            error: step.error,
76            duration_ms: step.duration_ms,
77            cost_usd: step.cost_usd,
78            input_tokens: step.input_tokens,
79            output_tokens: step.output_tokens,
80            created_at: step.created_at,
81            updated_at: step.updated_at,
82            started_at: step.started_at,
83            completed_at: step.completed_at,
84            dependencies,
85        }
86    }
87}
88
89impl From<Step> for StepResponse {
90    fn from(step: Step) -> Self {
91        Self::with_dependencies(step, Vec::new())
92    }
93}
ironflow_api/entities/step.rs

ironflow_api/entities/
step.rs
