compiler

type ClassifyStage struct{}

type CompileContext struct {
	AnalysisID int64
	Params     map[string]any
	// RequestParam 是本次分析的原始 request_param（已解析成 map）。它由调用方
	// 从 analysis.request_param 透传进来，用于为每个 runtime 节点生成
	// analysis_node.request_param，语义与 Params 派生 resolved_inputs 一致。
	RequestParam map[string]any
	Dag          map[string]any
	Abort        bool

	Nodes []map[string]any
	Edges []map[string]any

	NodeMap   map[string]map[string]any
	Incoming  map[string][]map[string]any
	Outgoing  map[string][]map[string]any
	Order     []string
	NodeKind  map[string]string
	NodeLabel map[string][]string

	NodeSamplesMap map[string]map[string]map[string]any
	OutputCache    map[cacheKey]any
	NodeStates     map[string][]*NodeRuntimeState
	StateOrder     []*NodeRuntimeState

	AnalysisNodes []map[string]any
	AnalysisEdges []map[string]any
}

type DecorateStage struct{}

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

type EdgeStrategy interface {
	Build(ctx *CompileContext, nid string, node map[string]any, states []*NodeRuntimeState, builder *RuntimeEdgeBuilder) []map[string]any
}

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

type NodeExpandStrategy interface {
	Expand(ctx *CompileContext, nid string, node map[string]any) ([]*NodeRuntimeState, error)
}

type NodeRuntimeState struct {
	OriginalNodeID string
	Node           map[string]any
	Kind           string
	NodeIDBase     string
	NodeID         string
	NodeName       string
	ScriptID       string
	SampleLabel    string
	Sample         map[string]any
	Inputs         map[string]any
	Outputs        map[string]any
	ResolvedInputs map[string]any
	// RequestParam 汇总节点自身的原始请求值（按输入句柄 name 建键）。目前只由散列
	// (scatter each) 节点写入：item 里按句柄名命中的原始值放到这里，而不是直接写进
	// resolved_inputs，落库后由 nodebuild.Materialize 的解析器据此生成结构化
	// resolved_inputs（与 select-assay 输入同一口径）。
	RequestParam   map[string]any
	ResolvedOutput map[string]any
	InputErrors    []string
	MaxRetry       int
}

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

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

type ResolveStrategy interface {
	Resolve(ctx *CompileContext, state *NodeRuntimeState) error
}

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

type RuntimeEdgeBuilder struct{}

type RuntimeNodeBuilder struct{}

type SampleEdgeStrategy struct{}

type SampleExpandStrategy struct{}

type SampleResolveStrategy struct{}

type SingletonEdgeStrategy struct{}

type SingletonExpandStrategy struct{}

type SingletonResolveStrategy struct{}

type Stage interface {
	Name() string
	Run(ctx *CompileContext) error
}

type TopologyStage struct{}