aggregator

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

type AggregatorInterface interface {
	// Aggregate merges multiple scraper results into a single Movie based on field-level priorities
	Aggregate(results []*models.ScraperResult) (*models.Movie, error)

	// AggregateWithPriority aggregates results using a custom scraper priority order
	AggregateWithPriority(results []*models.ScraperResult, customPriority []string) (*models.Movie, error)

	// GetResolvedPriorities returns the cached field-level priority map (for debugging)
	GetResolvedPriorities() map[string][]string
}

type AggregatorOptions struct {
	// GenreReplacementRepo is an optional genre replacement repository for tests.
	// If nil, loadGenreReplacementCache() is skipped (empty cache).
	// If non-nil, genre replacements are loaded from the repository during initialization.
	GenreReplacementRepo database.GenreReplacementRepositoryInterface

	// ActressAliasRepo is an optional actress alias repository for tests.
	// If nil, loadActressAliasCache() is skipped (empty cache).
	// If non-nil, actress aliases are loaded from the repository during initialization.
	ActressAliasRepo database.ActressAliasRepositoryInterface

	// TemplateEngine is an optional template engine for tests.
	// If nil, a real template.NewEngine() is created.
	// If non-nil, the injected template engine is used.
	TemplateEngine *template.Engine

	// GenreCache is an optional pre-populated genre replacement cache for tests.
	// If non-nil, this cache is used directly without loading from database.
	// Takes precedence over GenreReplacementRepo if both are provided.
	GenreCache map[string]string

	// ActressCache is an optional pre-populated actress alias cache for tests.
	// If non-nil, this cache is used directly without loading from database.
	// Takes precedence over ActressAliasRepo if both are provided.
	ActressCache map[string]string

	// Scrapers is an optional list of scrapers for dependency injection.
	// If non-nil, the scrapers are used in order as their priority for aggregation.
	// If nil, scraperutil.GetPriorities() is used for backward compatibility.
	Scrapers []models.Scraper
}