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 {
	Frontends        FrontendAdmin
	FavoritesMirror  FavoritesMirror
	NotInterested    NotInterestedPortal
	ViewerAlerts     ViewerAlertPreferences
	ActiveViewer     func(context.Context, int64) (*core.User, error)
	ViewerPortalURL  func(context.Context, *http.Request) (string, error)
	StremioPortalURL func(context.Context, *http.Request) (string, error)
	CreateDLNAGuest  func(context.Context) (*core.Viewer, error)
	LocalIdentity    *identity.Local
	IdentityGrants   *identity.Grants
	IdentityLimiter  *identity.LoginLimiter
	// OwnerCredentialChanged runs after an owner local sign-in, setup and
	// any local password change (the app refreshes the owner's recovery
	// sign-in from it). Nil does nothing.
	OwnerCredentialChanged func(context.Context)
	PollLimiter            *identity.LoginLimiter
	QuickConnect           *identity.QuickConnect
	Invites                *identity.Invite
	RefreshViewers         func(context.Context) error
	OwnerConfigured        func(context.Context) bool
	LocalOwnerConfigured   func(context.Context) bool
	SetViewerActive        func(context.Context, int64, bool) error
	AuthenticatePlex       func(context.Context, string) (*core.User, error)
	LinkPlex               func(context.Context, int64, string) error

	// 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
	// LogDir holds the on-disk logs offered by GET /api/logs/download;
	// empty offers the in-memory buffer instead.
	LogDir string
	// Support is the in-memory problem-capture recorder. Nil answers the
	// support routes with the same not-found result as an unknown path.
	Support *diagnostics.Recorder
	// 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 (an owner credential or
	// a console session) belongs to the owner.
	IsOwnerToken func(ctx context.Context, token string) bool

	// Sessions backs console sign-in and sign-out.
	Sessions Sessions

	// 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
	// TestIntroDB probes TheIntroDB with the posted key, or the stored key
	// when the post is empty or still redacted.
	TestIntroDB func(ctx context.Context, apiKey string) 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, string) (any, error)
	// WaitingReleaseKeys are in-window movies still hidden from viewers.
	// Nil leaves the waiting catalog filter empty.
	WaitingReleaseKeys func(context.Context) []core.RatingKey
	// Images backs the TMDB image proxy at /api/image.
	Images ImageProxy

	// PlexWatch is the per-viewer Plex account watch-state integration.
	// Nil hides the routes.
	PlexWatch PlexWatch
}

type FavoritesMirror interface {
	MirrorEnabled(context.Context, *core.User) (bool, error)
	SetMirror(context.Context, *core.User, bool) error
}

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

type FrontendAdmin interface {
	List(context.Context) ([]FrontendInfo, error)
	Settings(context.Context, frontend.Protocol) (frontend.Settings, error)
	PutSettings(context.Context, frontend.Protocol, frontend.Settings) error
	Toggle(context.Context, frontend.Protocol, bool) error
}

type FrontendInfo struct {
	Descriptor frontend.Descriptor `json:"descriptor"`
	Enabled    bool                `json:"enabled"`
	Status     frontend.Status     `json:"status"`
}

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 NotInterestedEntry struct {
	Handle string `json:"handle"`
	Title  string `json:"title,omitempty"`
	Key    string `json:"key,omitempty"`
}

type NotInterestedPortal interface {
	ListNotInterested(context.Context, *core.User) ([]NotInterestedEntry, error)
	RestoreNotInterested(context.Context, *core.User, string) (bool, error)
}

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 recorded the owner account for Claim.
	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 PlexWatch interface {
	Status(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	BeginPIN(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	FinishPIN(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	SetEnabled(ctx context.Context, userID, plexID int64, on bool) (PlexWatchStatus, error)
	Disconnect(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	Retry(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	Resolve(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	ExportCurrent(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
	ImportCurrent(ctx context.Context, userID, plexID int64) (PlexWatchStatus, error)
}

type PlexWatchStatus struct {
	Connected    bool   `json:"connected"`
	PlexID       int64  `json:"plexId,omitempty"`
	Username     string `json:"username,omitempty"`
	Enabled      bool   `json:"enabled"`
	Eligibility  string `json:"eligibility"`
	Revoked      bool   `json:"revoked"`
	Pending      int    `json:"pending"`
	Held         int    `json:"held"`
	HeldLegacy   int    `json:"heldLegacy"`
	Dead         int    `json:"dead"`
	InFlight     bool   `json:"inFlight"`
	Skipped      int    `json:"skipped"`
	Restricted   bool   `json:"restricted"`
	PINCode      string `json:"pinCode,omitempty"`
	PINURL       string `json:"pinUrl,omitempty"`
	PINExpires   string `json:"pinExpires,omitempty"`
	AccountMatch bool   `json:"accountMatch"`
}

type Sessions interface {
	// IssueOwnerSession exchanges an owner credential for a session. It
	// fails with core.ErrUnauthorized unless credential is the owner's.
	IssueOwnerSession(ctx context.Context, credential string) (token string, expires time.Time, err error)
	// RevokeOwnerSession ends a session; other tokens are ignored.
	RevokeOwnerSession(ctx context.Context, token string) error
}

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"`
	// ContentRatingSource is where ContentRating came from ("tmdb:US:6",
	// "omdb"); see core.Title.
	ContentRatingSource string   `json:"contentRatingSource,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 ViewerAlertPreferences interface {
	Enabled(context.Context, *core.User) (bool, error)
	SetEnabled(context.Context, *core.User, bool) error
}

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