workflow

type Binding struct {
	Kind          BindingKind
	WorkflowInput string
	InstanceID    string
	OutputName    string
}

type BindingKind string

type ComposeOptions struct {
	// WorkflowSlug is empty when the request should create a workflow.
	WorkflowSlug string
	// BaseSpec is the spec being edited — the draft when one
	// exists, else the saved file. Empty for a create.
	BaseSpec string
	Request  string
	Harness  agent.Harness
	Model    string
	// ReasoningEffort is medium when empty.
	ReasoningEffort runtimetypes.ReasoningEffort
	// Catalog lists installed harnesses and their real model ids, so
	// the agent never invents a model name.
	Catalog string
}

type ComposeResult struct {
	WorkflowSlug string
	Action       string
	YAML         string
	Summary      string
}

type CreatedDraft struct {
	WorkflowSlug string
	Spec         string
}

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

type ExecutionRecorder interface {
	StartWorkflow(ctx context.Context, snapshot *Snapshot, input map[string]any, project string) (WorkflowExecutionHandle, error)
	FinishWorkflow(ctx context.Context, handle WorkflowExecutionHandle, output map[string]any, status executionmodels.WorkflowExecutionStatus) error
	StartNode(ctx context.Context, workflow WorkflowExecutionHandle, node NodeSnapshot, input map[string]any, scope NodeExecutionScope) (NodeExecutionHandle, error)
	FinishNode(ctx context.Context, handle NodeExecutionHandle, output map[string]any, status executionmodels.NodeExecutionStatus, trace map[string]any) error
	StartConversation(ctx context.Context, handle NodeExecutionHandle, conversation *agent.Conversation, input map[string]any) error
	FinishConversation(ctx context.Context, conversation *agent.Conversation, output any) error
}

type Executor struct {
	NewHarness func(kind agent.Harness) (harnesses.Harness, error)
	Recorder   ExecutionRecorder
	ProjectDir string
	// SeedOutputs pre-completes top-level nodes with recorded outputs
	// from a previous execution ("re-run from here"). Seeded nodes are
	// never executed or recorded again.
	SeedOutputs map[string]map[string]any
}

type FlowSpec struct {
	Instances map[string]InstanceSpec `yaml:"instances"`
}

type InferenceNodeConfig struct {
	Harness     map[string]any `yaml:"harness"`
	Instruction string         `yaml:"instruction"`
}

type InstanceSpec struct {
	Node   string            `yaml:"node"`
	Inputs map[string]string `yaml:"inputs"`
}

type NodeConfigUpdate struct {
	Model       *string
	Harness     *string
	Instruction *string
	// "" removes the field — the harness default takes over.
	ReasoningEffort *string
	// "" removes the field — the compiler defaults to read_only.
	Permissions *string
}

type NodeExecutionHandle struct {
	ID uuid.UUID
}

type NodeExecutionScope struct {
	ParentNodeExecutionID uuid.UUID
	IterationIndex        *int
	BranchName            string
}

type NodeSnapshot struct {
	InstanceID                string
	NodeName                  string
	Kind                      string
	Operation                 string
	Executes                  string
	Over                      string
	Updates                   string
	BreaksOn                  string
	MaxIterations             int
	RoutesOn                  string
	WhenTrue                  string
	WhenFalse                 string
	Instruction               string
	Harness                   agent.Harness `json:"Harness,omitempty"`
	Model                     string
	ReasoningEffort           runtimetypes.ReasoningEffort `json:"ReasoningEffort,omitempty"`
	HarnessConfig             json.RawMessage
	Inputs                    map[string]Port
	InputOrder                []string
	InputBindings             map[string]Binding
	Outputs                   map[string]Port
	Workflow                  *Snapshot
	OutputName                string
	OutputSchema              map[string]any
	StructuredOutputSchema    map[string]any
	StructuredOutputSchemaRaw json.RawMessage
	WrapStructuredOutput      bool
	LoopTarget                *NodeSnapshot
	WhileTarget               *WhileTargetSnapshot
	TrueTarget                *NodeSnapshot
	FalseTarget               *NodeSnapshot
}

type NodeSpec struct {
	Kind          string              `yaml:"kind"`
	WorkflowSlug  string              `yaml:"workflow_slug"`
	Operation     string              `yaml:"operation"`
	Executes      string              `yaml:"executes"`
	Over          string              `yaml:"over"`
	Updates       string              `yaml:"updates"`
	BreaksOn      string              `yaml:"breaks_on"`
	MaxIterations int                 `yaml:"max_iterations"`
	RoutesOn      string              `yaml:"routes_on"`
	WhenTrue      string              `yaml:"when_true"`
	WhenFalse     string              `yaml:"when_false"`
	Inputs        map[string]string   `yaml:"inputs"`
	Outputs       map[string]string   `yaml:"outputs"`
	Config        InferenceNodeConfig `yaml:"config"`
}

type ObservedRecorder struct {
	Inner    ExecutionRecorder
	Observer RunObserver
	// contains filtered or unexported fields
}

type OutputBinding struct {
	Name   string
	Schema map[string]any
	From   Binding
}

type Port struct {
	Name    string
	TypeRef string
	Schema  map[string]any
}

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

type RenameResult struct {
	WorkflowSlug string
	// UpdatedRefs lists workflow ids whose specs embedded the
	// renamed workflow and were rewritten to the new id.
	UpdatedRefs []string
}

type RunObserver interface {
	NodeStarted(instanceID string)
	NodeFinished(instanceID string, status executionmodels.NodeExecutionStatus)
}

type SavedDraft struct {
	WorkflowSlug string `json:"workflow_slug"`
	Version      string `json:"version"`
	Spec         string `json:"spec"`
}

type SchemaSpec struct {
	Type        string                `yaml:"type"`
	SchemaRef   string                `yaml:"schema_ref"`
	Properties  map[string]SchemaSpec `yaml:"properties"`
	Items       *SchemaSpec           `yaml:"items"`
	Enum        []any                 `yaml:"enum"`
	Optional    bool                  `yaml:"optional"`
	Description string                `yaml:"description"`
	Nullable    bool                  `yaml:"nullable"`
}

type Snapshot struct {
	WorkflowSlug    string
	WorkflowID      string
	WorkflowVersion string
	Description     string
	Inputs          map[string]Port
	Outputs         map[string]OutputBinding
	Nodes           map[string]NodeSnapshot
	Order           []string
}

type Spec struct {
	Workflow        WorkflowHeader        `yaml:"workflow"`
	Schemas         map[string]SchemaSpec `yaml:"schemas"`
	Nodes           map[string]NodeSpec   `yaml:"nodes"`
	Flow            FlowSpec              `yaml:"flow"`
	SourcePath      string                `yaml:"-"`
	NodeInputOrder  map[string][]string   `yaml:"-"`
	NodeOutputOrder map[string][]string   `yaml:"-"`
}

type WhileTargetSnapshot struct {
	InstanceID                string
	NodeName                  string
	Instruction               string
	Harness                   agent.Harness `json:"Harness,omitempty"`
	Model                     string
	ReasoningEffort           runtimetypes.ReasoningEffort `json:"ReasoningEffort,omitempty"`
	HarnessConfig             json.RawMessage
	Inputs                    map[string]Port
	Workflow                  *Snapshot
	UpdateOutputName          string
	UpdateOutputSchema        map[string]any
	BreakOutputName           string
	StructuredOutputSchema    map[string]any
	StructuredOutputSchemaRaw json.RawMessage
}

type WorkflowExecutionHandle struct {
	ID uuid.UUID
}

type WorkflowHeader struct {
	// Slug is the human-facing handle — renameable, used in the CLI,
	// URLs, and cross-workflow references.
	Slug string `yaml:"slug"`
	// ID is the workflow's permanent identity, a uuid that run history
	// keys on. Stamped automatically, never hand-edited.
	ID          string                        `yaml:"id,omitempty"`
	Name        string                        `yaml:"name"`
	Version     string                        `yaml:"version"`
	Description string                        `yaml:"description"`
	Inputs      map[string]string             `yaml:"inputs"`
	Outputs     map[string]WorkflowOutputSpec `yaml:"outputs"`
}

type WorkflowOutputSpec struct {
	Schema string `yaml:"schema"`
	From   string `yaml:"from"`
}

type WorkflowSummary struct {
	Slug        string            `json:"slug"`
	ID          string            `json:"id,omitempty"`
	Name        string            `json:"name"`
	Version     string            `json:"version,omitempty"`
	Description string            `json:"description,omitempty"`
	Inputs      map[string]string `json:"inputs"`
	Outputs     map[string]string `json:"outputs"`
	// HasDraft marks unsaved composer changes; DraftOnly marks a
	// workflow that exists only as a draft (never saved).
	HasDraft  bool `json:"has_draft,omitempty"`
	DraftOnly bool `json:"draft_only,omitempty"`
}

type WorkflowVersionInfo struct {
	Version   int       `json:"version"`
	Current   bool      `json:"current,omitempty"`
	CreatedAt time.Time `json:"created_at"`
}