api

type AlertManager interface {
	GetStats() core.AlertManagerStats
	ListChannels() []*core.AlertChannel
	ListRules() []*core.AlertRule
	RegisterChannel(channel *core.AlertChannel) error
	RegisterRule(rule *core.AlertRule) error
	DeleteChannel(id string) error
	DeleteRule(id string) error
	AcknowledgeIncident(incidentID, userID string) error
	ResolveIncident(incidentID, userID string) error
}

type AuditBackend interface {
	Write(event *AuditEvent) error
	Query(filter AuditFilter) ([]*AuditEvent, error)
}

type AuditEvent struct {
	Timestamp time.Time       `json:"timestamp"`
	EventType string          `json:"event_type"`
	UserID    string          `json:"user_id,omitempty"`
	IPAddress string          `json:"ip_address"`
	UserAgent string          `json:"user_agent,omitempty"`
	Resource  string          `json:"resource"`
	Action    string          `json:"action"`
	Status    string          `json:"status"`
	Details   json.RawMessage `json:"details,omitempty"`
	RequestID string          `json:"request_id"`
}

type AuditEventLogger interface {
	Log(eventType, userID, resource, action, status string, details any)
	LogRequest(r *http.Request, userID string, status int, duration time.Duration)
	LogAuth(userID, ipAddress, action, status string, details map[string]any)
	LogSecurity(eventType, userID, resource, action string, severity string, details map[string]any)
}

type AuditFilter struct {
	StartTime  time.Time
	EndTime    time.Time
	EventTypes []string
	UserID     string
	Resource   string
	Action     string
	Status     string
	Limit      int
}

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

type Authenticator interface {
	Authenticate(token string) (*User, error)
	Login(email, password string) (*User, string, error)
	Logout(token string) error
}

type ClientMessage struct {
	Type      string   `json:"type"`
	Events    []string `json:"events,omitempty"`
	Workspace string   `json:"workspace,omitempty"`
}

type ClusterManager interface {
	IsLeader() bool
	Leader() string
	IsClustered() bool
	GetStatus() *ClusterStatus
}

type ClusterStatus struct {
	IsClustered bool   `json:"is_clustered"`
	NodeID      string `json:"node_id"`
	State       string `json:"state,omitempty"`
	Leader      string `json:"leader,omitempty"`
	Term        uint64 `json:"term,omitempty"`
	PeerCount   int    `json:"peer_count,omitempty"`
}

type Context struct {
	Request   *http.Request
	Response  http.ResponseWriter
	Params    map[string]string
	User      *User
	Workspace string
	StartTime time.Time
}

type Handler func(ctx *Context) error

type MCPError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type MCPPrompt struct {
	Name        string         `json:"name"`
	Description string         `json:"description"`
	Arguments   []MCPPromptArg `json:"arguments"`
	Handler     func(args map[string]string) (string, error)
}

type MCPPromptArg struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Required    bool   `json:"required"`
}

type MCPRequest struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      interface{}     `json:"id"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params"`
}

type MCPResource struct {
	URI         string `json:"uri"`
	Name        string `json:"name"`
	Description string `json:"description"`
	MIMEType    string `json:"mimeType"`
	Handler     func() (interface{}, error)
}

type MCPResponse struct {
	JSONRPC string      `json:"jsonrpc"`
	ID      interface{} `json:"id"`
	Result  interface{} `json:"result,omitempty"`
	Error   *MCPError   `json:"error,omitempty"`
}

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

type MCPTool struct {
	Name        string          `json:"name"`
	Description string          `json:"description"`
	InputSchema json.RawMessage `json:"inputSchema"`
	Handler     func(args json.RawMessage) (interface{}, error)
}

type Middleware func(Handler) Handler

type PaginatedResponse struct {
	Data       interface{} `json:"data"`
	Pagination Pagination  `json:"pagination"`
}

type Pagination struct {
	Total      int  `json:"total"`
	Offset     int  `json:"offset"`
	Limit      int  `json:"limit"`
	HasMore    bool `json:"has_more"`
	NextOffset *int `json:"next_offset,omitempty"`
}

type ProbeEngine interface {
	AssignSouls(souls []*core.Soul)
	GetStatus() *core.ProbeStatus
	ForceCheck(soulID string) (*core.Judgment, error)
}

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

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

type StatusComponent struct {
	ID          string    `json:"id"`
	Name        string    `json:"name"`
	Status      string    `json:"status"`
	Type        string    `json:"type"`
	Target      string    `json:"target"`
	Description string    `json:"description"`
	UpdatedAt   time.Time `json:"updated_at"`
	LastChecked time.Time `json:"last_checked,omitempty"`
	Latency     string    `json:"latency,omitempty"`
}

type StatusPageData struct {
	Name             string            `json:"name"`
	Description      string            `json:"description"`
	Status           string            `json:"status"`
	UpdatedAt        time.Time         `json:"updated_at"`
	UptimePercentage float64           `json:"uptime_percentage"`
	OperationalCount int               `json:"operational_count"`
	TotalCount       int               `json:"total_count"`
	Components       []StatusComponent `json:"components"`
}

type Storage interface {
	GetSoulNoCtx(id string) (*core.Soul, error)
	ListSoulsNoCtx(workspace string, offset, limit int) ([]*core.Soul, error)
	SaveSoul(ctx context.Context, soul *core.Soul) error
	DeleteSoul(ctx context.Context, id string) error

	GetJudgmentNoCtx(id string) (*core.Judgment, error)
	ListJudgmentsNoCtx(soulID string, start, end time.Time, limit int) ([]*core.Judgment, error)

	GetChannelNoCtx(id string) (*core.AlertChannel, error)
	ListChannelsNoCtx(workspace string) ([]*core.AlertChannel, error)
	SaveChannelNoCtx(channel *core.AlertChannel) error
	DeleteChannelNoCtx(id string) error

	GetRuleNoCtx(id string) (*core.AlertRule, error)
	ListRulesNoCtx(workspace string) ([]*core.AlertRule, error)
	SaveRuleNoCtx(rule *core.AlertRule) error
	DeleteRuleNoCtx(id string) error

	GetWorkspaceNoCtx(id string) (*core.Workspace, error)
	ListWorkspacesNoCtx() ([]*core.Workspace, error)
	SaveWorkspaceNoCtx(ws *core.Workspace) error
	DeleteWorkspaceNoCtx(id string) error

	GetStatsNoCtx(workspace string, start, end time.Time) (*core.Stats, error)

	GetStatusPageNoCtx(id string) (*core.StatusPage, error)
	ListStatusPagesNoCtx() ([]*core.StatusPage, error)
	SaveStatusPageNoCtx(page *core.StatusPage) error
	DeleteStatusPageNoCtx(id string) error

	// Journey methods
	GetJourneyNoCtx(id string) (*core.JourneyConfig, error)
	ListJourneysNoCtx(workspace string, offset, limit int) ([]*core.JourneyConfig, error)
	SaveJourneyNoCtx(journey *core.JourneyConfig) error
	DeleteJourneyNoCtx(id string) error
}

type User struct {
	ID        string    `json:"id"`
	Email     string    `json:"email"`
	Name      string    `json:"name"`
	Role      string    `json:"role"`
	Workspace string    `json:"workspace"`
	CreatedAt time.Time `json:"created_at"`
}

type WSClient struct {
	ID        string
	Conn      *websocket.Conn
	Workspace string
	UserID    string
	Rooms     map[string]bool
	// contains filtered or unexported fields
}

type WSMessage struct {
	Type      string      `json:"type"`
	Timestamp time.Time   `json:"timestamp"`
	Payload   interface{} `json:"payload"`
}

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