pipeline

type Concurrency struct {
	MaxParallel int    `yaml:"maxParallel,omitempty"`
	OnFailure   string `yaml:"onFailure,omitempty"`
}

type DAG struct {
	Nodes []*Node // topologically sorted; roots first
	// contains filtered or unexported fields
}

type Executor struct {
	Runner Runner
}

type Node struct {
	Step       *Step
	Deps       []*Node // steps this one waits on
	Dependents []*Node // steps waiting on this one
}

type Pipeline struct {
	Name        string         `yaml:"name"`
	Description string         `yaml:"description,omitempty"`
	Variables   map[string]any `yaml:"variables,omitempty"`
	Concurrency *Concurrency   `yaml:"concurrency,omitempty"`
	Defaults    *StepDefaults  `yaml:"defaults,omitempty"`
	Steps       []*Step        `yaml:"steps"`
}

type Record = map[string]any

type Reference struct {
	Raw  string   // the literal "${{ ... }}" including braces, for replacement
	Path []string // dotted path split on "."
}

type Resolver struct {
	State *State
	Env   func(string) string // defaults to os.Getenv when nil
}

type Runner interface {
	Run(ctx context.Context, s *Step, input []Record) ([]Record, error)
}

type State struct {
	Variables map[string]any
	// contains filtered or unexported fields
}

type Step struct {
	Name    string         `yaml:"name"`
	Command string         `yaml:"command"`
	Params  map[string]any `yaml:"params,omitempty"`
	Body    any            `yaml:"body,omitempty"`
	Format  string         `yaml:"format,omitempty"`

	InputFrom string            `yaml:"inputFrom,omitempty"`
	Outputs   map[string]string `yaml:"outputs,omitempty"`

	DependsOn       []string `yaml:"dependsOn,omitempty"`
	Condition       string   `yaml:"condition,omitempty"`
	ContinueOnError bool     `yaml:"continueOnError,omitempty"`

	Count        int     `yaml:"count,omitempty"`
	Parallelism  *int    `yaml:"parallelism,omitempty"`
	RetryCount   *int    `yaml:"retryCount,omitempty"`
	IgnoreErrors *bool   `yaml:"ignoreErrors,omitempty"`
	StatusCode   string  `yaml:"statusCode,omitempty"`
	Verbose      *bool   `yaml:"verbose,omitempty"`
	BasePath     *string `yaml:"basePath,omitempty"`
	Scheme       *string `yaml:"scheme,omitempty"`
	Server       *string `yaml:"server,omitempty"`
	Jwt          *string `yaml:"jwt,omitempty"`
}

type StepDefaults struct {
	Verbose      *bool   `yaml:"verbose,omitempty"`
	IgnoreErrors *bool   `yaml:"ignoreErrors,omitempty"`
	RetryCount   *int    `yaml:"retryCount,omitempty"`
	Parallelism  *int    `yaml:"parallelism,omitempty"`
	StatusCode   *string `yaml:"statusCode,omitempty"`
	BasePath     *string `yaml:"basePath,omitempty"`
	Scheme       *string `yaml:"scheme,omitempty"`
	Server       *string `yaml:"server,omitempty"`
	Jwt          *string `yaml:"jwt,omitempty"`
	Doc          *string `yaml:"doc,omitempty"`
}

type StepResult struct {
	Status  StepStatus
	Records []Record       // records the step emitted (may be nil if none)
	Outputs map[string]any // extracted per the step's outputs: block
	Err     error
}

type StepStatus int

type SubprocessRunner struct {
	// Binary is the path to the tcli executable. When empty, os.Executable()
	// is used, which is correct when the current process itself is tcli.
	Binary string

	// Stderr, if set, is where the child's stderr is copied. Defaults to
	// os.Stderr so tcli's logs surface during a pipeline run.
	Stderr io.Writer
}