plugins

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

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

type ConnectionInterceptor interface {
	Plugin

	// OnConnectionStart 连接开始时调用
	OnConnectionStart(ctx context.Context, conn types.Connection) error

	// OnConnectionEnd 连接结束时调用
	OnConnectionEnd(ctx context.Context, conn types.Connection, duration time.Duration) error
}

type DataProcessor interface {
	Plugin

	// ProcessData 处理数据
	ProcessData(ctx context.Context, data []byte, direction types.PacketDirection) ([]byte, error)
}

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

type GlobalConfig struct {
	// 插件系统启用状态
	Enabled bool `json:"enabled"`

	// 插件目录
	PluginsDir string `json:"plugins_dir"`

	// 配置目录
	ConfigDir string `json:"config_dir"`

	// 自动加载插件
	AutoLoad bool `json:"auto_load"`

	// 热重载
	EnableHotReload bool `json:"enable_hot_reload"`

	// 默认插件优先级
	DefaultPriority int `json:"default_priority"`

	// 全局白名单
	GlobalWhitelist []string `json:"global_whitelist"`

	// 全局黑名单
	GlobalBlacklist []string `json:"global_blacklist"`

	// 插件超时设置
	LoadTimeout    int `json:"load_timeout_seconds"`
	ExecuteTimeout int `json:"execute_timeout_seconds"`

	// 安全设置
	Security SecurityConfig `json:"security"`
}

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

type InterceptContext struct {
	Request         *http.Request
	Response        *http.Response
	Connection      types.Connection
	Timestamp       time.Time
	RequestBody     []byte
	ResponseBody    []byte
	RequestHeaders  http.Header
	ResponseHeaders http.Header
	Metadata        map[string]interface{}
}

type InterceptResult struct {
	// Continue 是否继续处理
	Continue bool
	// Modified 是否修改了请求/响应
	Modified bool
	// Message 处理消息
	Message string
	// Error 错误信息
	Error error
	// Metadata 元数据
	Metadata map[string]interface{}
}

type InterceptorType int

type Logger interface {
	Info(msg string, args ...interface{})
	Error(msg string, args ...interface{})
	Debug(msg string, args ...interface{})
	Warn(msg string, args ...interface{})
}

type ManagerConfig struct {
	PluginsDir      string        `json:"plugins_dir"`
	ConfigDir       string        `json:"config_dir"`
	AutoLoad        bool          `json:"auto_load"`
	LoadTimeout     time.Duration `json:"load_timeout"`
	EnableHotReload bool          `json:"enable_hot_reload"`
	WatchInterval   time.Duration `json:"watch_interval"`
}

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

type Plugin interface {
	// GetInfo 获取插件信息
	GetInfo() PluginInfo

	// Initialize 初始化插件
	Initialize(ctx context.Context, config PluginConfig) error

	// Start 启动插件
	Start(ctx context.Context) error

	// Stop 停止插件
	Stop(ctx context.Context) error

	// IsEnabled 检查插件是否启用
	IsEnabled() bool

	// GetPriority 获取插件优先级（数字越小优先级越高）
	GetPriority() int
}

type PluginAPI interface {
	// GetLogger 获取日志器
	GetLogger(pluginName string) Logger

	// GetConfig 获取应用配置
	GetConfig() types.Config

	// SendNotification 发送通知
	SendNotification(title, message string) error

	// GetMetrics 获取指标
	GetMetrics() map[string]interface{}

	// StoreData 存储数据
	StoreData(key string, value interface{}) error

	// GetData 获取数据
	GetData(key string) (interface{}, error)
}

type PluginConfig struct {
	Enabled   bool                   `json:"enabled"`
	Priority  int                    `json:"priority"`
	Settings  map[string]interface{} `json:"settings"`
	Whitelist []string               `json:"whitelist,omitempty"`
	Blacklist []string               `json:"blacklist,omitempty"`
}

type PluginFactory func(api PluginAPI) Plugin

type PluginInfo struct {
	Name        string `json:"name"`
	Version     string `json:"version"`
	Description string `json:"description"`
	Author      string `json:"author"`
	Category    string `json:"category"`
}

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

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

type PluginMetadata struct {
	Info     PluginInfo    `json:"info"`
	Config   PluginConfig  `json:"config"`
	FilePath string        `json:"file_path"`
	Factory  PluginFactory `json:"-"`
}

type RequestInterceptor interface {
	Plugin

	// InterceptRequest 拦截请求
	InterceptRequest(ctx context.Context, interceptCtx *InterceptContext) (*InterceptResult, error)
}

type ResponseInterceptor interface {
	Plugin

	// InterceptResponse 拦截响应
	InterceptResponse(ctx context.Context, interceptCtx *InterceptContext) (*InterceptResult, error)
}

type SecurityConfig struct {
	// 允许插件访问的功能
	AllowedAPIs []string `json:"allowed_apis"`

	// 插件沙箱模式
	SandboxMode bool `json:"sandbox_mode"`

	// 资源限制
	MaxMemoryMB int `json:"max_memory_mb"`
	MaxCPUTime  int `json:"max_cpu_time_seconds"`

	// 签名验证
	RequireSignature bool     `json:"require_signature"`
	TrustedKeys      []string `json:"trusted_keys"`
}

type WebSocketContext struct {
	Connection  types.Connection
	Request     *http.Request        // WebSocket升级请求
	MessageType WebSocketMessageType // 消息类型
	Message     []byte               // 消息内容
	Direction   WebSocketDirection   // 消息方向
	Timestamp   time.Time
	Metadata    map[string]interface{}
}

type WebSocketDirection int

type WebSocketInterceptor interface {
	Plugin

	// InterceptWebSocketMessage 拦截WebSocket消息
	InterceptWebSocketMessage(ctx context.Context, interceptCtx *WebSocketContext) (*InterceptResult, error)
}

type WebSocketMessageType int