executiondag

type BaseOutput struct {
	Status       Status `json:"status,omitempty"`
	StatusReason string `json:"status_reason,omitempty"`
}

type DAG[TInput any] struct {
	// contains filtered or unexported fields
}

type DataSourceInfo struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	URL         string `json:"url"`
}

type Entry struct {
	Key       string
	Data      any
	Extension string
}

type NoFetchProvider interface {
	GetNoFetch() bool
}

type Node[TInput any, TOutput StatusProvider] interface {
	// Execute runs the node's logic
	// - ctx: context for cancellation, logging, and accessing previous node outputs via GetOutput
	// - input: the input data for the node. MUST be treated as read-only. The
	//   DAG runs sibling nodes in a stage in parallel and passes the same input
	//   by value to each; if input contains pointer or slice fields, mutating
	//   them from inside Execute will race against other workers in the stage.
	// Returns the node's output or an error
	// If output.GetStatus() == StatusSkipped, dependent nodes are auto-skipped
	// (unless they implement SkipPropagationNode with AllowAutoSkip() returning false)
	// Any error halts the entire DAG execution
	Execute(ctx context.Context, input TInput) (TOutput, error)

	// GetDependencies returns the dependency keys for this node
	// Use DependsOn[T]() to create dependency keys
	GetDependencies() []any

	// CreateSkippedOutput creates a skipped output with the given reason
	// Called by the DAG framework when this node is auto-skipped due to a dependency being skipped
	// The implementation should return an output with StatusSkipped and appropriate zero/nil values for fields
	CreateSkippedOutput(reason string, input TInput) TOutput

	// Kind returns the kind/category of this node (e.g., "transformer", "scanner", "check")
	Kind() string
}

type NodeSummary struct {
	NodeType     string          `json:"node_type"`               // Type name of the node
	Status       string          `json:"status"`                  // "success", "skipped", "error"
	FilesWritten []string        `json:"files_written,omitempty"` // Paths to files written by this node
	Stats        map[string]any  `json:"stats,omitempty"`         // Node-specific statistics (e.g., records fetched, items processed)
	DataSource   *DataSourceInfo `json:"data_source,omitempty"`   // Non-nil for fetch nodes that consult external sources
}

type OutputSummary interface {
	Summary(outputDir string) NodeSummary
}

type OverridableV2 interface {
	ApplyOverridesV2([]overrides.Override) ([]overrides.AppliedOverride, error)
	GetSupportedOverrides() []overrides.FieldInfo
}

type Persistable interface {
	PersistKey() string
}

type ReadableNode[TInput any, TOutput StatusProvider] interface {
	Node[TInput, TOutput]
	Read(ctx context.Context, input TInput) (TOutput, error)
}

type SkipPropagationNode interface {
	// AllowAutoSkip returns whether this node should be automatically skipped
	// when one or more of its dependencies are skipped.
	// - Return true: node will be auto-skipped (default behavior)
	// - Return false: node's Execute() will be called, allowing it to inspect dependency status
	AllowAutoSkip() bool
}

type Source struct {
	Name        string         `json:"name" jsonschema:"description=Human-readable name of the data source"`
	Description string         `json:"description" jsonschema:"description=Description of what data this source provides"`
	URL         string         `json:"url" jsonschema:"description=Base URL of the data source API or website"`
	Category    SourceCategory `` /* 137-byte string literal not displayed */
	Version     string         `json:"version,omitempty" jsonschema:"description=Version of the data source (e.g. CWE database version)"`
}

type SourceCategory string

type SourceProvider interface {
	GetSources() map[string]Source
}

type Status string

type StatusProvider interface {
	GetStatus() Status
	GetStatusReason() string
}