core

type AlertSeverity string

type Capability string

type ConfigProvider interface {
	Config() any
}

type EventTypeDesc struct {
	Name        EventTypeName           // Unique ID, e.g., "deploy_success"
	Description string                  // Human-readable, e.g., "Fired when a stack deploys successfully"
	PayloadSpec map[string]PayloadField // Optional: Expected fields in event.Details (for validation/docs)
}

type EventTypeName string

type ExecutionEventInput struct {
	ExecutionID   string
	Owner         string
	Repo          string
	FullName      string
	Stage         ExecutionStage
	Status        ExecutionStatus
	FailureClass  FailureClass
	AlertSeverity AlertSeverity
	NodeID        string
	Trigger       string
	Source        string
	Details       map[string]any
}

type ExecutionStage string

type ExecutionStatus string

type FailureClass string

type InternalEvent struct {
	Type      EventTypeName          `json:"type"`
	Timestamp time.Time              `json:"timestamp"`
	Source    string                 `json:"source"` // "timer", "webhook_trigger", "notifications", etc.
	Repo      string                 `json:"repo,omitempty"`
	Details   map[string]interface{} `json:"details,omitempty"` // Structured metadata lives here; keep the top-level surface small.
	Message   string                 `json:"message,omitempty"`
}

type Listener func(ctx context.Context, event InternalEvent)

type Module interface {
	// Name returns the stable module name used for registration and logging.
	Name() string
	// Init prepares the module and receives the shared PluginRegistry.
	Init(ctx context.Context, logger *slog.Logger, registry PluginRegistry) error
	// Start begins the module's runtime work.
	Start(ctx context.Context) error
	// Stop shuts the module down and releases owned resources.
	Stop(ctx context.Context) error
}

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

type NotificationPayload struct {
	EventType     EventTypeName  `json:"event_type"`
	Timestamp     time.Time      `json:"timestamp"`
	Source        string         `json:"source,omitempty"`
	Repo          string         `json:"repo,omitempty"`
	Message       string         `json:"message,omitempty"`
	Title         string         `json:"title"`
	Body          string         `json:"body"`
	ExecutionID   string         `json:"execution_id,omitempty"`
	FullName      string         `json:"full_name,omitempty"`
	Stage         string         `json:"stage,omitempty"`
	Status        string         `json:"status,omitempty"`
	FailureClass  string         `json:"failure_class,omitempty"`
	AlertSeverity string         `json:"alert_severity,omitempty"`
	LastError     string         `json:"last_error,omitempty"`
	Details       map[string]any `json:"details,omitempty"`
}

type PayloadField struct {
	Type        string // e.g., "string", "int", "map[string]interface{}"
	Description string
	Required    bool
}

type Plugin interface {
	Module
	// Description returns a human-readable summary of the plugin.
	Description() string
	// Capabilities returns the plugin capabilities it provides to the system.
	Capabilities() []Capability
	// Status reports the current plugin health for APIs and status pages.
	Status() ServiceStatus
	// Execute runs a plugin-specific action with free-form parameters.
	Execute(ctx context.Context, action string, params map[string]interface{}) (interface{}, error)
}

type PluginRegistry interface {
	// GetPlugin returns a plugin by its registered name.
	GetPlugin(name string) (Plugin, error)
	// GetPluginsWithCapability returns all plugins advertising the given capability.
	GetPluginsWithCapability(cap Capability) []Plugin
	// ListPlugins returns all registered plugins in registration order.
	ListPlugins() []Plugin
	// RegisterEventType declares an event type for validation and discoverability.
	RegisterEventType(desc EventTypeDesc) error
	// Publish delivers an event to matching subscribers on this manager's bus.
	Publish(ctx context.Context, event InternalEvent)
	// GetMuxServer returns the shared HTTP mux used for core and plugin routes.
	GetMuxServer() *http.ServeMux
	// Subscribe registers a listener for an exact event type or wildcard pattern.
	Subscribe(pattern string, handler Listener)
	// GetHTTPClient returns the shared HTTP client for outbound requests.
	GetHTTPClient() *http.Client
	// GetConfig returns the sectioned configuration map visible to plugins.
	GetConfig() map[string]map[string]any
}

type RuntimeFile struct {
	EnvKey   string `json:"env_key"`
	Filename string `json:"filename,omitempty"`
	Content  []byte `json:"-"`
	Mode     uint32 `json:"mode,omitempty"`
}

type Secret struct {
	Value string
}

type ServiceStatus string