recipe

type ActivityExecution struct {
	Name      string // Activity name from YAML definition
	Status    string // Use string for flexibility
	StartTime time.Time
	EndTime   time.Time
	Duration  *time.Duration
	Result    map[string]interface{}
	Error     string
	Attempt   int

	ActivityID   string
	ActivityType string
}

type ActivityStatus string

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

type Duration time.Duration

type ExtensionFunctionImport struct {
	Selector string            `yaml:"selector"`
	Include  []string          `yaml:"include,omitempty"`
	Rename   map[string]string `yaml:"rename,omitempty"`
}

type ExtensionImports struct {
	Functions []ExtensionFunctionImport `yaml:"functions,omitempty"`
}

type HashComputer struct{}

type InitialTransitions []Transition

type InputSchema struct {
	Type        string      `yaml:"type,omitempty"`                                                // Type of the input (string, number, boolean, etc.)
	Description string      `yaml:"description,omitempty"`                                         // Description of the input
	Required    bool        `yaml:"required,omitempty"`                                            // Whether the input is required
	Default     interface{} `yaml:"default_value,omitempty" jsonschema:"oneof_type=string;number"` // Default value if not provided
}

type Job struct {
	ID            string
	RecipeName    string
	RecipeVersion string
	Status        JobStatus
	StartTime     time.Time
	EndTime       *time.Time
	UpdateTime    time.Time
	Input         map[string]interface{}
	Output        map[string]interface{}
	Error         string

	// Optional fields
	Duration     *time.Duration
	Inputs       map[string]interface{} // alias for Input
	Outputs      map[string]interface{} // alias for Output
	Activities   []*ActivityExecution
	WorkflowType string

	ExecutionInfo *WorkflowExecutionInfo
}

type JobFilter struct {
	RecipeName string
	Status     *JobStatus
	StartTime  *time.Time
	EndTime    *time.Time
	Limit      int
}

type JobStatus string

type Node struct {
	NodeImpl
}

type NodeImpl interface {
	GetMetadata() NodeMetadata
	// contains filtered or unexported methods
}

type NodeList []Node

type NodeMetadata struct {
	ID        string                 `yaml:"id,omitempty"`
	Desc      string                 `yaml:"desc,omitempty"`
	Const     bool                   `yaml:"const,omitempty"`
	Timeout   Duration               `yaml:"timeout,omitempty"`
	Retry     *RetryPolicy           `yaml:"retry,omitempty"`
	Inputs    map[string]interface{} `yaml:"inputs,omitempty"`
	Vars      map[string]interface{} `yaml:"vars,omitempty"`
	Artifacts map[string]interface{} `yaml:"artifacts,omitempty"`
	When      cel.CELExpr            `yaml:"when,omitempty"` // Conditional execution
}

type NodeOp struct {
	NodeMetadata `yaml:",inline"`
	OpData       `yaml:",inline"`
}

type NodeSequence struct {
	NodeMetadata `yaml:",inline"`
	SequenceData `yaml:",inline"`
}

type NodeShared struct {
	Shared string `yaml:"shared"`
}

type NodeState struct {
	NodeMetadata     `yaml:",inline"`
	StateMachineData `yaml:",inline"`
}

type NodeVisitor interface {
	// Root node visitors - return (replacement, error)
	VisitRecipe(recipe *Recipe) (Recipe, error)
	VisitRecipeOp(node *RecipeOp, path []string) (*RecipeOp, error)
	VisitRecipeSequence(node *RecipeSequence, path []string) (*RecipeSequence, error)
	VisitRecipeState(node *RecipeState, path []string) (*RecipeState, error)

	// Intermediate node visitors - return (replacement, error)
	VisitNodeOp(node *NodeOp, path []string) (Node, error)
	VisitNodeShared(node *NodeShared, path []string) (Node, error)
	VisitNodeSequence(node *NodeSequence, path []string) (Node, error)
	VisitNodeState(node *NodeState, path []string) (Node, error)

	// Control whether to traverse children of container nodes
	ShouldTraverseSequenceChildren(node *NodeSequence, path []string) bool
	ShouldTraverseStateChildren(node *NodeState, path []string) bool
}

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

type OpData struct {
	Op string `yaml:"op"`
}

type Recipe struct {
	RecipeImpl
}

type RecipeFile struct {
	// Core identity
	ID          string
	Version     string
	Description string

	// File paths
	BasePath string // Directory containing the recipe

	// Content
	Recipe Recipe

	// Metadata
	Hash         string // Canonical hash of recipe content
	LastModified time.Time
}

type RecipeImpl interface {
	GetMetadata() RecipeMetadata
	// contains filtered or unexported methods
}

type RecipeManifest struct {
	Recipe struct {
		Name        string `yaml:"name"`
		Version     string `yaml:"version"`
		Description string `yaml:"description"`
		Files       struct {
			Workflow   string `yaml:"workflow"`
			Activities string `yaml:"activities"`
			Agents     string `yaml:"agents"`
		} `yaml:"files"`
	} `yaml:"recipe"`
}

type RecipeMetadata struct {
	Version      string `yaml:"version"`
	NodeMetadata `yaml:",inline"`
	Defs         map[string]Node        `yaml:"defs,omitempty"`         // Shared node definitions
	InputSchema  map[string]InputSchema `yaml:"input_schema,omitempty"` // Optional schema for inputs
	Extensions   ExtensionImports       `yaml:"extensions,omitempty"`
}

type RecipeOp struct {
	RecipeMetadata `yaml:",inline" refer:"true"`
	OpData         `yaml:",inline" refer:"true"`
}

type RecipeProvider interface {
	GetRecipe(name string) (*Recipe, error)
}

type RecipeSequence struct {
	RecipeMetadata `yaml:",inline" refer:"true"`
	SequenceData   `yaml:",inline" refer:"true"`
}

type RecipeState struct {
	RecipeMetadata   `yaml:",inline" refer:"true"`
	StateMachineData `yaml:",inline" refer:"true"`
}

type RetryPolicy = swf.RetryPolicy

type SequenceData struct {
	Sequence NodeList               `yaml:"sequence,omitempty"`
	Outputs  map[string]interface{} `yaml:"outputs,omitempty"`
}

type SharedNodeResolver struct {
	BaseVisitor // Embed to get default implementations
	// contains filtered or unexported fields
}

type SingleStateMetadata struct {
	Transitions []Transition `yaml:"transitions,omitempty" json:"transitions,omitempty"`
}

type State struct {
	Node                `yaml:",inline"`
	SingleStateMetadata `yaml:",inline"`
}

type StateMachineData struct {
	States  *StateMap              `yaml:"state,omitempty"`
	Outputs map[string]interface{} `yaml:"outputs,omitempty"`
}

type StateMap struct {
	Initial InitialTransitions `yaml:"initial" validate:"required"` // State selector transitions (string is supported as shorthand)
	States  map[string]State   `yaml:"states"`                      // Inline the states
}

type Transition struct {
	To      string                 `yaml:"to"`
	When    cel.CELExpr            `yaml:"when,omitempty"` // CEL expression
	Payload map[string]interface{} `yaml:"payload,omitempty"`
}

type WorkerStatus string

type WorkflowExecutionInfo struct {
	JobId string
}