schema

type Condition struct {
	// Text
	Include []string `json:"include" yaml:"include"`
	Exclude []string `json:"exclude" yaml:"exclude"`

	// Env
	IncludeEnv []string `json:"include env" yaml:"include env"`
	ExcludeEnv []string `json:"exclude env" yaml:"exclude env"`

	// Vars
	IncludeVar []string `json:"include var" yaml:"include var"`
	ExcludeVar []string `json:"exclude var" yaml:"exclude var"`

	// Regex
	Match    []string `json:"match" yaml:"match"`
	Mismatch []string `json:"mismatch" yaml:"mismatch"`
}

type Env struct {
	Value    string `json:"value" yaml:"value"`
	Priority uint32 `json:"priority" yaml:"priority"`
	Secret   bool   `json:"secret" yaml:"secret"`
}

type EnvParam struct {
	Env     string   `json:"env" yaml:"env"`
	Replace []string `json:"replace" yaml:"replace"`
}

type Error string

type Fact []string

type FullMessage struct {
	Message
	Source string
}

type LiteralCommand []string

type LiteralParam string

type LogReader interface {
	io.ReadSeekCloser

	ReadAt(p []byte, offset int64) (n int, err error)
	Size() (int64, bool)
}

type LogReaderProvider interface {
	Available() bool
	Reader() (LogReader, error)
	io.Closer
}

type Message struct {
	Target  string            `json:"target"`
	Options map[string]string `json:"options"`
	Data    []byte            `json:"data"`
}

type Pipeline struct {
	PipelineDefinition `yaml:",inline"`

	Env            map[string]Env    `json:"env" yaml:"env"`
	Facts          map[string]Fact   `json:"facts" yaml:"facts"`
	TaskDomains    map[string]string `json:"taskDomains" yaml:"taskDomains"`
	TrustedDomains []string          `json:"trustedDomains" yaml:"trustedDomains"`
	TrustedTasks   []string          `json:"trustedTasks" yaml:"trustedTasks"`

	Setup Setup `json:"setup" yaml:"setup"`
}

type PipelineDefinition struct {
	Name        string               `json:"name" yaml:"name"`
	Headline    string               `json:"headline" yaml:"headline"`
	Description string               `json:"description" yaml:"description"`
	When        map[string]Condition `json:"when" yaml:"when"`
	Steps       []Step               `json:"steps" yaml:"steps"`
}

type PipelineResult struct {
	Success  bool   `json:"success"`
	ExitCode int    `json:"exitCode"`
	Error    string `json:"error"`
}

type PipelineStatus struct {
	Pipeline    Pipeline
	WorkerGroup string
	ActivityID  string

	Status Status
	Logs   LogReaderProvider
	Result PipelineResult
}

type RawCommand any

type RawParam any

type ResolvedRunConfig struct {
	Command   []string
	Input     string
	Directory string
	User      string
	Params    map[string]string
}

type RunConfig struct {
	Task      string              `json:"task" yaml:"task"`
	Command   RawCommand          `json:"command" yaml:"command"`
	Input     RawParam            `json:"input" yaml:"input"`
	Directory RawParam            `json:"directory" yaml:"directory"`
	User      RawParam            `json:"user" yaml:"user"`
	Params    map[string]RawParam `json:"params" yaml:"params"`
}

type Setup struct {
	RunConfig `yaml:",inline"`
}

type Status string

type Step struct {
	RunConfig `yaml:",inline"`

	Name          string               `json:"name" yaml:"name"`
	Stage         string               `json:"stage" yaml:"stage"`
	When          map[string]Condition `json:"when" yaml:"when"`
	IgnoreFailure bool                 `json:"ignoreFailure" yaml:"ignoreFailure"`
}

type Trigger map[string]string

type Var string

type VarParam struct {
	Var     string   `json:"var" yaml:"var"`
	Replace []string `json:"replace" yaml:"replace"`
}

type WorkerAckRequest struct {
	Contract string `json:"contract"`
}

type WorkerLogsPositionResponse struct {
	Position int64 `json:"position"`
}

type WorkerQueueResponse struct {
	Contract string   `json:"contract"`
	Activity string   `json:"activity"`
	Pipeline Pipeline `json:"pipeline"`
}