compiler

type Agent struct {
	Node *ast.AgentNode
	// contains filtered or unexported fields
}

type AgentStep struct {
	Agent      *Agent
	OutputName string
	Retry      *Retry
}

type Compiler struct {
	// contains filtered or unexported fields
}

type ForeachStep struct {
	UsesAgent  *Agent      // Optional: agent to generate array
	Selector   cel.Program // Optional: CEL program to extract array
	Job        *Job        // Job to execute for each item (resolved)
	JobName    string      // Job name for resolution
	OutputName string
	Retry      *Retry
	Formatter  Formatter // Output serialization format
}

type Formatter interface {
	// Format converts array of results into serialized output.
	// Input: results from foreach iterations ([]any)
	// Output: serialized data (any) - typically string or []any
	Format(results []any) (any, error)
}

type JSONFormatter struct{}

type JSONLFormatter struct{}

type Job struct {
	Name  string
	Steps []Step
}

type Retry struct {
	Attempts int
	Delay    int
	Yield    *Agent
}

type RouterStep struct {
	Agent      *Agent
	OutputName string
	RouteNodes []ast.RouteNode // For reference
	Conditions []cel.Program   // Compiled CEL expressions
	Routes     map[string]*Job // Resolved job references
	DefaultJob string          // Default job name
	Default    *Job            // Resolved default job
	Retry      *Retry
}

type RunStep struct {
	Command    string // Compiled template for the command
	Shell      string // Shell to use (sh, bash, zsh, etc.)
	OutputName string
	Retry      *Retry
}

type Server struct {
	// contains filtered or unexported fields
}

type Step interface {
	Prompt(ctx context.Context, opt ...chatter.Opt) error
	GetOutputName() string
}

type TextFormatter struct {
	Delimiter string
}

type Workflow struct {
	Name       string
	About      string
	Entrypoint string // Optional: default job name, or "main" if empty
	Schema     ast.SchemaNode
	Jobs       map[string]*Job
}

type WorkflowContext struct {
	// Input is the original workflow input
	Input any

	// State is a shared key-value store for workflow data
	State map[string]any

	// Steps holds named outputs from previous steps
	Steps map[string]any

	// Current is the most recent step output (for chaining)
	Current any
}