workflow

type Command func(ctx Context)

type Condition = any

type ConditionFunc = func(ctx Context) (bool, error)

type Context struct {
	context.Context

	// Workflow is the current workflow.
	Workflow Workflow
	// Job is the current job.
	Job Job
	// Step is the current step.
	Step Step

	// Outputs holds the outputs of steps and jobs, mapped by their path.
	// Outputs should not be written directly, as they are managed by the workflow
	// runtime.
	// Example:
	//   ctx.Outputs["step.getManifests.manifests"]
	//   ctx.Outputs["jobs.oci.step.getManifests.manifests"]
	Outputs map[string]any

	// Values holds values (variables) stored by calling Store on a step to store
	// a named output. Values can later be used as inputs.
	// Values should not be written directly, as they are managed by the workflow
	// runtime.
	// Example:
	//    FetchTitlesFromIMDB().Store("titles", "movieTitles")
	//    CreateReportFromTitles("movieTitles")
	Values map[string]any

	// Error holds any current error of the context.
	Error error
}

type Input = any

type Job struct {
	ID        string
	Name      string
	Steps     []Step
	DependsOn []string
	If        Condition
}

type Ref struct {
	Key string
}

type Step struct {
	ID   string
	Name string

	// Inputs holds a map of named inputs that can be used by the step.
	Inputs map[string]Input

	Main func(ctx Context) (Command, error)
	If   Condition

	Post   func(ctx Context) error
	PostIf Condition
}

type StepFunc func(ctx Context) (Command, error)

type Workflow struct {
	Name string
	Jobs []Job
}