pluginsdk

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

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

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

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

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

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

type BlockedIP struct {
	IP            string    `json:"ip"`
	Reason        string    `json:"reason"`
	SourceService string    `json:"source_service"`
	BlockedAt     time.Time `json:"blocked_at"`
	ExpiresAt     time.Time `json:"expires_at,omitempty"`
	ThreatScore   int       `json:"threat_score"`
	Categories    []string  `json:"categories"`
}

type CLICommand struct {
	Name        string       `json:"name"`
	Description string       `json:"description"`
	Usage       string       `json:"usage"`
	Flags       []CLIFlag    `json:"flags,omitempty"`
	Subcommands []CLICommand `json:"subcommands,omitempty"`
}

type CLIFlag struct {
	Name        string `json:"name"`
	Shorthand   string `json:"shorthand,omitempty"`
	Description string `json:"description"`
	Type        string `json:"type"` // "string", "int", "bool", "stringSlice"
	Default     string `json:"default,omitempty"`
	Required    bool   `json:"required"`
}

type CLIPlugin interface {
	Info() PluginInfo
	Configure(config map[string]interface{}) error
	Commands() []CLICommand
	Execute(ctx context.Context, command string, args []string, flags map[string]interface{}) (string, error)
	Health() PluginHealth
}

type DataSourcePlugin interface {
	Info() PluginInfo
	Configure(config map[string]interface{}) error
	Connect(ctx context.Context) error
	Disconnect(ctx context.Context) error
	Query(ctx context.Context, query string, params map[string]interface{}) ([]map[string]interface{}, error)
	Subscribe(ctx context.Context, topic string, handler func(data map[string]interface{})) error
	Health() PluginHealth
}

type FirewallPlugin interface {
	Info() PluginInfo
	Configure(config map[string]interface{}) error
	Health() PluginHealth

	// Firewall control
	Enable(ctx context.Context, enable bool, defaultDenyInbound bool, defaultDenyOutbound bool) (*FirewallStatus, error)
	Status(ctx context.Context) (*FirewallStatus, error)

	// IP blocking
	BlockIP(ctx context.Context, ip string, reason string, sourceService string, durationSeconds int64, threatScore int, categories []string) (*BlockedIP, error)
	UnblockIP(ctx context.Context, ip string) error
	ListBlockedIPs(ctx context.Context, limit int, offset int, sourceService string) ([]BlockedIP, int, error)
	IsIPBlocked(ctx context.Context, ip string) (bool, *BlockedIP, error)

	// Rule management
	AddRule(ctx context.Context, rule *FirewallRule) (*FirewallRule, error)
	RemoveRule(ctx context.Context, ruleID string) error
	UpdateRule(ctx context.Context, rule *FirewallRule) (*FirewallRule, error)
	ListRules(ctx context.Context, limit int, offset int, direction string, enabledOnly bool) ([]FirewallRule, int, error)
	GetRule(ctx context.Context, ruleID string) (*FirewallRule, error)

	// Bulk operations
	SyncBlocklist(ctx context.Context, blockedIPs []BlockedIP, replace bool) (added int, removed int, unchanged int, err error)
	FlushRules(ctx context.Context, flushBlocks bool, flushRules bool, keepEssential bool) (rulesFlushed int, blocksFlushed int, err error)

	// Port management (convenience)
	OpenPort(ctx context.Context, port int, protocol string, direction string, sourceIP string, description string) (*FirewallRule, error)
	ClosePort(ctx context.Context, port int, protocol string, direction string) error
}

type FirewallRule struct {
	ID            string    `json:"id"`
	Name          string    `json:"name"`
	Description   string    `json:"description"`
	Direction     string    `json:"direction"`   // "inbound", "outbound", "both"
	Action        string    `json:"action"`      // "allow", "deny", "drop", "reject"
	Protocol      string    `json:"protocol"`    // "tcp", "udp", "icmp", "any"
	SourceIP      string    `json:"source_ip"`   // CIDR notation
	SourcePort    string    `json:"source_port"` // Port or range
	DestIP        string    `json:"dest_ip"`
	DestPort      string    `json:"dest_port"`
	Interface     string    `json:"interface"`
	Priority      int       `json:"priority"`
	Enabled       bool      `json:"enabled"`
	CreatedAt     time.Time `json:"created_at"`
	ExpiresAt     time.Time `json:"expires_at,omitempty"`
	Reason        string    `json:"reason"`
	SourceService string    `json:"source_service"`
	HitCount      int64     `json:"hit_count"`
	LastHitAt     time.Time `json:"last_hit_at,omitempty"`
}

type FirewallStatus struct {
	Enabled             bool              `json:"enabled"`
	Backend             string            `json:"backend"`
	Version             string            `json:"version"`
	TotalRules          int               `json:"total_rules"`
	ActiveRules         int               `json:"active_rules"`
	BlockedIPs          int               `json:"blocked_ips"`
	DefaultDenyInbound  bool              `json:"default_deny_inbound"`
	DefaultDenyOutbound bool              `json:"default_deny_outbound"`
	LastUpdated         time.Time         `json:"last_updated"`
	Capabilities        map[string]string `json:"capabilities"`
}

type PluginHealth struct {
	State     PluginState            `json:"state"`
	Message   string                 `json:"message,omitempty"`
	LastCheck time.Time              `json:"last_check"`
	Metrics   map[string]interface{} `json:"metrics,omitempty"`
}

type PluginInfo struct {
	Name         string     `json:"name"`
	Version      string     `json:"version"`
	Type         PluginType `json:"type"`
	Description  string     `json:"description"`
	Author       string     `json:"author"`
	License      string     `json:"license"`
	Capabilities []string   `json:"capabilities,omitempty"`
}

type PluginState int

type PluginType string

type ReporterPlugin interface {
	Info() PluginInfo
	Configure(config map[string]interface{}) error
	SupportedFormats() []string
	Generate(ctx context.Context, format string, data map[string]interface{}) ([]byte, error)
	Health() PluginHealth
}

type ServicePlugin interface {
	Info() PluginInfo
	Configure(config map[string]interface{}) error
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Health() PluginHealth
	Execute(ctx context.Context, action string, params map[string]interface{}) (map[string]interface{}, error)
}

type StoragePlugin interface {
	Info() PluginInfo
	Configure(config map[string]interface{}) error
	Connect(ctx context.Context) error
	Disconnect(ctx context.Context) error
	Get(ctx context.Context, collection, key string) ([]byte, error)
	Set(ctx context.Context, collection, key string, value []byte) error
	Delete(ctx context.Context, collection, key string) error
	List(ctx context.Context, collection, prefix string) ([]string, error)
	Query(ctx context.Context, collection string, query map[string]interface{}) ([][]byte, error)
	Health() PluginHealth
}