workflow

type ActionConfig struct {
	Type       ActionType            `json:"type"`
	HTTP       *HTTPActionConfig     `json:"http,omitempty"`
	LLM        *LLMActionConfig      `json:"llm,omitempty"`
	Skill      *SkillActionConfig    `json:"skill,omitempty"`
	Channel    *ChannelActionConfig  `json:"channel,omitempty"`
	Browser    *BrowserActionConfig  `json:"browser,omitempty"`
	File       *FileActionConfig     `json:"file,omitempty"`
	JavaScript *JavaScriptConfig     `json:"javascript,omitempty"`
	Variable   *VariableActionConfig `json:"variable,omitempty"`
	Email      *EmailActionConfig    `json:"email,omitempty"`
	Notify     *NotifyActionConfig   `json:"notify,omitempty"`
}

type ActionHandler func(ctx context.Context, config map[string]interface{}, input map[string]interface{}) (map[string]interface{}, error)

type ActionType string

type BrowserActionConfig struct {
	Action   string                 `json:"action"` // navigate, click, type, screenshot, etc.
	URL      string                 `json:"url,omitempty"`
	Selector string                 `json:"selector,omitempty"`
	Value    string                 `json:"value,omitempty"`
	Options  map[string]interface{} `json:"options,omitempty"`
}

type ChannelActionConfig struct {
	ChannelType string `json:"channel_type"`
	ChannelID   string `json:"channel_id"`
	Message     string `json:"message"`
	Format      string `json:"format,omitempty"` // text, markdown, html
}

type ChannelTriggerConfig struct {
	ChannelType string   `json:"channel_type"` // telegram, discord, etc.
	ChannelID   string   `json:"channel_id,omitempty"`
	Keywords    []string `json:"keywords,omitempty"`   // Trigger on keywords
	Regex       string   `json:"regex,omitempty"`      // Trigger on regex match
	FromUsers   []string `json:"from_users,omitempty"` // Filter by user
}

type ConditionConfig struct {
	Expression string `json:"expression"` // JavaScript expression
	TruePort   string `json:"true_port,omitempty"`
	FalsePort  string `json:"false_port,omitempty"`
}

type Config struct {
	MaxConcurrentExecutions int    `json:"max_concurrent_executions" yaml:"max_concurrent_executions"`
	DefaultTimeout          int    `json:"default_timeout" yaml:"default_timeout"` // seconds
	MaxTimeout              int    `json:"max_timeout" yaml:"max_timeout"`         // seconds
	RetryDelay              int    `json:"retry_delay" yaml:"retry_delay"`         // seconds
	MaxRetries              int    `json:"max_retries" yaml:"max_retries"`
	SaveExecutionData       bool   `json:"save_execution_data" yaml:"save_execution_data"`
	ExecutionDataRetention  int    `json:"execution_data_retention" yaml:"execution_data_retention"` // days
	WebhookBasePath         string `json:"webhook_base_path" yaml:"webhook_base_path"`
	Enabled                 bool   `json:"enabled" yaml:"enabled"`
}

type Connection struct {
	ID         string `json:"id"`
	SourceNode string `json:"source_node"`
	SourcePort string `json:"source_port,omitempty"`
	TargetNode string `json:"target_node"`
	TargetPort string `json:"target_port,omitempty"`
	Condition  string `json:"condition,omitempty"` // For conditional connections
}

type CreateWorkflowRequest struct {
	Name        string            `json:"name" validate:"required"`
	Description string            `json:"description,omitempty"`
	Nodes       []Node            `json:"nodes,omitempty"`
	Connections []Connection      `json:"connections,omitempty"`
	Variables   map[string]string `json:"variables,omitempty"`
	Settings    *WorkflowSettings `json:"settings,omitempty"`
	Tags        []string          `json:"tags,omitempty"`
}

type DelayConfig struct {
	Duration int    `json:"duration"`        // Delay in seconds
	Until    string `json:"until,omitempty"` // Wait until specific time
}

type EmailActionConfig struct {
	To          []string `json:"to"`
	Cc          []string `json:"cc,omitempty"`
	Bcc         []string `json:"bcc,omitempty"`
	Subject     string   `json:"subject"`
	Body        string   `json:"body"`
	ContentType string   `json:"content_type,omitempty"` // text, html
	Attachments []string `json:"attachments,omitempty"`
}

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

type ExecuteWorkflowRequest struct {
	TriggerData map[string]interface{} `json:"trigger_data,omitempty"`
}

type Execution struct {
	ID           string                 `json:"id"`
	WorkflowID   string                 `json:"workflow_id"`
	WorkflowName string                 `json:"workflow_name"`
	TenantID     string                 `json:"tenant_id"`
	Status       ExecutionStatus        `json:"status"`
	StatusReason string                 `json:"status_reason,omitempty"`
	TriggerType  TriggerType            `json:"trigger_type"`
	TriggerData  map[string]interface{} `json:"trigger_data,omitempty"`
	Variables    map[string]interface{} `json:"variables,omitempty"`
	NodeResults  map[string]*NodeResult `json:"node_results,omitempty"`
	Checkpoint   *ExecutionCheckpoint   `json:"checkpoint,omitempty"`
	Error        string                 `json:"error,omitempty"`
	StartedAt    time.Time              `json:"started_at"`
	CompletedAt  *time.Time             `json:"completed_at,omitempty"`
	Duration     int64                  `json:"duration,omitempty"` // Duration in milliseconds
}

type ExecutionCancellationController interface {
	CancelExecution(ctx context.Context, executionID string, reason string) (handled bool, err error)
}

type ExecutionCheckpoint struct {
	ID        string                  `json:"id"`
	Kind      ExecutionCheckpointKind `json:"kind"`
	NodeID    string                  `json:"node_id,omitempty"`
	NodeName  string                  `json:"node_name,omitempty"`
	Reason    string                  `json:"reason,omitempty"`
	Payload   map[string]interface{}  `json:"payload,omitempty"`
	CreatedAt time.Time               `json:"created_at"`
	ResumedAt *time.Time              `json:"resumed_at,omitempty"`
	Resume    *ExecutionResumeInput   `json:"resume,omitempty"`
}

type ExecutionCheckpointKind string

type ExecutionLaunchRequest struct {
	WorkflowID     string                 `json:"workflow_id"`
	TriggerType    TriggerType            `json:"trigger_type,omitempty"`
	TriggerData    map[string]interface{} `json:"trigger_data,omitempty"`
	UserID         string                 `json:"user_id,omitempty"`
	ConversationID string                 `json:"conversation_id,omitempty"`
	TenantID       string                 `json:"tenant_id,omitempty"`
}

type ExecutionLauncher interface {
	LaunchExecution(ctx context.Context, req ExecutionLaunchRequest) (*Execution, error)
}

type ExecutionLog struct {
	ID          string    `json:"id"`
	ExecutionID string    `json:"execution_id"`
	NodeID      string    `json:"node_id,omitempty"`
	Level       string    `json:"level"` // debug, info, warn, error
	Message     string    `json:"message"`
	Data        string    `json:"data,omitempty"`
	Timestamp   time.Time `json:"timestamp"`
}

type ExecutionResumeController interface {
	ResumeExecution(ctx context.Context, executionID string, resume ExecutionResumeInput) (handled bool, execution *Execution, err error)
}

type ExecutionResumeInput struct {
	Decision string                 `json:"decision,omitempty"`
	Payload  map[string]interface{} `json:"payload,omitempty"`
}

type ExecutionStatus string

type FileActionConfig struct {
	Operation  string `json:"operation"` // read, write, copy, move, delete
	SourcePath string `json:"source_path"`
	DestPath   string `json:"dest_path,omitempty"`
	Content    string `json:"content,omitempty"`
	Encoding   string `json:"encoding,omitempty"`
	CreateDirs bool   `json:"create_dirs,omitempty"`
}

type FileChangeConfig struct {
	Path      string   `json:"path"`
	Patterns  []string `json:"patterns,omitempty"`  // File patterns to watch
	Events    []string `json:"events,omitempty"`    // create, modify, delete
	Recursive bool     `json:"recursive,omitempty"` // Watch subdirectories
}

type HTTPActionConfig struct {
	URL             string            `json:"url"`
	Method          string            `json:"method"`
	Headers         map[string]string `json:"headers,omitempty"`
	Body            string            `json:"body,omitempty"`
	ContentType     string            `json:"content_type,omitempty"`
	Timeout         int               `json:"timeout,omitempty"`
	FollowRedirects bool              `json:"follow_redirects,omitempty"`
	ValidateSSL     bool              `json:"validate_ssl,omitempty"`
}

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

type JavaScriptConfig struct {
	Code    string `json:"code"`
	Timeout int    `json:"timeout,omitempty"`
}

type LLMActionConfig struct {
	Provider     string   `json:"provider"` // openai, claude, ollama
	Model        string   `json:"model"`
	Prompt       string   `json:"prompt"`
	SystemPrompt string   `json:"system_prompt,omitempty"`
	Temperature  float64  `json:"temperature,omitempty"`
	MaxTokens    int      `json:"max_tokens,omitempty"`
	Tools        []string `json:"tools,omitempty"` // Tool names to enable
}

type ListOptions struct {
	Offset  int               `json:"offset"`
	Limit   int               `json:"limit"`
	Sort    string            `json:"sort,omitempty"`
	Order   string            `json:"order,omitempty"` // asc, desc
	Filters map[string]string `json:"filters,omitempty"`
}

type LoopConfig struct {
	Type          string `json:"type"`                     // for_each, while, count
	Items         string `json:"items,omitempty"`          // Expression for items to iterate
	Condition     string `json:"condition,omitempty"`      // While condition
	Count         int    `json:"count,omitempty"`          // Fixed count
	MaxIterations int    `json:"max_iterations,omitempty"` // Safety limit
}

type Node struct {
	ID          string                 `json:"id"`
	Type        NodeType               `json:"type"`
	Name        string                 `json:"name"`
	Description string                 `json:"description,omitempty"`
	Config      map[string]interface{} `json:"config,omitempty"`
	Position    *Position              `json:"position,omitempty"`
	Disabled    bool                   `json:"disabled,omitempty"`
}

type NodeResult struct {
	NodeID      string                 `json:"node_id"`
	NodeName    string                 `json:"node_name"`
	Status      NodeStatus             `json:"status"`
	Input       map[string]interface{} `json:"input,omitempty"`
	Output      map[string]interface{} `json:"output,omitempty"`
	Error       string                 `json:"error,omitempty"`
	StartedAt   time.Time              `json:"started_at"`
	CompletedAt *time.Time             `json:"completed_at,omitempty"`
	Duration    int64                  `json:"duration,omitempty"` // Duration in milliseconds
	RetryCount  int                    `json:"retry_count,omitempty"`
}

type NodeStatus string

type NodeType string

type NotifyActionConfig struct {
	Title    string `json:"title,omitempty"`
	Message  string `json:"message"`
	Priority string `json:"priority,omitempty"` // low, normal, high
	Channel  string `json:"channel,omitempty"`  // Notification channel
}

type Position struct {
	X float64 `json:"x"`
	Y float64 `json:"y"`
}

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

type ResumeExecutionRequest struct {
	Decision string                 `json:"decision,omitempty"`
	Payload  map[string]interface{} `json:"payload,omitempty"`
}

type ScheduleConfig struct {
	Cron     string `json:"cron,omitempty"`     // Cron expression
	Interval int    `json:"interval,omitempty"` // Interval in seconds
	Timezone string `json:"timezone,omitempty"` // Timezone for cron
}

type Service interface {
	// Workflow CRUD
	CreateWorkflow(ctx context.Context, workflow *Workflow) (*Workflow, error)
	GetWorkflow(ctx context.Context, id string) (*Workflow, error)
	UpdateWorkflow(ctx context.Context, workflow *Workflow) (*Workflow, error)
	DeleteWorkflow(ctx context.Context, id string) error
	ListWorkflows(ctx context.Context, tenantID string, opts *ListOptions) ([]*Workflow, int, error)

	// Workflow control
	EnableWorkflow(ctx context.Context, id string) error
	DisableWorkflow(ctx context.Context, id string) error
	ValidateWorkflow(ctx context.Context, workflow *Workflow) error

	// Execution
	ExecuteWorkflow(ctx context.Context, id string, triggerData map[string]interface{}) (*Execution, error)
	ExecuteWorkflowWithTrigger(ctx context.Context, id string, triggerType TriggerType, triggerData map[string]interface{}) (*Execution, error)
	GetExecution(ctx context.Context, id string) (*Execution, error)
	ListExecutions(ctx context.Context, workflowID string, opts *ListOptions) ([]*Execution, int, error)
	CancelExecution(ctx context.Context, id string) error
	RetryExecution(ctx context.Context, id string) (*Execution, error)
	ResumeExecution(ctx context.Context, id string, resume ExecutionResumeInput) (*Execution, error)

	// Logs
	GetExecutionLogs(ctx context.Context, executionID string, opts *ListOptions) ([]*ExecutionLog, int, error)

	// Triggers
	RegisterTrigger(ctx context.Context, workflowID string, trigger *TriggerConfig) error
	UnregisterTrigger(ctx context.Context, workflowID string) error

	// Webhook
	HandleWebhook(ctx context.Context, path string, method string, headers map[string]string, body []byte) (*Execution, error)

	// Stats
	GetStats(ctx context.Context, tenantID string) (*Stats, error)
}

type SkillActionConfig struct {
	SkillID    string                 `json:"skill_id"`
	Parameters map[string]interface{} `json:"parameters,omitempty"`
}

type Stats struct {
	TotalWorkflows       int `json:"total_workflows"`
	ActiveWorkflows      int `json:"active_workflows"`
	TotalExecutions      int `json:"total_executions"`
	RunningExecutions    int `json:"running_executions"`
	SuccessfulExecutions int `json:"successful_executions"`
	FailedExecutions     int `json:"failed_executions"`
}

type SwitchConfig struct {
	Expression string            `json:"expression"`        // Expression to evaluate
	Cases      map[string]string `json:"cases"`             // Value -> port mapping
	Default    string            `json:"default,omitempty"` // Default port
}

type SystemTriggerConfig struct {
	EventType string `json:"event_type"` // startup, shutdown, etc.
}

type ToolExecutionRequest struct {
	ToolName   string
	Arguments  map[string]interface{}
	SessionID  string
	UserID     string
	Provider   string
	ProviderID string
	Model      string
	AgentID    string
}

type ToolExecutionResult struct {
	ExecutionResult interface{}
	CompactPayload  interface{}
	AuditPayload    interface{}
}

type ToolRuntime interface {
	Execute(ctx context.Context, req ToolExecutionRequest) (*ToolExecutionResult, error)
}

type TriggerConfig struct {
	Type     TriggerType           `json:"type"`
	Schedule *ScheduleConfig       `json:"schedule,omitempty"`
	Webhook  *WebhookConfig        `json:"webhook,omitempty"`
	File     *FileChangeConfig     `json:"file,omitempty"`
	Channel  *ChannelTriggerConfig `json:"channel,omitempty"`
	System   *SystemTriggerConfig  `json:"system,omitempty"`
}

type TriggerType string

type UpdateWorkflowRequest struct {
	Name        string            `json:"name,omitempty"`
	Description string            `json:"description,omitempty"`
	Status      WorkflowStatus    `json:"status,omitempty"`
	Nodes       []Node            `json:"nodes,omitempty"`
	Connections []Connection      `json:"connections,omitempty"`
	Variables   map[string]string `json:"variables,omitempty"`
	Settings    *WorkflowSettings `json:"settings,omitempty"`
	Tags        []string          `json:"tags,omitempty"`
}

type VariableActionConfig struct {
	Name  string `json:"name"`
	Value string `json:"value"`
	Scope string `json:"scope,omitempty"` // execution, workflow
}

type WebhookConfig struct {
	Path       string            `json:"path"`
	Method     string            `json:"method,omitempty"` // GET, POST, etc.
	Headers    map[string]string `json:"headers,omitempty"`
	AuthType   string            `json:"auth_type,omitempty"` // none, basic, bearer, api_key
	AuthConfig map[string]string `json:"auth_config,omitempty"`
}

type Workflow struct {
	ID          string            `json:"id"`
	TenantID    string            `json:"tenant_id"`
	Name        string            `json:"name"`
	Description string            `json:"description,omitempty"`
	Status      WorkflowStatus    `json:"status"`
	Nodes       []Node            `json:"nodes"`
	Connections []Connection      `json:"connections"`
	Variables   map[string]string `json:"variables,omitempty"`
	Settings    *WorkflowSettings `json:"settings,omitempty"`
	Tags        []string          `json:"tags,omitempty"`
	Version     int               `json:"version"`
	CreatedAt   time.Time         `json:"created_at"`
	UpdatedAt   time.Time         `json:"updated_at"`
	CreatedBy   string            `json:"created_by,omitempty"`
	UpdatedBy   string            `json:"updated_by,omitempty"`
}

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

type WorkflowSettings struct {
	Timeout            int  `json:"timeout,omitempty"`              // Execution timeout in seconds
	MaxRetries         int  `json:"max_retries,omitempty"`          // Max retries on failure
	RetryDelay         int  `json:"retry_delay,omitempty"`          // Delay between retries in seconds
	ContinueOnError    bool `json:"continue_on_error,omitempty"`    // Continue execution on node error
	SaveExecutionData  bool `json:"save_execution_data,omitempty"`  // Save execution data for debugging
	MaxConcurrent      int  `json:"max_concurrent,omitempty"`       // Max concurrent executions
	NotifyOnCompletion bool `json:"notify_on_completion,omitempty"` // Send notification on completion
	NotifyOnError      bool `json:"notify_on_error,omitempty"`      // Send notification on error
}

type WorkflowStatus string

type WorkflowTemplateResponse struct {
	ID          string   `json:"id"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Category    string   `json:"category"`
	Tags        []string `json:"tags"`
	Workflow    Workflow `json:"workflow"`
}