dk-runner 0.2.76

dkod verification runner — CI/CD pipeline execution
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146

use serde::Deserialize;
use std::path::PathBuf;
use std::time::Duration;

// --- TOML deserialization types ---

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct WorkflowFile {
    pub pipeline: PipelineConfig,
    #[serde(default)]
    pub stage: Vec<StageConfig>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct PipelineConfig {
    pub name: String,
    #[serde(default = "default_timeout")]
    pub timeout: String,
}

fn default_timeout() -> String {
    "10m".to_string()
}

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct StageConfig {
    pub name: String,
    #[serde(default)]
    pub parallel: bool,
    #[serde(default)]
    pub step: Vec<StepConfig>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct StepConfig {
    pub name: String,
    #[serde(default)]
    pub run: Option<String>,
    #[serde(default, rename = "type")]
    pub step_type: Option<String>,
    #[serde(default)]
    pub timeout: Option<String>,
    #[serde(default)]
    pub changeset_aware: bool,
    #[serde(default = "default_required")]
    pub required: bool,
    #[serde(default)]
    pub check: Vec<String>,
    #[serde(default)]
    pub prompt: Option<String>,
}

fn default_required() -> bool {
    true
}

// --- YAML deserialization types ---

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct YamlWorkflowFile {
    pub pipeline: YamlPipelineConfig,
    #[serde(default)]
    pub stages: Vec<YamlStageConfig>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct YamlPipelineConfig {
    pub name: String,
    #[serde(default = "default_timeout")]
    pub timeout: String,
    #[serde(default)]
    pub allowed_commands: Vec<String>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct YamlStageConfig {
    pub name: String,
    #[serde(default)]
    pub parallel: bool,
    #[serde(default)]
    pub steps: Vec<YamlStepConfig>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct YamlStepConfig {
    pub name: String,
    #[serde(default)]
    pub run: Option<String>,
    #[serde(default, rename = "type")]
    pub step_type: Option<String>,
    #[serde(default)]
    pub timeout: Option<String>,
    #[serde(default)]
    pub changeset_aware: bool,
    #[serde(default = "default_required")]
    pub required: bool,
    #[serde(default)]
    pub check: Vec<String>,
    #[serde(default)]
    pub prompt: Option<String>,
}

// --- Resolved types (post-parsing) ---

#[derive(Debug, Clone)]
pub struct Workflow {
    pub name: String,
    pub timeout: Duration,
    pub stages: Vec<Stage>,
    /// Per-repo command allowlist. Empty means "use default allowlist".
    pub allowed_commands: Vec<String>,
}

#[derive(Debug, Clone)]
pub struct Stage {
    pub name: String,
    pub parallel: bool,
    pub steps: Vec<Step>,
}

#[derive(Debug, Clone)]
pub struct Step {
    pub name: String,
    pub step_type: StepType,
    pub timeout: Duration,
    pub required: bool,
    pub changeset_aware: bool,
    /// Optional subdirectory to run this step in, relative to the repo root.
    pub work_dir: Option<PathBuf>,
}

#[derive(Debug, Clone)]
pub enum StepType {
    Command { run: String },
    Semantic { checks: Vec<String> },
    AgentReview { prompt: String },
    HumanApprove,
}