core

type AuthProvider interface {
	// ID returns the unique identifier for this auth provider.
	ID() string
	// Name returns the human-readable name.
	Name() string
	// AuthType returns the authentication type (e.g., "oauth", "apikey", "cookie").
	AuthType() string
	// Authenticate performs the authentication flow.
	Authenticate(ctx context.Context) error
	// IsAuthenticated checks if valid credentials exist.
	IsAuthenticated() bool
	// GetCredentials returns the current credentials.
	GetCredentials() (any, error)
	// ClearCredentials removes stored credentials.
	ClearCredentials() error
}

type ConfigOption struct {
	ID          string   `json:"id"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Type        string   `json:"type"` // "bool", "string", "int", "select"
	Default     any      `json:"default"`
	Options     []string `json:"options,omitempty"` // For "select" type
	Required    bool     `json:"required"`
}

type Ingester interface {
	// ID returns the unique identifier for this ingester.
	ID() string
	// Name returns the human-readable name for display.
	Name() string
	// Description returns a brief description of this ingester.
	Description() string
	// SupportedExtensions returns file extensions this ingester handles (e.g., ".zip", ".tgz").
	// For folder ingesters, this returns an empty slice.
	SupportedExtensions() []string
	// CanIngest checks if the given path can be ingested by this module.
	CanIngest(path string) bool
	// Ingest imports data from the source path to the destination directory.
	// Returns the path where data was extracted/copied to.
	Ingest(ctx context.Context, sourcePath, destDir string, progress ProgressFunc) (string, error)
}

type Output interface {
	// ID returns the unique identifier for this output.
	ID() string
	// Name returns the human-readable name for display.
	Name() string
	// Description returns a brief description of this output.
	Description() string
	// ConfigSchema returns the configuration schema for this output.
	ConfigSchema() []ConfigOption
	// SupportedItemTypes returns the item types this output can handle.
	SupportedItemTypes() []string
	// Initialize prepares the output for use (e.g., authentication, connection).
	Initialize(ctx context.Context, cfg OutputConfig) error
	// Export sends a single item to the destination.
	Export(ctx context.Context, item ProcessedItem) error
	// ExportBatch sends multiple items to the destination.
	ExportBatch(ctx context.Context, items []ProcessedItem, progress ProgressFunc) error
	// Finalize completes the export process (e.g., cleanup, finalization).
	Finalize(ctx context.Context) error
}

type OutputConfig struct {
	DestDir  string         `json:"dest_dir"`
	Settings map[string]any `json:"settings"`
}

type ProcessResult struct {
	// ProcessedItems contains items ready for output
	Items []ProcessedItem
	// Stats contains processing statistics
	Stats map[string]int
	// Metadata contains service-specific metadata
	Metadata map[string]any
	// LogPath is the path to the processing log
	LogPath string
}

type ProcessedItem struct {
	// SourcePath is the original source file path
	SourcePath string
	// ProcessedPath is the path after processing (may be same as source)
	ProcessedPath string
	// DestRelPath is the suggested relative path for output
	DestRelPath string
	// Metadata contains item-specific metadata
	Metadata map[string]any
	// Type indicates the item type (e.g., "photo", "video", "playlist", "track")
	Type string
}

type Processor interface {
	// ID returns the unique identifier for this processor.
	ID() string
	// Name returns the human-readable name for display.
	Name() string
	// Description returns a brief description of this processor.
	Description() string
	// ConfigSchema returns the configuration schema for this processor.
	ConfigSchema() []ConfigOption
	// Process runs the processing pipeline on the data.
	Process(ctx context.Context, cfg ProcessorConfig, events chan<- ProgressEvent) (*ProcessResult, error)
}

type ProcessorConfig struct {
	SourceDir  string         `json:"source_dir"`
	WorkDir    string         `json:"work_dir"`    // Working directory for intermediate files
	SessionDir string         `json:"session_dir"` // Session directory for logs
	DryRun     bool           `json:"dry_run"`
	Settings   map[string]any `json:"settings"` // Processor-specific settings
}

type ProgressEvent struct {
	Phase   int
	Label   string
	Done    int
	Total   int
	Message string
}

type ProgressFunc func(done, total int)

type Registry[T any] struct {
	// contains filtered or unexported fields
}

type Service interface {
	// ID returns the unique identifier for this service.
	ID() string
	// Name returns the human-readable name for display.
	Name() string
	// Description returns a brief description of what this service handles.
	Description() string
	// Ingesters returns all available ingestion modules for this service.
	Ingesters() []Ingester
	// Processors returns all available processors for this service.
	Processors() []Processor
	// SupportedOutputs returns the IDs of compatible output modules.
	SupportedOutputs() []string
	// DefaultConfig returns the default configuration for this service.
	DefaultConfig() ServiceConfig
}

type ServiceConfig struct {
	// Service-specific settings stored as a map for flexibility
	Settings map[string]any `json:"settings"`
}

type StreamingOutput interface {
	Output
	// SupportsStreaming returns true if this output can receive streamed data.
	SupportsStreaming() bool
	// ExportStream writes streamed data directly to the destination.
	ExportStream(ctx context.Context, item ProcessedItem, reader io.Reader, size int64) error
}