pluginapi

type ActionNode interface {
	ValidateConfig(ctx context.Context, config json.RawMessage) error
	Execute(ctx context.Context, config json.RawMessage, input map[string]any) (any, error)
}

type Bundle struct {
	Info                   PluginInfo
	Actions                map[string]ActionNode
	Triggers               map[string]TriggerNode
	Tools                  map[string]ToolNode
	TriggerRuntimeProvider TriggerRuntimeProvider
}

type FieldOption struct {
	Value string `json:"value"`
	Label string `json:"label"`
}

type FieldSpec struct {
	Name               string        `json:"name"`
	Label              string        `json:"label"`
	Description        string        `json:"description,omitempty"`
	Type               FieldType     `json:"type"`
	Required           bool          `json:"required,omitempty"`
	Placeholder        string        `json:"placeholder,omitempty"`
	TemplateSupported  bool          `json:"template_supported,omitempty"`
	Options            []FieldOption `json:"options,omitempty"`
	DefaultStringValue string        `json:"default_string_value,omitempty"`
	DefaultBoolValue   *bool         `json:"default_bool_value,omitempty"`
	DefaultNumberValue *float64      `json:"default_number_value,omitempty"`
}

type FieldType string

type NodeKind string

type NodeSpec struct {
	ID            string                 `json:"id"`
	Kind          NodeKind               `json:"kind"`
	Label         string                 `json:"label"`
	Description   string                 `json:"description,omitempty"`
	Icon          string                 `json:"icon,omitempty"`
	Color         string                 `json:"color,omitempty"`
	MenuPath      []string               `json:"menu_path,omitempty"`
	DefaultConfig map[string]any         `json:"default_config,omitempty"`
	Fields        []FieldSpec            `json:"fields,omitempty"`
	Outputs       []OutputHandle         `json:"outputs,omitempty"`
	OutputHints   []OutputHint           `json:"output_hints,omitempty"`
	Metadata      map[string]interface{} `json:"metadata,omitempty"`
}

type OutputHandle struct {
	ID    string `json:"id"`
	Label string `json:"label"`
	Color string `json:"color,omitempty"`
}

type OutputHint struct {
	Expression  string `json:"expression"`
	Label       string `json:"label"`
	Description string `json:"description,omitempty"`
}

type Plugin interface {
	Describe(ctx context.Context) (PluginInfo, error)
	ValidateConfig(ctx context.Context, nodeID string, config json.RawMessage) error
	ExecuteAction(ctx context.Context, nodeID string, config json.RawMessage, input map[string]any) (any, error)
	ToolDefinition(ctx context.Context, nodeID string, meta ToolNodeMetadata, config json.RawMessage) (*ToolDefinition, error)
	ExecuteTool(ctx context.Context, nodeID string, config json.RawMessage, args json.RawMessage, input map[string]any) (any, error)
	OpenTriggerRuntime(ctx context.Context) (TriggerRuntime, error)
}

type PluginInfo struct {
	ID         string     `json:"id"`
	Name       string     `json:"name"`
	Version    string     `json:"version"`
	APIVersion string     `json:"api_version"`
	Nodes      []NodeSpec `json:"nodes"`
}

type ToolDefinition struct {
	Type     string   `json:"type"`
	Function ToolSpec `json:"function"`
}

type ToolNode interface {
	ValidateConfig(ctx context.Context, config json.RawMessage) error
	ToolDefinition(ctx context.Context, meta ToolNodeMetadata, config json.RawMessage) (*ToolDefinition, error)
	ExecuteTool(ctx context.Context, config json.RawMessage, args json.RawMessage, input map[string]any) (any, error)
}

type ToolNodeMetadata struct {
	NodeID string `json:"node_id"`
	Label  string `json:"label"`
}

type ToolSpec struct {
	Name        string         `json:"name"`
	Description string         `json:"description,omitempty"`
	Parameters  map[string]any `json:"parameters,omitempty"`
}

type TriggerEvent struct {
	SubscriptionID string `json:"subscription_id"`
	Payload        any    `json:"payload,omitempty"`
}

type TriggerNode interface {
	ValidateConfig(ctx context.Context, config json.RawMessage) error
}

type TriggerRuntime interface {
	SendSnapshot(ctx context.Context, snapshot TriggerSubscriptionSnapshot) error
	Recv(ctx context.Context) (*TriggerEvent, error)
	Close() error
}

type TriggerRuntimeProvider interface {
	OpenTriggerRuntime(ctx context.Context) (TriggerRuntime, error)
}

type TriggerSubscription struct {
	SubscriptionID string          `json:"subscription_id"`
	PipelineID     string          `json:"pipeline_id,omitempty"`
	NodeType       string          `json:"node_type,omitempty"`
	NodeID         string          `json:"node_id"`
	NodeInstanceID string          `json:"node_instance_id,omitempty"`
	Config         json.RawMessage `json:"config,omitempty"`
}

type TriggerSubscriptionSnapshot struct {
	Subscriptions []TriggerSubscription `json:"subscriptions"`
}