workflow

type APICallStep struct {
	Endpoint string                 `json:"endpoint"`
	Method   string                 `json:"method"`
	Headers  map[string]string      `json:"headers,omitempty"`
	Body     map[string]interface{} `json:"body,omitempty"`
	Query    map[string]string      `json:"query,omitempty"`
}

type BackoffConfig struct {
	Type            BackoffType `json:"type,omitempty"`
	InitialInterval int         `json:"initial-interval,omitempty"` // seconds
	Multiplier      float64     `json:"multiplier,omitempty"`
	MaxInterval     int         `json:"max-interval,omitempty"` // seconds
}

type BackoffType string

type ConditionalStep struct {
	Condition string  `json:"condition"`
	Then      []*Step `json:"then,omitempty"`
	Else      []*Step `json:"else,omitempty"`
}

type DAG struct {
	Nodes map[string]*DAGNode
	Edges map[string][]string // stepID -> []dependentStepIDs
}

type DAGNode struct {
	Step         *Step
	Dependencies []string
	Dependents   []string
	Level        int // Depth in the graph for topological ordering
}

type ErrorMatch struct {
	HTTPStatus *int   `json:"http-status,omitempty"`
	ErrorType  string `json:"error-type,omitempty"`
}

type ExecutionContext struct {
	// Flags from CLI arguments
	Flags map[string]interface{}

	// Variables for temporary storage
	Variables map[string]interface{}

	// Step results keyed by step ID
	StepResults map[string]*StepResult

	// Completed steps in order
	CompletedSteps []*StepResult

	// Rollback actions to execute if workflow fails
	RollbackActions []*RollbackAction

	// HTTP client for API calls
	HTTPClient interface{} // Will be *http.Client

	// Plugin executor interface
	PluginExecutor interface{}
	// contains filtered or unexported fields
}

type ExecutionState struct {
	WorkflowID     string
	StartTime      time.Time
	Status         ExecutionStatus
	CompletedSteps []*StepResult
	CurrentStep    string
	Error          error
}

type ExecutionStatus string

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

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

type LoopStep struct {
	Iterator   string  `json:"iterator"`
	Collection string  `json:"collection"`
	Steps      []*Step `json:"steps"`
}

type ParallelStep struct {
	Steps []*Step `json:"steps"`
}

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

type PluginStep struct {
	Plugin  string                 `json:"plugin"`
	Command string                 `json:"command"`
	Input   map[string]interface{} `json:"input,omitempty"`
}

type PollingConfig struct {
	Endpoint       string   `json:"endpoint"`
	Interval       int      `json:"interval"` // seconds
	Timeout        int      `json:"timeout"`  // seconds
	TerminalStates []string `json:"terminal-states,omitempty"`
	StatusField    string   `json:"status-field,omitempty"`
}

type RetryConfig struct {
	MaxAttempts     int            `json:"max-attempts,omitempty"`
	Backoff         *BackoffConfig `json:"backoff,omitempty"`
	RetryableErrors []*ErrorMatch  `json:"retryable-errors,omitempty"`
}

type RollbackAction struct {
	StepID string
	Action *Step
	Result *StepResult
}

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

type RollbackStatus struct {
	TotalActions      int
	ExecutedActions   int
	SuccessfulActions int
	FailedActions     int
	Errors            []error
}

type Settings struct {
	ParallelExecution bool `json:"parallel-execution,omitempty"`
	FailFast          bool `json:"fail-fast,omitempty"`
	Timeout           int  `json:"timeout,omitempty"` // seconds
	DryRunSupported   bool `json:"dry-run-supported,omitempty"`
}

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

type Step struct {
	// Common fields
	ID          string   `json:"id"`
	Type        StepType `json:"type"`
	Description string   `json:"description,omitempty"`
	DependsOn   []string `json:"depends-on,omitempty"`
	Condition   string   `json:"condition,omitempty"`
	Required    bool     `json:"required,omitempty"`

	// Retry configuration
	Retry *RetryConfig `json:"retry,omitempty"`

	// Rollback action
	Rollback *Step `json:"rollback,omitempty"`

	// Output mapping
	Output map[string]string `json:"output,omitempty"`

	// Type-specific fields
	APICall     *APICallStep     `json:"api-call,omitempty"`
	Plugin      *PluginStep      `json:"plugin,omitempty"`
	Conditional *ConditionalStep `json:"conditional,omitempty"`
	Loop        *LoopStep        `json:"loop,omitempty"`
	Wait        *WaitStep        `json:"wait,omitempty"`
	Parallel    *ParallelStep    `json:"parallel,omitempty"`
}

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

type StepResult struct {
	StepID    string
	Success   bool
	Output    map[string]interface{}
	Error     error
	Retries   int
	StartTime time.Time
	EndTime   time.Time
	Duration  time.Duration
}

type StepType string

type WaitStep struct {
	Condition string         `json:"condition,omitempty"`
	Duration  int            `json:"duration,omitempty"` // seconds
	Polling   *PollingConfig `json:"polling,omitempty"`
}

type Workflow struct {
	Steps    []*Step   `json:"steps"`
	Settings *Settings `json:"settings,omitempty"`
}