scanning

type ActivityTracker interface {
	Start(action, detail string, source activity.ActivitySource) string
	StartScan(action, detail string, source activity.ActivitySource,
		scope activity.ScanScope, role auth.Role) (id string, existing bool)
	End(id string)
	Fail(id string)
	FinishCancelled(id string)
	Progress(id string, current, total int, msg string)
	SetQueued(id string, queued bool)
	IsCancelled(id string) bool
}

type AlertRecorder interface {
	Record(category, msg string)
	RecordInfo(msg string)
}

type BGTracker interface {
	Add(delta int)
	Done()
}

type BackoffPrefixReader interface {
	GetBackoffByPrefix(ctx context.Context, mediaType api.MediaType, mediaIDPrefix string) ([]api.BackoffEntry, error)
}

type Deps struct {
	DB ScanStore
	// Backoff feeds season-tracker earlyStop seeding from existing
	// adaptive-backoff rows. Optional: nil disables seeding.
	Backoff       BackoffPrefixReader
	Metrics       ScanMetrics
	Events        EventPublisher
	Activity      ActivityTracker
	Alerts        AlertRecorder
	ShowSkipCache *showskip.Cache
	// ClearCaches clears provider download caches after scan completion.
	ClearCaches func(providers []api.Provider)
}

type EventPublisher interface {
	PublishCoverageUpdate(mediaType api.MediaType, mediaID string)
	PublishScanStart(action, detail string, source activity.ActivitySource, actID string)
	PublishScanDone(action, detail string, source activity.ActivitySource, actID string, outcome activity.Outcome)
}

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

type HandlerDeps struct {
	// StateFunc returns the current live state snapshot as BOTH views one
	// operation needs — the handler view and the scanning-engine view —
	// derived from ONE generation read, so the two views can never straddle
	// a hot reload.
	StateFunc func() (*HandlerState, *LiveState)
	// CtxFunc returns the server-level context (outlives individual requests).
	CtxFunc func() context.Context
	// ScanDeps provides the scanning engine dependencies (stable server
	// singletons, not generation state).
	ScanDeps func() *Deps
	// Activity tracks scan activity lifecycle.
	Activity ActivityTracker
	// Stops registers the graceful stop callbacks of running scans.
	Stops *activity.StopRegistry
	// ScanGuard serializes manual scan requests.
	ScanGuard *ScanGuard
	// Alerts records alerts visible in the UI.
	Alerts AlertRecorder
	// Events publishes SSE events.
	Events EventPublisher
	// InvalidateStats clears the stats cache after scan completion.
	InvalidateStats func()
	// BGTracker tracks background goroutine lifecycle for graceful shutdown.
	BGTracker BGTracker
}

type HandlerState struct {
	Cfg    api.ConfigProvider
	Engine api.SearchEngine
	Sonarr ScanHandlerSonarr // nil when sonarr not configured
	Radarr ScanHandlerRadarr // nil when radarr not configured
}

type LiveState struct {
	Cfg         api.ConfigProvider
	Engine      api.SearchEngine
	Sonarr      ScanSonarrClient
	Radarr      ScanRadarrClient
	ShowCounter api.ShowSubtitleCounter
	Providers   []api.Provider
}

type ScanAccepted struct {
	ActivityID string `json:"activity_id"`
	Status     string `json:"status"`
}

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

type ScanHandlerRadarr interface {
	GetMovieByID(ctx context.Context, id int) (arrapi.Movie, error)
}

type ScanHandlerSonarr interface {
	GetSeriesByID(ctx context.Context, id int) (arrapi.Series, error)
	GetEpisodes(ctx context.Context, seriesID int) ([]arrapi.Episode, error)
}

type ScanItem struct {
	Series *arrapi.Series  // non-nil for episodes
	Ep     *arrapi.Episode // non-nil for episodes
	Movie  *arrapi.Movie   // non-nil for movies
}

type ScanMetrics interface {
	RecordScan(items, found int, dur time.Duration)
	AdaptiveSkip()
}

type ScanOutcome = api.ScanOutcome

type ScanRadarrClient interface {
	GetWantedMovies(ctx context.Context, excludeTagIDs map[int]struct{}, fn func(arrapi.Movie) error) error
	ResolveExcludeTagIDs(ctx context.Context, tagNames []string, logMissing bool) map[int]struct{}
	RescanMovie(ctx context.Context, movieID int) error
}

type ScanSonarrClient interface {
	GetWantedEpisodes(ctx context.Context, excludeTagIDs map[int]struct{}, fn func(arrapi.Series, arrapi.Episode) error) error
	ResolveExcludeTagIDs(ctx context.Context, tagNames []string, logMissing bool) map[int]struct{}
	RescanSeries(ctx context.Context, seriesID int) error
}

type ScanStore interface {
	RecentlyScanned(ctx context.Context, cutoff time.Time) (map[string]bool, error)
	RecordScanState(ctx context.Context, rec *api.ScanRecord) error
	// Scan-cycle mark (duration-aware resume): set when a full scan begins,
	// cleared on normal completion. A dangling mark at the next scan start
	// means the previous cycle was interrupted; the resume cutoff extends
	// back to that cycle's start so a pass longer than scan_interval keeps
	// its early segment in the resume set. ScanCycleStart returns the zero
	// time when no mark is stored.
	ScanCycleStart(ctx context.Context) (time.Time, error)
	SetScanCycleStart(ctx context.Context, t time.Time) error
	ClearScanCycleStart(ctx context.Context) error
}