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
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
pub struct ValidationResult {
pub is_valid: bool,
pub issues: Vec<String>,
}
impl Default for ValidationResult {
fn default() -> Self {
Self::new()
}
}
impl ValidationResult {
pub fn new() -> Self {
ValidationResult {
is_valid: true,
issues: Vec::new(),
}
}
pub fn add_issue(&mut self, issue: String) {
self.is_valid = false;
self.issues.push(issue);
}
}
// GitLab pipeline models
pub mod gitlab {
use serde::{Deserialize, Serialize};
use std::collections::HashMap;
/// Represents a GitLab CI/CD pipeline configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Pipeline {
/// Default image for all jobs
#[serde(skip_serializing_if = "Option::is_none")]
pub image: Option<Image>,
/// Global variables available to all jobs
#[serde(skip_serializing_if = "Option::is_none")]
pub variables: Option<HashMap<String, String>>,
/// Pipeline stages in execution order
#[serde(skip_serializing_if = "Option::is_none")]
pub stages: Option<Vec<String>>,
/// Default before_script for all jobs
#[serde(skip_serializing_if = "Option::is_none")]
pub before_script: Option<Vec<String>>,
/// Default after_script for all jobs
#[serde(skip_serializing_if = "Option::is_none")]
pub after_script: Option<Vec<String>>,
/// Job definitions (name => job)
#[serde(flatten)]
pub jobs: HashMap<String, Job>,
/// Workflow rules for the pipeline
#[serde(skip_serializing_if = "Option::is_none")]
pub workflow: Option<Workflow>,
/// Includes for pipeline configuration
#[serde(skip_serializing_if = "Option::is_none")]
pub include: Option<Vec<Include>>,
}
/// A job in a GitLab CI/CD pipeline
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Job {
/// The stage this job belongs to
#[serde(skip_serializing_if = "Option::is_none")]
pub stage: Option<String>,
/// Docker image to use for this job
#[serde(skip_serializing_if = "Option::is_none")]
pub image: Option<Image>,
/// Script commands to run
#[serde(skip_serializing_if = "Option::is_none")]
pub script: Option<Vec<String>>,
/// Commands to run before the main script
#[serde(skip_serializing_if = "Option::is_none")]
pub before_script: Option<Vec<String>>,
/// Commands to run after the main script
#[serde(skip_serializing_if = "Option::is_none")]
pub after_script: Option<Vec<String>>,
/// When to run the job (on_success, on_failure, always, manual)
#[serde(skip_serializing_if = "Option::is_none")]
pub when: Option<String>,
/// Allow job failure
#[serde(skip_serializing_if = "Option::is_none")]
pub allow_failure: Option<bool>,
/// Services to run alongside the job
#[serde(skip_serializing_if = "Option::is_none")]
pub services: Option<Vec<Service>>,
/// Tags to define which runners can execute this job
#[serde(skip_serializing_if = "Option::is_none")]
pub tags: Option<Vec<String>>,
/// Job-specific variables
#[serde(skip_serializing_if = "Option::is_none")]
pub variables: Option<HashMap<String, String>>,
/// Job dependencies
#[serde(skip_serializing_if = "Option::is_none")]
pub dependencies: Option<Vec<String>>,
/// Artifacts to store after job execution
#[serde(skip_serializing_if = "Option::is_none")]
pub artifacts: Option<Artifacts>,
/// Cache configuration
#[serde(skip_serializing_if = "Option::is_none")]
pub cache: Option<Cache>,
/// Rules for when this job should run
#[serde(skip_serializing_if = "Option::is_none")]
pub rules: Option<Vec<Rule>>,
/// Only run on specified refs
#[serde(skip_serializing_if = "Option::is_none")]
pub only: Option<Only>,
/// Exclude specified refs
#[serde(skip_serializing_if = "Option::is_none")]
pub except: Option<Except>,
/// Retry configuration
#[serde(skip_serializing_if = "Option::is_none")]
pub retry: Option<Retry>,
/// Timeout for the job in seconds
#[serde(skip_serializing_if = "Option::is_none")]
pub timeout: Option<String>,
/// Mark job as parallel and specify instance count
#[serde(skip_serializing_if = "Option::is_none")]
pub parallel: Option<usize>,
/// Flag to indicate this is a template job
#[serde(skip_serializing_if = "Option::is_none")]
pub template: Option<bool>,
/// List of jobs this job extends from
#[serde(skip_serializing_if = "Option::is_none")]
pub extends: Option<Vec<String>>,
}
/// Docker image configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
#[serde(untagged)]
pub enum Image {
/// Simple image name as string
Simple(String),
/// Detailed image configuration
Detailed {
/// Image name
name: String,
/// Entrypoint to override in the image
#[serde(skip_serializing_if = "Option::is_none")]
entrypoint: Option<Vec<String>>,
},
}
/// Service container to run alongside a job
#[derive(Debug, Serialize, Deserialize, Clone)]
#[serde(untagged)]
pub enum Service {
/// Simple service name as string
Simple(String),
/// Detailed service configuration
Detailed {
/// Service name/image
name: String,
/// Command to run in the service container
#[serde(skip_serializing_if = "Option::is_none")]
command: Option<Vec<String>>,
/// Entrypoint to override in the image
#[serde(skip_serializing_if = "Option::is_none")]
entrypoint: Option<Vec<String>>,
},
}
/// Artifacts configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Artifacts {
/// Paths to include as artifacts
#[serde(skip_serializing_if = "Option::is_none")]
pub paths: Option<Vec<String>>,
/// Artifact expiration duration
#[serde(skip_serializing_if = "Option::is_none")]
pub expire_in: Option<String>,
/// When to upload artifacts (on_success, on_failure, always)
#[serde(skip_serializing_if = "Option::is_none")]
pub when: Option<String>,
}
/// Cache configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Cache {
/// Cache key
#[serde(skip_serializing_if = "Option::is_none")]
pub key: Option<String>,
/// Paths to cache
#[serde(skip_serializing_if = "Option::is_none")]
pub paths: Option<Vec<String>>,
/// When to save cache (on_success, on_failure, always)
#[serde(skip_serializing_if = "Option::is_none")]
pub when: Option<String>,
/// Cache policy
#[serde(skip_serializing_if = "Option::is_none")]
pub policy: Option<String>,
}
/// Rule for conditional job execution
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Rule {
/// If condition expression
#[serde(skip_serializing_if = "Option::is_none")]
pub if_: Option<String>,
/// When to run if condition is true
#[serde(skip_serializing_if = "Option::is_none")]
pub when: Option<String>,
/// Variables to set if condition is true
#[serde(skip_serializing_if = "Option::is_none")]
pub variables: Option<HashMap<String, String>>,
}
/// Only/except configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
#[serde(untagged)]
pub enum Only {
/// Simple list of refs
Refs(Vec<String>),
/// Detailed configuration
Complex {
/// Refs to include
#[serde(skip_serializing_if = "Option::is_none")]
refs: Option<Vec<String>>,
/// Branch patterns to include
#[serde(skip_serializing_if = "Option::is_none")]
branches: Option<Vec<String>>,
/// Tags to include
#[serde(skip_serializing_if = "Option::is_none")]
tags: Option<Vec<String>>,
/// Pipeline types to include
#[serde(skip_serializing_if = "Option::is_none")]
variables: Option<Vec<String>>,
/// Changes to files that trigger the job
#[serde(skip_serializing_if = "Option::is_none")]
changes: Option<Vec<String>>,
},
}
/// Except configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
#[serde(untagged)]
pub enum Except {
/// Simple list of refs
Refs(Vec<String>),
/// Detailed configuration
Complex {
/// Refs to exclude
#[serde(skip_serializing_if = "Option::is_none")]
refs: Option<Vec<String>>,
/// Branch patterns to exclude
#[serde(skip_serializing_if = "Option::is_none")]
branches: Option<Vec<String>>,
/// Tags to exclude
#[serde(skip_serializing_if = "Option::is_none")]
tags: Option<Vec<String>>,
/// Pipeline types to exclude
#[serde(skip_serializing_if = "Option::is_none")]
variables: Option<Vec<String>>,
/// Changes to files that don't trigger the job
#[serde(skip_serializing_if = "Option::is_none")]
changes: Option<Vec<String>>,
},
}
/// Workflow configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct Workflow {
/// Rules for when to run the pipeline
pub rules: Vec<Rule>,
}
/// Retry configuration
#[derive(Debug, Serialize, Deserialize, Clone)]
#[serde(untagged)]
pub enum Retry {
/// Simple max attempts
MaxAttempts(u32),
/// Detailed retry configuration
Detailed {
/// Maximum retry attempts
max: u32,
/// When to retry
#[serde(skip_serializing_if = "Option::is_none")]
when: Option<Vec<String>>,
},
}
/// Include configuration for external pipeline files
#[derive(Debug, Serialize, Deserialize, Clone)]
#[serde(untagged)]
pub enum Include {
/// Simple string include
Local(String),
/// Detailed include configuration
Detailed {
/// Local file path
#[serde(skip_serializing_if = "Option::is_none")]
local: Option<String>,
/// Remote file URL
#[serde(skip_serializing_if = "Option::is_none")]
remote: Option<String>,
/// Include from project
#[serde(skip_serializing_if = "Option::is_none")]
project: Option<String>,
/// Include specific file from project
#[serde(skip_serializing_if = "Option::is_none")]
file: Option<String>,
/// Include template
#[serde(skip_serializing_if = "Option::is_none")]
template: Option<String>,
/// Ref to use when including from project
#[serde(skip_serializing_if = "Option::is_none")]
ref_: Option<String>,
},
}
}