plugins

type BinaryDependency struct {
	Binary       string            `json:"binary"`        // Binary name (e.g., "ffmpeg")
	Check        string            `json:"check"`         // Command to verify (e.g., "ffmpeg -version")
	VersionRegex string            `json:"version_regex"` // Regex to extract version
	MinVersion   string            `json:"min_version"`   // Minimum required version
	Install      map[string]string `json:"install"`       // Package manager -> install command

	// Runtime state (not serialized)
	Found   bool   `json:"-"`
	Version string `json:"-"`
}

type Config struct {
	// Plugin directories to scan
	PluginDirs []string `json:"plugin_dirs,omitempty"`

	// Disabled plugins (by ID)
	Disabled []string `json:"disabled,omitempty"`

	// Plugin-specific settings
	PluginSettings map[string]map[string]any `json:"plugin_settings,omitempty"`

	// Hot-reload enabled
	HotReload bool `json:"hot_reload,omitempty"`
}

type ConfigError struct {
	PluginID string
	Field    string
	Reason   string
}

type ConfigOption struct {
	ID          string   `json:"id"`
	Name        string   `json:"name"`
	Description string   `json:"description,omitempty"`
	Type        string   `json:"type"` // bool, string, int, float, select, path, password
	Default     any      `json:"default,omitempty"`
	Options     []string `json:"options,omitempty"` // For select type
	Required    bool     `json:"required,omitempty"`
	Sensitive   bool     `json:"sensitive,omitempty"` // If true, mask in UI
}

type ConnectorPlugin interface {
	Plugin

	// AsConnector returns the base connector interface.
	AsConnector() core.Connector

	// AsReader returns the reader interface if supported.
	AsReader() (core.ConnectorReader, bool)

	// AsWriter returns the writer interface if supported.
	AsWriter() (core.ConnectorWriter, bool)

	// AsTester returns the tester interface if supported.
	AsTester() (core.ConnectorTester, bool)
}

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

type DependencyError struct {
	Binary  string
	Message string
	Install map[string]string
}

type DependencyStatus struct {
	Binary    string
	Found     bool
	Path      string
	Version   string
	MeetsMin  bool
	MinNeeded string
	Error     string
}

type DiscoveredPlugin struct {
	Path     string
	Type     PluginType
	Tier     PluginTier
	Info     *PluginInfo
	Manifest *ExternalManifest
	Source   PluginSource
	Error    string
}

type ExternalManifest struct {
	APIVersion string               `json:"apiVersion"` // e.g., "revoco/v1"
	Kind       string               `json:"kind"`       // "ExternalPlugin"
	Metadata   ExternalManifestMeta `json:"metadata"`
	Spec       ExternalManifestSpec `json:"spec"`
}

type ExternalManifestMeta struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
	Version     string `json:"version"`
	Author      string `json:"author,omitempty"`
}

type ExternalManifestSpec struct {
	Type            PluginType         `json:"type"` // connector, processor, output
	Runtime         ExternalRuntime    `json:"runtime"`
	Entrypoint      string             `json:"entrypoint"`
	Setup           *ExternalSetup     `json:"setup,omitempty"`
	Capabilities    []string           `json:"capabilities,omitempty"`
	DataTypes       []string           `json:"dataTypes,omitempty"`
	RequiresAuth    bool               `json:"requiresAuth,omitempty"`
	AuthType        string             `json:"authType,omitempty"`
	ConfigSchema    []ConfigOption     `json:"configSchema,omitempty"`
	DefaultSelector *Selector          `json:"defaultSelector,omitempty"`
	Dependencies    []BinaryDependency `json:"dependencies,omitempty"`
}

type ExternalRuntime struct {
	Command      string `json:"command"`      // e.g., "python3"
	MinVersion   string `json:"minVersion"`   // e.g., "3.9"
	VersionCheck string `json:"versionCheck"` // e.g., "python3 --version"
}

type ExternalSetup struct {
	Command string `json:"command"` // e.g., "pip install -r requirements.txt"
	RunWhen string `json:"runWhen"` // File to check for changes (e.g., "requirements.txt")
}

type InstalledPlugin struct {
	Entry       RegistryEntry `json:"entry"`
	InstalledAt time.Time     `json:"installed_at"`
	UpdatedAt   time.Time     `json:"updated_at"`
	Source      string        `json:"source"` // "registry", "local", "url"
	SourcePath  string        `json:"source_path"`
	LocalPath   string        `json:"local_path"`
}

type InstalledPluginsDB struct {
	Version   string                     `json:"version"`
	Plugins   map[string]InstalledPlugin `json:"plugins"`
	UpdatedAt time.Time                  `json:"updated_at"`
}

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

type InstallerOption func(*Installer)

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

type LuaError struct {
	PluginID string
	Function string
	Message  string
}

type LuaPluginMeta struct {
	ID           string   `lua:"id"`
	Name         string   `lua:"name"`
	Description  string   `lua:"description"`
	Version      string   `lua:"version"`
	Type         string   `lua:"type"` // connector, processor, output
	Capabilities []string `lua:"capabilities,omitempty"`
	DataTypes    []string `lua:"data_types,omitempty"`
	RequiresAuth bool     `lua:"requires_auth,omitempty"`
	AuthType     string   `lua:"auth_type,omitempty"`
}

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

type ManagerOption func(*Manager)

type ManifestError struct {
	Path   string
	Field  string
	Reason string
}

type OutputPlugin interface {
	Plugin

	// AsOutput returns the output interface.
	AsOutput() svccore.Output

	// Selector returns the default selector for this output.
	Selector() *Selector
}

type Plugin interface {
	// Info returns the plugin metadata.
	Info() PluginInfo

	// Load initializes the plugin. Called once when discovered.
	Load(ctx context.Context) error

	// Unload releases any resources held by the plugin.
	Unload() error

	// Reload reloads the plugin (for hot-reload support).
	Reload(ctx context.Context) error
}

type PluginConfig struct {
	PluginID string         `json:"plugin_id"`
	Enabled  bool           `json:"enabled"`
	Settings map[string]any `json:"settings"`
	Selector *Selector      `json:"selector,omitempty"`
}

type PluginError struct {
	PluginID string
	Op       string // Operation that failed
	Err      error
}

type PluginFactory func(dp *DiscoveredPlugin) (Plugin, error)

type PluginInfo struct {
	// Identity
	ID          string `json:"id"`
	Name        string `json:"name"`
	Description string `json:"description"`
	Version     string `json:"version"`
	Author      string `json:"author,omitempty"`

	// Classification
	Type   PluginType   `json:"type"`
	Tier   PluginTier   `json:"tier"`
	Source PluginSource `json:"source"`

	// Location
	Path string `json:"path"` // File path or directory

	// State
	State      PluginState `json:"state"`
	StateError string      `json:"state_error,omitempty"`

	// Capabilities (for connectors)
	Capabilities []core.ConnectorCapability `json:"capabilities,omitempty"`
	DataTypes    []core.DataType            `json:"data_types,omitempty"`
	RequiresAuth bool                       `json:"requires_auth,omitempty"`
	AuthType     string                     `json:"auth_type,omitempty"`

	// Configuration
	ConfigSchema []ConfigOption `json:"config_schema,omitempty"`

	// Dependencies
	Dependencies []BinaryDependency `json:"dependencies,omitempty"`

	// Default selector (for processors and outputs)
	DefaultSelector *Selector `json:"default_selector,omitempty"`
}

type PluginReader struct {
	io.ReadCloser
	Plugin Plugin
	Item   *core.DataItem
}

type PluginSource string

type PluginState string

type PluginTier string

type PluginType string

type PluginUpdate struct {
	ID             string
	CurrentVersion string
	LatestVersion  string
	Entry          RegistryEntry
}

type Processor interface {
	// Identity
	ID() string
	Name() string
	Description() string

	// Configuration
	ConfigSchema() []ConfigOption

	// Selector
	DefaultSelector() *Selector

	// Processing
	CanProcess(item *core.DataItem) bool
	Process(ctx context.Context, item *core.DataItem, config map[string]any) (*core.DataItem, error)
	ProcessBatch(ctx context.Context, items []*core.DataItem, config map[string]any, progress ProgressFunc) ([]*core.DataItem, error)
}

type ProcessorPlugin interface {
	Plugin

	// AsProcessor returns the processor interface.
	AsProcessor() Processor

	// Selector returns the default selector for this processor.
	Selector() *Selector
}

type ProgressFunc func(done, total int, message string)

type RPCCallError struct {
	PluginID string
	Method   string
	Code     int
	Message  string
}

type RPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Data    any    `json:"data,omitempty"`
}

type RPCRequest struct {
	JSONRPC string         `json:"jsonrpc"`
	ID      int            `json:"id,omitempty"`
	Method  string         `json:"method"`
	Params  map[string]any `json:"params,omitempty"`
}

type RPCResponse struct {
	JSONRPC string    `json:"jsonrpc"`
	ID      int       `json:"id,omitempty"`
	Result  any       `json:"result,omitempty"`
	Error   *RPCError `json:"error,omitempty"`
}

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

type RegistryEntry struct {
	ID          string            `json:"id"`
	Name        string            `json:"name"`
	Description string            `json:"description"`
	Author      string            `json:"author"`
	Version     string            `json:"version"`
	Type        PluginType        `json:"type"`
	Tier        PluginTier        `json:"tier"`
	Tags        []string          `json:"tags,omitempty"`
	Homepage    string            `json:"homepage,omitempty"`
	Repository  string            `json:"repository,omitempty"`
	License     string            `json:"license,omitempty"`
	Downloads   int               `json:"downloads,omitempty"`
	Path        string            `json:"path"` // Path within the plugins branch
	Checksum    string            `json:"checksum,omitempty"`
	Platforms   []string          `json:"platforms,omitempty"`   // e.g., ["linux", "darwin", "windows"]
	MinVersion  string            `json:"min_version,omitempty"` // Minimum revoco version
	Deprecated  bool              `json:"deprecated,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"`
}

type RegistryIndex struct {
	Version     string                   `json:"version"`
	LastUpdated time.Time                `json:"last_updated"`
	Plugins     map[string]RegistryEntry `json:"plugins"`
}

type RegistryStats struct {
	Total      int
	Connectors int
	Processors int
	Outputs    int
	ByTier     map[PluginTier]int
	ByState    map[PluginState]int
}

type Selector struct {
	// By data type
	DataTypes []core.DataType `json:"data_types,omitempty" yaml:"data_types,omitempty"`

	// By file extension (e.g., ".jpg", ".png")
	Extensions []string `json:"extensions,omitempty" yaml:"extensions,omitempty"`

	// By MIME type (supports wildcards like "image/*")
	MimeTypes []string `json:"mime_types,omitempty" yaml:"mime_types,omitempty"`

	// By source connector ID
	SourceConnectors []string `json:"source_connectors,omitempty" yaml:"source_connectors,omitempty"`

	// By path pattern (glob)
	PathMatch   string `json:"path_match,omitempty" yaml:"path_match,omitempty"`
	PathExclude string `json:"path_exclude,omitempty" yaml:"path_exclude,omitempty"`

	// By metadata condition (Lua expression evaluated at runtime)
	Condition string `json:"condition,omitempty" yaml:"condition,omitempty"`

	// Chain from another job's output
	From string `json:"from,omitempty" yaml:"from,omitempty"`

	// Select all items (overrides other filters)
	All bool `json:"all,omitempty" yaml:"all,omitempty"`
}

type SelectorError struct {
	Field string
	Err   error
}

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

type WatchOp int