pipeline

type ApplyResult struct {
	Name    string `json:"name"`
	ID      int64  `json:"id"`
	Enabled bool   `json:"enabled"`
	Version int    `json:"version"`
}

type BlueprintCatalogEntry struct {
	Source          string
	Document        BlueprintDocument
	YAML            string
	Hash            string
	Missing         []string
	InstanceCount   int
	UpdateAvailable bool
}

type BlueprintDocument struct {
	Kind        string              `json:"kind" yaml:"kind"`
	ID          string              `json:"id" yaml:"id"`
	Title       string              `json:"title" yaml:"title"`
	Description string              `json:"description,omitempty" yaml:"description,omitempty"`
	Requires    BlueprintRequires   `json:"requires" yaml:"requires,omitempty"`
	Inputs      []BlueprintInputDef `json:"inputs,omitempty" yaml:"inputs,omitempty"`
	Definition  map[string]any      `json:"definition" yaml:"definition"`
}

type BlueprintInputDef struct {
	Name        string `json:"name" yaml:"name"`
	Type        string `json:"type" yaml:"type"`
	Required    bool   `json:"required,omitempty" yaml:"required,omitempty"`
	Default     any    `json:"default,omitempty" yaml:"default,omitempty"`
	Description string `json:"description,omitempty" yaml:"description,omitempty"`
}

type BlueprintLibrary interface {
	ListUserTemplates(ctx context.Context) ([]BlueprintTemplateRecord, error)
	GetUserTemplate(ctx context.Context, blueprintID string) (*BlueprintTemplateRecord, error)
	UpsertUserTemplate(ctx context.Context, rec BlueprintTemplateRecord) error
	DeleteUserTemplate(ctx context.Context, blueprintID string) error
}

type BlueprintOrigin struct {
	Source string         `json:"source"`
	ID     string         `json:"id"`
	Hash   string         `json:"hash"`
	YAML   string         `json:"yaml"`
	Inputs map[string]any `json:"inputs"`
}

type BlueprintOriginStore interface {
	CreateDefinition(ctx context.Context, name, description, createdBy string) error
	GetDefinitionByName(ctx context.Context, name string) (*model.PipelineDefinition, error)
	UpdateDefinitionDraft(ctx context.Context, name, yamlDraft string, version int) (*model.PipelineDefinition, error)
	PublishDefinition(ctx context.Context, name string, version int) (*model.PipelineDefinition, error)
	SetBlueprintOrigin(ctx context.Context, name string, origin BlueprintOrigin) error
	ClearBlueprintOrigin(ctx context.Context, name string) error
	ListLinkedPipelineNames(ctx context.Context, source, blueprintID string) ([]string, error)
	EnsureDefinitionCreatedBy(ctx context.Context, name, createdBy string) error
}

type BlueprintRequires struct {
	Capabilities []string `json:"capabilities,omitempty" yaml:"capabilities,omitempty"`
}

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

type BlueprintTemplateRecord struct {
	BlueprintID string
	Title       string
	Description string
	YAML        string
	Hash        string
	CreatedBy   string
}

type BuiltinBlueprint struct {
	Document BlueprintDocument
	YAML     string
	Hash     string
}

type CheckpointData struct {
	StepIndex   int                    `json:"step_index"`
	StepResults map[string]*StepResult `json:"step_results"`
	Event       types.DataEvent        `json:"event"`
	HeartbeatAt time.Time              `json:"heartbeat_at"`
}

type Clock interface {
	Now() time.Time
	After(d time.Duration) <-chan time.Time
}

type Definition struct {
	Name        string
	Description string
	Enabled     bool
	Resumable   bool
	// UID is the Web UI creator of this pipeline (from pipeline_definitions.created_by).
	// Applied to events when the trigger does not carry a UID (cron/webhook).
	UID        string
	Trigger    Trigger
	Steps      []Step
	ParentName string
}

type DefinitionCatalog interface {
	CreateDefinition(ctx context.Context, name, description, createdBy string) error
	GetDefinitionByName(ctx context.Context, name string) (*model.PipelineDefinition, error)
	UpdateDefinitionDraft(ctx context.Context, name, yamlDraft string, version int) (*model.PipelineDefinition, error)
	PublishDefinition(ctx context.Context, name string, version int) (*model.PipelineDefinition, error)
	EnsureDefinitionCreatedBy(ctx context.Context, name, createdBy string) error
	DeleteDefinitionByName(ctx context.Context, name string) (int64, error)
	ListPublishedDefinitions(ctx context.Context) ([]DefinitionRecord, error)
	GetRunsByParentName(ctx context.Context, parentName string) ([]*model.PipelineRun, error)
}

type DefinitionReader interface {
	ListPublishedDefinitions(ctx context.Context) ([]DefinitionRecord, error)
}

type DefinitionRecord struct {
	Name        string
	Description string
	YAML        string
	// CreatedBy is the Web UI user UID that created the pipeline.
	CreatedBy string
	UpdatedAt time.Time
}

type DefinitionSource func(ctx context.Context) ([]Definition, error)

type EditorDefinition struct {
	Name        string         `json:"name" yaml:"name"`
	Description string         `json:"description" yaml:"description"`
	Enabled     bool           `json:"enabled" yaml:"enabled"`
	Resumable   bool           `json:"resumable" yaml:"resumable"`
	Triggers    []TriggerEntry `json:"triggers" yaml:"triggers"`
	Steps       []Step         `json:"steps" yaml:"steps"`
}

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

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

type InstantiateRequest struct {
	Source       string
	BlueprintID  string
	PipelineName string
	Inputs       map[string]any
	Enable       bool
	CreatedBy    string
}

type ListInfo struct {
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Enabled     bool     `json:"enabled"`
	Resumable   bool     `json:"resumable"`
	Triggers    []string `json:"triggers"`
}

type RealClock struct{}

type RenderContext struct {
	Event types.DataEvent
	Steps map[string]map[string]any
	Input map[string]any
	// contains filtered or unexported fields
}

type RunStore interface {
	CreateRun(ctx context.Context, pipelineName, eventID, eventType, triggerSource string) (*model.PipelineRun, error)
	UpdateRunStatus(ctx context.Context, runID int64, status int, errMsg string) error
	CreateStepRun(ctx context.Context, runID int64, stepName, capName, operation string, params map[string]any, attempt int) (*model.PipelineStepRun, error)
	UpdateStepRun(ctx context.Context, stepRunID int64, status int, result map[string]any, errMsg string, attempt int) error
	ListStepRuns(ctx context.Context, runID int64) ([]*model.PipelineStepRun, error)
	ClaimFailedRun(ctx context.Context, runID int64) error
	PrepareStepRetry(ctx context.Context, stepRunID int64, params map[string]any, attempt int) error
	SaveCheckpoint(ctx context.Context, runID int64, data any) error
	GetIncompleteRuns(ctx context.Context) ([]*model.PipelineRun, error)
	GetCheckpoint(ctx context.Context, runID int64, target any) error
	GetRun(ctx context.Context, runID int64) (*model.PipelineRun, error)
	UpdateRunHeartbeat(ctx context.Context, runID int64) error
	HasConsumed(ctx context.Context, consumerName, eventID string) (bool, error)
	RecordConsumption(ctx context.Context, consumerName, eventID string) error
	RecordResourceLink(ctx context.Context, link model.ResourceLink) error
}

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

type Step struct {
	Name       string
	Capability hub.CapabilityType
	Operation  string
	Params     map[string]any
	Retry      *backoff.Config
}

type StepCallback interface {
	OnRunStart(ctx context.Context, runID int64, pipelineName string,
		trigger string, totalSteps int, stepNames []string)
	OnStepStart(ctx context.Context, runID int64, pipelineName string,
		stepIndex int, stepName string, input map[string]any)
	OnStepDone(ctx context.Context, runID int64, pipelineName string,
		stepIndex int, stepName string, output map[string]any, elapsedMs int64)
	OnStepError(ctx context.Context, runID int64, pipelineName string,
		stepIndex int, stepName string, err error, elapsedMs int64)
	OnRunComplete(ctx context.Context, runID int64, pipelineName string,
		elapsedMs int64, failed bool, errMsg string)
}

type StepProgressEvent struct {
	RunID        int64          `json:"run_id"`
	PipelineName string         `json:"pipeline_name"`
	StepIndex    int            `json:"step_index"`
	StepName     string         `json:"step_name"`
	Status       string         `json:"status"`
	Input        map[string]any `json:"input,omitempty"`
	Output       map[string]any `json:"output,omitempty"`
	ElapsedMs    int64          `json:"elapsed_ms,omitempty"`
	Error        string         `json:"error,omitempty"`
	TotalSteps   int            `json:"total_steps,omitempty"`
}

type StepResult struct {
	Name        string         `json:"name"`
	Capability  string         `json:"capability"`
	Operation   string         `json:"operation"`
	Output      map[string]any `json:"output"`
	CompletedAt time.Time      `json:"completed_at"`
}

type Trigger struct {
	Event       string
	Cron        string
	CronTimeout time.Duration
	Webhook     *WebhookConfig
}

type TriggerEntry struct {
	Enabled     bool           `json:"enabled" yaml:"enabled"`
	Type        string         `json:"type" yaml:"type"` // "event", "cron", "webhook"
	Event       string         `json:"event,omitempty" yaml:"event,omitempty"`
	Cron        string         `json:"cron,omitempty" yaml:"cron,omitempty"`
	CronTimeout string         `json:"cron_timeout,omitempty" yaml:"cron_timeout,omitempty"`
	Webhook     *WebhookConfig `json:"webhook,omitempty" yaml:"webhook,omitempty"`
}

type WebhookAuthConfig struct {
	Token       string
	HMACSecret  string
	HMACHeader  string
	TokenHeader string
}

type WebhookConfig struct {
	Path      string
	Method    string
	Auth      WebhookAuthConfig
	Payload   config.WebhookPayloadMode
	EventType string
}