model

type Defaults struct {
	Timeout *Duration `yaml:"timeout,omitempty"`
	OnError string    `yaml:"onError,omitempty"`
	CWD     string    `yaml:"cwd,omitempty"`
}

type Duration struct {
	time.Duration
}

type FlowStep struct {
	// Participant is set for a bare string step reference, e.g. `- stepA`.
	Participant string
	// Loop is set for a loop control construct, e.g. `- loop: {...}`.
	Loop *LoopStep
	// Parallel is set for a parallel construct, e.g. `- parallel: [...]`.
	Parallel *ParallelStep
	// If is set for a conditional branch, e.g. `- if: "expr"\n  then: [...]`.
	If *IfStep
	// Override is set for a participant invocation with overrides, e.g. `- stepA:\n  timeout: 30m`.
	Override *ParticipantOverrideStep
	// InlineParticipant is set when a full participant definition appears
	// inline inside the flow (has fields like `as` and `type`).
	InlineParticipant *Participant
	// Wait is set for a wait control construct, e.g. `- wait: {...}`.
	Wait *WaitStep
	// Set is set for a set control construct, e.g. `- set: {key: expr}`.
	Set *SetStep
}

type IfStep struct {
	Condition string     `yaml:"condition"`
	Then      []FlowStep `yaml:"then"`
	Else      []FlowStep `yaml:"else,omitempty"`
}

type InputField struct {
	Type        string        `yaml:"type,omitempty"`
	Required    bool          `yaml:"required,omitempty"`
	Default     interface{}   `yaml:"default,omitempty"`
	Description string        `yaml:"description,omitempty"`
	Format      string        `yaml:"format,omitempty"`
	Enum        []interface{} `yaml:"enum,omitempty"`
	Minimum     *float64      `yaml:"minimum,omitempty"`
	Maximum     *float64      `yaml:"maximum,omitempty"`
	MinLength   *int          `yaml:"minLength,omitempty"`
	MaxLength   *int          `yaml:"maxLength,omitempty"`
	Pattern     string        `yaml:"pattern,omitempty"`
	Items       *InputField   `yaml:"items,omitempty"`
}

type LoopStep struct {
	// As optionally renames the loop context variable (e.g. `as: attempt`).
	As    string      `yaml:"as,omitempty"`
	Until string      `yaml:"until,omitempty"`
	Max   interface{} `yaml:"max,omitempty"`
	Steps []FlowStep  `yaml:"steps"`
}

type ParallelStep struct {
	Steps []FlowStep
}

type Participant struct {
	Type    ParticipantType `yaml:"type"`
	As      string          `yaml:"as,omitempty"`
	When    string          `yaml:"when,omitempty"`
	Timeout *Duration       `yaml:"timeout,omitempty"`
	OnError string          `yaml:"onError,omitempty"`
	Retry   *RetryConfig    `yaml:"retry,omitempty"`
	CWD     string          `yaml:"cwd,omitempty"`
	Input   interface{}     `yaml:"input,omitempty"`
	Output  interface{}     `yaml:"output,omitempty"`

	// exec
	Run string `yaml:"run,omitempty"`

	// http
	URL     string            `yaml:"url,omitempty"`
	Method  string            `yaml:"method,omitempty"`
	Headers map[string]string `yaml:"headers,omitempty"`
	Body    interface{}       `yaml:"body,omitempty"`

	// workflow
	Path string `yaml:"path,omitempty"`

	// mcp
	Server string `yaml:"server,omitempty"`
	Tool   string `yaml:"tool,omitempty"`

	// emit
	Event     string      `yaml:"event,omitempty"`
	Payload   interface{} `yaml:"payload,omitempty"`
	Ack       bool        `yaml:"ack,omitempty"`
	OnTimeout string      `yaml:"onTimeout,omitempty"`
}

type ParticipantOverrideStep struct {
	Participant string       `yaml:"-"`
	When        string       `yaml:"when,omitempty"`
	Timeout     *Duration    `yaml:"timeout,omitempty"`
	OnError     string       `yaml:"onError,omitempty"`
	Retry       *RetryConfig `yaml:"retry,omitempty"`
	Input       interface{}  `yaml:"input,omitempty"`
	Workflow    string       `yaml:"workflow,omitempty"`
}

type ParticipantType string

type RetryConfig struct {
	Max     int      `yaml:"max"`
	Backoff Duration `yaml:"backoff,omitempty"`
	Factor  float64  `yaml:"factor,omitempty"`
}

type SetStep struct {
	// Values maps context keys to CEL expressions.
	Values map[string]string
}

type WaitStep struct {
	Event     string    `yaml:"event,omitempty"`
	Match     string    `yaml:"match,omitempty"`
	Until     string    `yaml:"until,omitempty"`
	Poll      *Duration `yaml:"poll,omitempty"`
	Timeout   *Duration `yaml:"timeout,omitempty"`
	OnTimeout string    `yaml:"onTimeout,omitempty"`
}

type Workflow struct {
	ID           string                 `yaml:"id,omitempty"`
	Name         string                 `yaml:"name,omitempty"`
	Version      interface{}            `yaml:"version,omitempty"`
	Defaults     *Defaults              `yaml:"defaults,omitempty"`
	Inputs       map[string]InputField  `yaml:"inputs,omitempty"`
	Participants map[string]Participant `yaml:"participants,omitempty"`
	Flow         []FlowStep             `yaml:"flow"`
	Output       *WorkflowOutput        `yaml:"output,omitempty"`
}

type WorkflowOutput struct {
	// Expression is set when the output is a single string value.
	Expression string
	// Map is set when the output is a mapping of field names to CEL expressions.
	Map map[string]string
	// Schema is the optional schema->map style output (spec v0.2)
	Schema map[string]InputField
	// MapField used when output is provided as { schema: {...}, map: {...} }
	MapField map[string]string
}