engine

type Graph = domain.WorkflowGraph

type InOutManager interface {
	All() []InOutState
	Erase()

	Add(state InOutState)
	Set(nodeId string, stype string, name string, value any, valueType string, persistent bool)
	Get(nodeId string, name string) (*InOutState, bool)
	Take(nodeId string, name string) (*InOutState, bool)
	Remove(nodeId string, name string) bool
}

type InOutState struct {
	NodeId     string
	Type       string
	Name       string
	Value      any
	ValueType  string
	Persistent bool
}

type Node = domain.WorkflowNode

type NodeExecutionContext struct {
	WorkflowContext

	Node *Node
}

type NodeExecutionResult struct {
	Terminated bool // 是否终止执行（通常由 End 节点主动触发）

	Variables []VariableState

	Outputs []InOutState
	// contains filtered or unexported fields
}

type NodeExecutor interface {
	Execute(execCtx *NodeExecutionContext) (*NodeExecutionResult, error)
	// contains filtered or unexported methods
}

type NodeType = domain.WorkflowNodeType

type VariableManager interface {
	All() []VariableState
	Erase()

	Add(entry VariableState)
	Set(name string, value any, valueType string)
	SetScoped(scope string, name string, value any, valueType string)
	Get(name string) (*VariableState, bool)
	GetScoped(scope string, key string) (*VariableState, bool)
	Take(key string) (*VariableState, bool)
	TakeScoped(scope string, key string) (*VariableState, bool)
	Remove(key string) bool
	RemoveScoped(scope string, key string) bool
}

type VariableState struct {
	Scope     string // 零值时表示全局的，否则表示指定节点的
	Key       string
	Value     any
	ValueType string
}

type WorkflowContext struct {
	WorkflowId string
	RunId      string
	RunGraph   *Graph
	// contains filtered or unexported fields
}

type WorkflowEngine interface {
	Invoke(ctx context.Context, workflowId string, runId string, graph *Graph) error

	OnStart(callback func(ctx context.Context) error)
	OnEnd(callback func(ctx context.Context) error)
	OnError(callback func(ctx context.Context, err error) error)
	OnNodeStart(callback func(ctx context.Context, node *Node) error)
	OnNodeEnd(callback func(ctx context.Context, node *Node, res *NodeExecutionResult) error)
	OnNodeError(callback func(ctx context.Context, node *Node, err error) error)
	OnNodeLogging(callback func(ctx context.Context, node *Node, log logging.Record) error)
}