2026-06-05 01:29:07 +02:00
|
|
|
package model
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"fmt"
|
|
|
|
|
"os"
|
|
|
|
|
|
|
|
|
|
"gopkg.in/yaml.v3"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
// Parse reads a .gitlab-ci.yml file and returns a Pipeline.
|
|
|
|
|
func Parse(path string) (*Pipeline, error) {
|
|
|
|
|
data, err := os.ReadFile(path)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, fmt.Errorf("reading file: %w", err)
|
|
|
|
|
}
|
2026-06-11 21:24:18 +02:00
|
|
|
p, err := ParseBytes(data)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
p.SourceFile = path
|
|
|
|
|
p.SetJobOrigin(path)
|
|
|
|
|
return p, nil
|
2026-06-07 20:13:03 +02:00
|
|
|
}
|
2026-06-05 01:29:07 +02:00
|
|
|
|
2026-06-07 20:13:03 +02:00
|
|
|
// ParseBytes parses YAML from an in-memory byte slice.
|
|
|
|
|
func ParseBytes(data []byte) (*Pipeline, error) {
|
2026-06-11 21:24:18 +02:00
|
|
|
// First pass: parse into a yaml.Node document to extract job keys with
|
|
|
|
|
// their exact source line numbers (key nodes carry the line, value nodes
|
|
|
|
|
// carry the body we decode into Job / map[string]any).
|
|
|
|
|
var doc yaml.Node
|
|
|
|
|
if err := yaml.Unmarshal(data, &doc); err != nil {
|
2026-06-05 01:29:07 +02:00
|
|
|
return nil, fmt.Errorf("parsing YAML: %w", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Second pass: decode known top-level fields into Pipeline.
|
|
|
|
|
p := &Pipeline{}
|
|
|
|
|
if err := yaml.Unmarshal(data, p); err != nil {
|
|
|
|
|
return nil, fmt.Errorf("parsing pipeline structure: %w", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
p.Jobs = make(map[string]Job)
|
|
|
|
|
p.RawJobs = make(map[string]map[string]any)
|
2026-06-11 21:24:18 +02:00
|
|
|
|
|
|
|
|
if doc.Kind != yaml.DocumentNode || len(doc.Content) == 0 {
|
|
|
|
|
return p, nil
|
|
|
|
|
}
|
|
|
|
|
root := doc.Content[0]
|
|
|
|
|
if root.Kind != yaml.MappingNode {
|
|
|
|
|
return p, nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Walk root mapping in key/value pairs.
|
|
|
|
|
for i := 0; i+1 < len(root.Content); i += 2 {
|
|
|
|
|
keyNode := root.Content[i]
|
|
|
|
|
valNode := root.Content[i+1]
|
|
|
|
|
key := keyNode.Value
|
2026-06-05 01:29:07 +02:00
|
|
|
if ReservedKeys[key] {
|
|
|
|
|
continue
|
|
|
|
|
}
|
2026-06-11 21:24:18 +02:00
|
|
|
|
2026-06-05 01:29:07 +02:00
|
|
|
var rawMap map[string]any
|
2026-06-11 21:24:18 +02:00
|
|
|
if err := valNode.Decode(&rawMap); err != nil {
|
2026-06-05 01:29:07 +02:00
|
|
|
return nil, fmt.Errorf("parsing raw job %q: %w", key, err)
|
|
|
|
|
}
|
|
|
|
|
p.RawJobs[key] = rawMap
|
|
|
|
|
|
|
|
|
|
var j Job
|
2026-06-11 21:24:18 +02:00
|
|
|
if err := valNode.Decode(&j); err != nil {
|
2026-06-05 01:29:07 +02:00
|
|
|
return nil, fmt.Errorf("parsing job %q: %w", key, err)
|
|
|
|
|
}
|
|
|
|
|
j.Name = key
|
2026-06-11 21:24:18 +02:00
|
|
|
j.Line = keyNode.Line // exact line of the job name key
|
2026-06-05 01:29:07 +02:00
|
|
|
p.Jobs[key] = j
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return p, nil
|
|
|
|
|
}
|