1. 1use std::collections::BTreeMap;
2. 2
3. 3use serde::{Deserialize, Serialize};
4. 4
5. 5#[derive(Debug, Clone, Serialize, Deserialize)]
6. 6pub struct FlowDef {
7. 7 pub name: String,
8. 8 #[serde(default)]
9. 9 pub description: String,
10. 10 #[serde(default)]
11. 11 pub nodes: Vec<NodeDef>,
12. 12}
13. 13
14. 14#[derive(Debug, Clone, Serialize, Deserialize)]
15. 15#[serde(deny_unknown_fields)]
16. 16pub struct NodeDef {
17. 17 pub id: String,
18. 18 pub r#type: String,
19. 19 #[serde(default)]
20. 20 pub deps: Vec<String>,
21. 21 #[serde(default = "default_required")]
22. 22 pub required: bool,
23. 23 #[serde(default)]
24. 24 pub prompt: Option<String>,
25. 25 #[serde(default)]
26. 26 pub command: Option<String>,
27. 27 #[serde(default)]
28. 28 pub message: Option<String>,
29. 29 #[serde(default)]
30. 30 pub readonly: bool,
31. 31 #[serde(default)]
32. 32 pub paths: Vec<String>,
33. 33 #[serde(default)]
34. 34 pub timeout_ms: Option<u64>,
35. 35 /// Done-contract (docs/design/42-managed-work-contracts.md mechanism 5): shell checks
36. 36 /// that must pass AFTER the node succeeds. `verify:` prefix optional;
37. 37 /// every entry runs as a brokered bash command and must exit 0.
38. 38 #[serde(default)]
39. 39 pub accept: Vec<String>,
40. 40}
41. 41
42. 42fn default_required() -> bool {
43. 43 true
44. 44}
45. 45
46. 46impl NodeDef {
47. 47 /// The strings a `{{dep}}` substitution may pull from upstream outputs.
48. 48 pub fn uses_template(&self) -> bool {
49. 49 match self.r#type.as_str() {
50. 50 "agent" => self.prompt.as_deref().is_some_and(|p| p.contains("{{")),
51. 51 "bash" => self.command.as_deref().is_some_and(|c| c.contains("{{")),
52. 52 _ => false,
53. 53 }
54. 54 }
55. 55}
56. 56
57. 57#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
58. 58#[serde(rename_all = "snake_case")]
59. 59pub enum NodeStatus {
60. 60 Pending,
61. 61 Running,
62. 62 Completed,
63. 63 Failed,
64. 64 Skipped,
65. 65}
66. 66
67. 67#[derive(Debug, Clone, Serialize, Deserialize)]
68. 68pub struct NodeResult {
69. 69 pub status: NodeStatus,
70. 70 #[serde(default)]
71. 71 pub output: String,
72. 72}
73. 73
74. 74#[derive(Debug, Clone, Serialize, Deserialize)]
75. 75pub struct FlowState {
76. 76 pub run_id: String,
77. 77 pub flow_name: String,
78. 78 /// Frozen definition (raw TOML) captured at first run.
79. 79 pub definition_toml: String,
80. 80 pub started_at: chrono::DateTime<chrono::Utc>,
81. 81 #[serde(default)]
82. 82 pub outcome: Option<vak_intent::OutcomeSpec>,
83. 83 pub nodes: BTreeMap<String, NodeResult>,
84. 84}
85. 85