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 CatchClause struct {
	ID       string                 `yaml:"id,omitempty" json:"id,omitempty"`
	When     cel.CELExpr            `yaml:"when,omitempty" json:"when,omitempty"`
	To       string                 `yaml:"to,omitempty" json:"to,omitempty"`
	Payload  map[string]interface{} `yaml:"payload,omitempty" json:"payload,omitempty"`
	Continue *CatchContinue         `yaml:"continue,omitempty" json:"continue,omitempty"`
	Fail     *CatchFail             `yaml:"fail,omitempty" json:"fail,omitempty"`
}

type CatchContinue struct {
	Outputs map[string]interface{} `yaml:"outputs,omitempty" json:"outputs,omitempty"`
}

type CatchFail struct {
	Kind    string      `yaml:"kind,omitempty" json:"kind,omitempty"`
	Code    string      `yaml:"code,omitempty" json:"code,omitempty"`
	Message string      `yaml:"message,omitempty" json:"message,omitempty"`
	Cause   interface{} `yaml:"cause,omitempty" json:"cause,omitempty"`
}

type ChildGroupAggregate struct {
	Shape    interface{} `yaml:"shape,omitempty" json:"shape,omitempty"`
	Artifact interface{} `yaml:"artifact,omitempty" json:"artifact,omitempty"`
}

type ChildGroupArtifacts struct {
	Use []interface{} `yaml:"use,omitempty" json:"use,omitempty"`
}

type ChildGroupChild struct {
	Key        interface{}            `yaml:"key,omitempty" json:"key,omitempty"`
	Recipe     interface{}            `yaml:"recipe,omitempty" json:"recipe,omitempty"`
	CellName   interface{}            `yaml:"cell_name,omitempty" json:"cell_name,omitempty"`
	Required   interface{}            `yaml:"required,omitempty" json:"required,omitempty"`
	When       interface{}            `yaml:"when,omitempty" json:"when,omitempty"`
	SkipReason interface{}            `yaml:"skip_reason,omitempty" json:"skip_reason,omitempty"`
	GitRef     interface{}            `yaml:"git_ref,omitempty" json:"git_ref,omitempty"`
	Inputs     map[string]interface{} `yaml:"inputs,omitempty" json:"inputs,omitempty"`
	Artifacts  []interface{}          `yaml:"artifacts,omitempty" json:"artifacts,omitempty"`
}

type ChildGroupData struct {
	Mode         string              `yaml:"mode,omitempty" json:"mode,omitempty"`
	Children     []ChildGroupChild   `yaml:"children,omitempty" json:"children,omitempty"`
	ChildrenFrom interface{}         `yaml:"children_from,omitempty" json:"children_from,omitempty"`
	Child        *ChildGroupChild    `yaml:"child,omitempty" json:"child,omitempty"`
	Artifacts    ChildGroupArtifacts `yaml:"artifacts,omitempty" json:"artifacts,omitempty"`
	Aggregate    ChildGroupAggregate `yaml:"aggregate,omitempty" json:"aggregate,omitempty"`
}

type Duration time.Duration

type ExecutionNeedResources struct {
	CPU              any `yaml:"cpu,omitempty" json:"cpu,omitempty"`
	Memory           any `yaml:"memory,omitempty" json:"memory,omitempty"`
	EphemeralStorage any `yaml:"ephemeral-storage,omitempty" json:"ephemeral-storage,omitempty"`
}

type ExecutionNeeds struct {
	Packages  []string               `yaml:"packages,omitempty" json:"packages,omitempty"`
	Resources ExecutionNeedResources `yaml:"resources,omitempty" json:"resources,omitempty"`
	Image     any                    `yaml:"image,omitempty" json:"image,omitempty"`
	Platform  any                    `yaml:"platform,omitempty" json:"platform,omitempty"`
}

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 FailureKind string

type FailureNode struct {
	ID   string          `json:"id,omitempty"`
	Path string          `json:"path,omitempty"`
	Type FailureNodeType `json:"type"`
	Op   string          `json:"op,omitempty"`
}

type FailureNodeType string

type FailureTask struct {
	Status     string `json:"status,omitempty"`
	ExitCode   *int   `json:"exit_code,omitempty"`
	StderrTail string `json:"stderr_tail,omitempty"`
	StdoutTail string `json:"stdout_tail,omitempty"`
}

type FailureTiming struct {
	Timeout string `json:"timeout,omitempty"`
	Scope   string `json:"scope,omitempty"`
	After   string `json:"after,omitempty"`
}

type HashComputer struct{}

type IncludeData struct {
	Recipe string `yaml:"recipe" json:"recipe"`
}

type InitialTransitions []Transition

type InlineInclusionMetadata struct {
	Execution         *execution.Requirements `yaml:"execution,omitempty" json:"execution,omitempty"`
	CallsitePath      string                  `yaml:"callsite_path,omitempty" json:"callsite_path,omitempty"`
	RecipeID          string                  `yaml:"recipe_id,omitempty" json:"recipe_id,omitempty"`
	RecipeVersion     string                  `yaml:"recipe_version,omitempty" json:"recipe_version,omitempty"`
	Source            RecipeSourceSnapshot    `yaml:"source,omitempty" json:"source,omitempty"`
	ContentSHA256     string                  `yaml:"content_sha256,omitempty" json:"content_sha256,omitempty"`
	ResolvedSelectors map[string]string       `yaml:"resolved_selectors,omitempty" json:"resolved_selectors,omitempty"`
}

type InputSchema struct {
	Secret      bool        `yaml:"secret,omitempty"`
	ObjectType  string      `yaml:"object_type,omitempty"`
	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 NodeChildGroup struct {
	NodeMetadata `yaml:",inline"`
	ChildGroup   ChildGroupData `yaml:"child_group" json:"child_group"`
}

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

type NodeInclude struct {
	NodeMetadata `yaml:",inline"`
	Include      IncludeData `yaml:"include" json:"include"`
}

type NodeInternalMetadata struct {
	Inline               *InlineInclusionMetadata `yaml:"inline,omitempty" json:"inline,omitempty"`
	CompositeInputSchema map[string]InputSchema   `yaml:"composite_input_schema,omitempty" json:"composite_input_schema,omitempty"`
}

type NodeList []Node

type NodeMetadata struct {
	Workspace      *WorkspaceSpec         `yaml:"workspace,omitempty" json:"workspace,omitempty"`
	ExecutionNeeds *ExecutionNeeds        `yaml:"execution_needs,omitempty" json:"execution_needs,omitempty"`
	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
	Catch          []CatchClause          `yaml:"catch,omitempty" json:"catch,omitempty"`
	Internal       *NodeInternalMetadata  `yaml:"__c2j_internal,omitempty" json:"__c2j_internal,omitempty" jsonschema:"-"`
}

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)
	VisitRecipeChildGroup(node *RecipeChildGroup, path []string) (*RecipeChildGroup, error)

	// Intermediate node visitors - return (replacement, error)
	VisitNodeOp(node *NodeOp, path []string) (Node, error)
	VisitNodeChildGroup(node *NodeChildGroup, path []string) (Node, error)
	VisitNodeInclude(node *NodeInclude, 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 RecipeChildGroup struct {
	RecipeMetadata `yaml:",inline" refer:"true"`
	ChildGroup     ChildGroupData `yaml:"child_group" json:"child_group"`
}

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 {
	Execution    *execution.Requirements `yaml:"execution,omitempty" json:"execution,omitempty"`
	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 RecipeSourceSnapshot struct {
	SourceKind        string `yaml:"source_kind,omitempty" json:"source_kind,omitempty"`
	SubmittedSelector string `yaml:"submitted_selector,omitempty" json:"submitted_selector,omitempty"`
	ResolvedSelector  string `yaml:"resolved_selector,omitempty" json:"resolved_selector,omitempty"`
	ResolvedCommit    string `yaml:"resolved_commit,omitempty" json:"resolved_commit,omitempty"`
	ArtifactName      string `yaml:"artifact_name,omitempty" json:"artifact_name,omitempty"`
	WasAlreadyPinned  bool   `yaml:"was_already_pinned,omitempty" json:"was_already_pinned,omitempty"`
}

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

type RetryPolicy = jobdb.RetryPolicy

type RuntimeFailure struct {
	Kind      FailureKind                    `json:"kind"`
	Code      string                         `json:"code,omitempty"`
	Message   string                         `json:"message"`
	Retryable bool                           `json:"retryable"`
	Node      FailureNode                    `json:"node"`
	Timing    *FailureTiming                 `json:"timing,omitempty"`
	Task      *FailureTask                   `json:"task,omitempty"`
	Artifacts map[string]recipeartifacts.Ref `json:"artifacts,omitempty"`
	Attrs     map[string]interface{}         `json:"attrs,omitempty"`
	Cause     *RuntimeFailure                `json:"cause,omitempty"`
}

type SequenceData struct {
	Sequence NodeList               `yaml:"sequence"`
	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
}

type WorkspaceSpec struct {
	Cell string `yaml:"cell" json:"cell"`
	Ref  string `yaml:"ref,omitempty" json:"ref,omitempty"`
}