admin

type Access struct {
	Owner         bool
	SetupComplete bool
}

type CatalogBrowser interface {
	BrowseTitles(context.Context, core.BrowseQuery) (core.Page, error)
}

type CatalogHelper interface {
	SearchTitles(ctx context.Context, q string, t core.MediaType, limit int) ([]core.Title, error)
	// Facets: genre, decade, contentRating, studio, country, language.
	Facets(ctx context.Context, t core.MediaType, facet string) ([]core.FacetValue, error)
	// Lookup kinds: person, keyword, company, network, collection, watchProvider.
	Lookup(ctx context.Context, kind, q, region string) ([]core.LookupResult, error)
	TitleDetail(ctx context.Context, key core.RatingKey) (*core.Title, error)
}

type CollectionStudio interface {
	ListSpecs(ctx context.Context) ([]core.CollectionSpec, error)
	GetSpec(ctx context.Context, id string) (*core.CollectionSpec, error)
	CreateSpec(ctx context.Context, spec core.CollectionSpec) (*core.CollectionSpec, error)
	UpdateSpec(ctx context.Context, id string, spec core.CollectionSpec) (*core.CollectionSpec, error)
	DeleteSpec(ctx context.Context, id string) error
	Preview(ctx context.Context, spec core.CollectionSpec, n int) (*core.CollectionPreview, error)
	Rebuild(ctx context.Context, id string) (*core.CollectionSpec, error)
	Templates() []core.CollectionTemplate
	Generate(ctx context.Context, prompt, mediaType string) (*core.CollectionSpec, string, error)
	// Artwork returns the collection's poster at width w.
	Artwork(ctx context.Context, id string, w int) ([]byte, string, time.Time, error)
}

type Deps struct {
	// Extensions are owner-authenticated API subtrees keyed by relative path.
	Extensions    map[string]http.Handler
	ValidateExtra func(config.Config) []FieldError
	// Config is the owner settings store. Required.
	Config *config.Store
	// Logger defaults to slog.Default().
	Logger *slog.Logger
	// Logs is the in-memory log ring served at /ether/api/logs. A fresh
	// 2000-entry buffer is created when nil (retrieve it via
	// Handler.Logs()); pass a shared one to tail server logs.
	Logs *LogBuffer
	// Version is reported by /ether/api/bootstrap ("dev" when empty).
	Version string

	// PlexAuth drives wizard step 1 (plex.tv PIN sign-in and claim).
	PlexAuth PlexAuth

	// SignIn powers "Sign in with Plex" on the admin login screen.
	SignIn SignIn

	// IsOwnerToken reports whether a bearer token belongs to the owner.
	IsOwnerToken func(ctx context.Context, token string) bool

	// Provider/integration testers used by the wizard and settings pages.
	TestUsenet        func(ctx context.Context, p config.UsenetProvider) error
	TestIndexer       func(ctx context.Context, ix config.Indexer) error
	TestDebrid        func(ctx context.Context, p config.DebridProvider) error
	TestTMDB          func(ctx context.Context, key string) error
	TestOpenSubtitles func(ctx context.Context, cfg config.OpenSubtitles) error
	TestLLM           func(ctx context.Context, cfg config.LLM) error
	// LLMModels lists the models the provider in cfg offers.
	LLMModels func(ctx context.Context, cfg config.LLM) ([]LLMModel, error)
	TestTrakt func(ctx context.Context, cfg config.Trakt) error

	// Dashboard status providers. Each non-nil provider appears on the
	// dashboard and at /ether/api/status/{name}.
	SessionsStatus  StatusFunc // "sessions" — now playing
	CacheStatus     StatusFunc // "cache" — usage; {used,budget} renders as a bar
	ProvidersStatus StatusFunc // "providers" — Usenet provider health
	IndexersStatus  StatusFunc // "indexers" — budgets remaining
	CatalogStatus   StatusFunc // "catalog" — catalogue sync/stats
	RemoteStatus    StatusFunc // "remote" — remote access
	HWAccelStatus   StatusFunc // "hwaccel" — transcoding hardware

	// CacheRestartRequired reports whether the saved folder/storage differs
	// from the running cache, including changes made during initial setup.
	CacheRestartRequired func() bool
	// SystemLoad is this machine's recent CPU, memory, network and GPU
	// load, served on its own route because only the Overview polls it.
	SystemLoad StatusFunc
	// ExtraStatus adds/overrides named status providers generically. The
	// "widget" entry is required: it backs GET /ether/api/status.
	ExtraStatus map[string]StatusFunc

	// ResolverTraces backs GET /ether/api/traces.
	ResolverTraces StatusFuncE

	// Users backs the user-administration and viewer endpoints.
	Users UserStore

	// ViewerDirectory lists stored identities for owner administration, including
	// imported or inactive viewers. It must never be used for authentication.
	// Nil preserves the active-user fallback for smaller integrations.
	ViewerDirectory func(context.Context) ([]ViewerRecord, error)

	// TestTimeout bounds each wizard test call (default 20s).
	TestTimeout time.Duration
	// StatusTimeout bounds each status provider call (default 5s).
	StatusTimeout time.Duration

	// DiskUsage overrides free-space reporting (tests). Nil → OS statfs.
	DiskUsage func(path string) (total, free int64, err error)

	// Personalization backs /api/viewers/*, /api/layout and
	// /api/insights/* (internal/personalize.Engine). Viewers are listed
	// from Users.
	Personalization Personalization

	// Collections backs /api/collections* (Collection Studio).
	Collections CollectionStudio
	// CatalogHelper backs /api/catalog/*.
	CatalogHelper     CatalogHelper
	CatalogVisibility func(context.Context, []core.LibraryExclusion) (any, error)
	// Images backs the TMDB image proxy at /api/image.
	Images ImageProxy
}

type FieldError struct {
	Field   string `json:"field"`
	Message string `json:"message"`
}

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

type ImageProxy interface {
	Get(ctx context.Context, path string, w int) ([]byte, string, error)
}

type LLMModel struct {
	ID    string `json:"id"`
	Label string `json:"label,omitempty"`
}

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

type LogEntry struct {
	Time    time.Time         `json:"time"`
	Level   string            `json:"level"`
	Message string            `json:"message"`
	Attrs   map[string]string `json:"attrs,omitempty"`
}

type Personalization interface {
	ViewerStats(ctx context.Context, userIDs []int64) (map[int64]core.ViewerStats, error)
	RecentActivity(ctx context.Context, userID int64, limit int) ([]core.ViewerActivity, error)
	Taste(ctx context.Context, user *core.User) (*core.TasteProfile, error)
	SetTasteOverrides(ctx context.Context, user *core.User, overrides []core.TasteOverride) (*core.TasteProfile, error)
	// PreviewHome is exactly what /hubs (or /hubs/sections/{id} when
	// section is "movies", "shows" or a section id) serves the viewer in
	// the context.
	PreviewHome(ctx context.Context, user *core.User, hc core.HubContext, section string, limit int) (*core.HomePreview, error)
	Refresh(ctx context.Context, user *core.User) error
	// HomeLayout is the saved Home layout document; SetHomeLayout
	// validates and replaces it, applying from the next /hubs request.
	HomeLayout(ctx context.Context) (core.HomeLayout, error)
	SetHomeLayout(ctx context.Context, d core.HomeLayout) (core.HomeLayout, error)
	// PreviewLayout assembles what the viewer would see under a draft
	// document without saving it.
	PreviewLayout(ctx context.Context, user *core.User, hc core.HubContext, section string, limit int, d core.HomeLayout) (*core.HomePreview, error)
	// LayoutDefaults is the default row count per section (home, movies,
	// shows).
	LayoutDefaults() map[string]int
	AvailableRows(ctx context.Context) ([]core.RowDescriptor, error)
	RowInsights(ctx context.Context, days int) ([]core.RowInsight, error)
	// RankerInsight describes the learned ranking model.
	RankerInsight(ctx context.Context) (core.RankerInsight, error)
	Activity(ctx context.Context, days int) ([]core.ActivityDay, error)
}

type PlexAuth interface {
	// StartPIN begins the PIN flow: id is the poll handle, code is the
	// 4-character code shown to the owner, authURL is the plex.tv page to open.
	StartPIN(ctx context.Context) (id, code, authURL string, err error)
	// PollPIN reports whether the owner has approved the PIN yet. When done
	// is true the implementation has stored the owner token in config.
	PollPIN(ctx context.Context, id string) (done bool, err error)
	// Claim claims this server to the signed-in account.
	Claim(ctx context.Context) error
	// Status returns a JSON-able snapshot (claimed, owner, connections...).
	Status() any
}

type SetupStep struct {
	ID       string `json:"id"`
	Title    string `json:"title"`
	Complete bool   `json:"complete"`
	Required bool   `json:"required"`
	Detail   string `json:"detail,omitempty"`
}

type SignIn interface {
	// StartPIN creates a PIN; forwardURL is where plex.tv sends the browser
	// after approval.
	StartPIN(ctx context.Context, forwardURL string) (id, code, authURL string, err error)
	// PINToken returns the account token once approved, "" while pending.
	PINToken(ctx context.Context, id string) (string, error)
}

type StatusFunc func(ctx context.Context) any

type StatusFuncE func(ctx context.Context) (any, error)

type TitleCard struct {
	Key            string   `json:"key"`
	Type           string   `json:"type"`
	Title          string   `json:"title"`
	Year           int      `json:"year,omitempty"`
	Summary        string   `json:"summary,omitempty"`
	Poster         string   `json:"poster,omitempty"`
	Backdrop       string   `json:"backdrop,omitempty"`
	Rating         float64  `json:"rating,omitempty"`
	ContentRating  string   `json:"contentRating,omitempty"`
	RuntimeMinutes int      `json:"runtimeMinutes,omitempty"`
	Genres         []string `json:"genres,omitempty"`
	ShowTitle      string   `json:"showTitle,omitempty"`
	Season         int      `json:"season,omitempty"`
	Episode        int      `json:"episode,omitempty"`
}

type UserStore interface {
	Users(ctx context.Context) ([]core.User, error)
	UpdateUser(ctx context.Context, u core.User) error
}

type ViewerRecord struct {
	core.User
	Active bool
	Origin string
}