forked from tangled.org/core
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140package workflow
import ( "fmt"
"tangled.sh/tangled.sh/core/api/tangled")
type Compiler struct { Trigger tangled.Pipeline_TriggerMetadata Diagnostics Diagnostics}
type Diagnostics struct { Errors []error Warnings []Warning}
func (d *Diagnostics) Combine(o Diagnostics) { d.Errors = append(d.Errors, o.Errors...) d.Warnings = append(d.Warnings, o.Warnings...)}
func (d *Diagnostics) AddWarning(path string, kind WarningKind, reason string) { d.Warnings = append(d.Warnings, Warning{path, kind, reason})}
func (d *Diagnostics) AddError(err error) { d.Errors = append(d.Errors, err)}
func (d Diagnostics) IsErr() bool { return len(d.Errors) != 0}
type Warning struct { Path string Type WarningKind Reason string}
type WarningKind string
var ( WorkflowSkipped WarningKind = "workflow skipped" InvalidConfiguration WarningKind = "invalid configuration")
// convert a repositories' workflow files into a fully compiled pipeline that runners acceptfunc (compiler *Compiler) Compile(p Pipeline) tangled.Pipeline { cp := tangled.Pipeline{ TriggerMetadata: &compiler.Trigger, }
for _, w := range p { cw := compiler.compileWorkflow(w)
// empty workflows are not added to the pipeline if len(cw.Steps) == 0 { continue }
cp.Workflows = append(cp.Workflows, &cw) }
return cp}
func (compiler *Compiler) compileWorkflow(w Workflow) tangled.Pipeline_Workflow { cw := tangled.Pipeline_Workflow{}
if !w.Match(compiler.Trigger) { compiler.Diagnostics.AddWarning( w.Name, WorkflowSkipped, fmt.Sprintf("did not match trigger %s", compiler.Trigger.Kind), ) return cw }
if len(w.Steps) == 0 { compiler.Diagnostics.AddWarning( w.Name, WorkflowSkipped, "empty workflow", ) return cw }
// validate clone options compiler.analyzeCloneOptions(w)
cw.Name = w.Name cw.Dependencies = w.Dependencies.AsRecord() for _, s := range w.Steps { step := tangled.Pipeline_Step{ Command: s.Command, Name: s.Name, } for k, v := range s.Environment { e := &tangled.Pipeline_Pair{ Key: k, Value: v, } step.Environment = append(step.Environment, e) } cw.Steps = append(cw.Steps, &step) } for k, v := range w.Environment { e := &tangled.Pipeline_Pair{ Key: k, Value: v, } cw.Environment = append(cw.Environment, e) }
o := w.CloneOpts.AsRecord() cw.Clone = &o
return cw}
func (compiler *Compiler) analyzeCloneOptions(w Workflow) { if w.CloneOpts.Skip && w.CloneOpts.IncludeSubmodules { compiler.Diagnostics.AddWarning( w.Name, InvalidConfiguration, "cannot apply `clone.skip` and `clone.submodules`", ) }
if w.CloneOpts.Skip && w.CloneOpts.Depth > 0 { compiler.Diagnostics.AddWarning( w.Name, InvalidConfiguration, "cannot apply `clone.skip` and `clone.depth`", ) }}