operationrules

type ActionConfig struct {
	Name         string         `json:"name"`                    // Action name
	Timeout      time.Duration  `json:"timeout,omitempty"`       // Optional override
	PollInterval time.Duration  `json:"poll_interval,omitempty"` // For polling actions
	Parameters   map[string]any `json:"parameters,omitempty"`    // Action-specific params
}

type OperationRule struct {
	ID             uuid.UUID       `json:"id"`
	Name           string          `json:"name"`
	Description    string          `json:"description,omitempty"`
	OperationType  common.TaskType `json:"operation_type"` // e.g., "power_control", "firmware_control"
	OperationCode  string          `json:"operation_code"` // e.g., "power_on", "power_off", "upgrade"
	RuleDefinition RuleDefinition  `json:"rule_definition"`
	IsDefault      bool            `json:"is_default"`
	CreatedAt      time.Time       `json:"created_at"`
	UpdatedAt      time.Time       `json:"updated_at"`
}

type RackRuleAssociation struct {
	RackID        uuid.UUID
	OperationType common.TaskType
	OperationCode string
	RuleID        uuid.UUID
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

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

type RetryPolicy struct {
	MaxAttempts        int           `json:"max_attempts"`
	InitialInterval    time.Duration `json:"initial_interval"`       // Parsed once at rule creation time
	BackoffCoefficient float64       `json:"backoff_coefficient"`    // Exponential backoff multiplier
	MaxInterval        time.Duration `json:"max_interval,omitempty"` // Parsed once at rule creation time
}

type RuleDefinition struct {
	Version string         `json:"version"` // Schema version for forward compatibility
	Steps   []SequenceStep `json:"steps"`
}

type RuleLoader interface {
	Load() (map[common.TaskType]map[string]*OperationRule, error)
}

type RuleStore interface {
	GetRuleByOperationAndRack(ctx context.Context, opType common.TaskType, operation string, rackID *uuid.UUID) (*OperationRule, error)
}

type SequenceStep struct {
	// Which component type this step applies to
	ComponentType devicetypes.ComponentType `json:"component_type"`

	// Execution stage number (steps with same stage run in parallel)
	// Stage 1 executes first, then stage 2, etc.
	Stage int `json:"stage"`

	// Maximum parallel component operations (0 = unlimited, 1 = sequential)
	// Controls how many components of this type are processed concurrently
	MaxParallel int `json:"max_parallel"`

	// Child workflow configuration (applies to entire workflow: pre + main + post)
	Timeout     time.Duration `json:"timeout,omitempty"` // Child workflow timeout
	RetryPolicy *RetryPolicy  `json:"retry,omitempty"`   // Child workflow retry

	// Action sequences
	PreOperation  []ActionConfig `json:"pre_operation,omitempty"`  // Before main operation
	MainOperation ActionConfig   `json:"main_operation"`           // Primary operation
	PostOperation []ActionConfig `json:"post_operation,omitempty"` // After main operation

	// Legacy field for backward compatibility (deprecated: use MainOperation)
	DelayAfter time.Duration `json:"delay_after,omitempty"`
}

type Stage struct {
	Number int            // The actual stage number from the rule definition
	Steps  []SequenceStep // All steps in this stage (execute in parallel)
}

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

type YAMLActionConfig struct {
	Name         string         `yaml:"name"`
	Timeout      string         `yaml:"timeout,omitempty"`
	PollInterval string         `yaml:"poll_interval,omitempty"`
	Parameters   map[string]any `yaml:"parameters,omitempty"`
}

type YAMLConfig struct {
	Version string     `yaml:"version"`
	Rules   []YAMLRule `yaml:"rules"`
}

type YAMLRetryPolicy struct {
	MaxAttempts        int     `yaml:"max_attempts"`
	InitialInterval    string  `yaml:"initial_interval"`
	BackoffCoefficient float64 `yaml:"backoff_coefficient"`
	MaxInterval        string  `yaml:"max_interval,omitempty"`
}

type YAMLRule struct {
	Name          string     `yaml:"name"`
	Description   string     `yaml:"description,omitempty"`
	OperationType string     `yaml:"operation_type"`
	Operation     string     `yaml:"operation"`
	Steps         []YAMLStep `yaml:"steps"`
}

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

type YAMLStep struct {
	ComponentType string             `yaml:"component_type"`
	Stage         int                `yaml:"stage"`
	MaxParallel   int                `yaml:"max_parallel"`
	Timeout       string             `yaml:"timeout,omitempty"`
	Retry         *YAMLRetryPolicy   `yaml:"retry,omitempty"`
	PreOperation  []YAMLActionConfig `yaml:"pre_operation,omitempty"`
	MainOperation YAMLActionConfig   `yaml:"main_operation"`
	PostOperation []YAMLActionConfig `yaml:"post_operation,omitempty"`
	DelayAfter    string             `yaml:"delay_after,omitempty"` // Legacy
}