prefetch

type Deps struct {
	Catalog  core.Catalog
	Resolver core.Resolver
	Engine   core.Engine
	State    core.State
	Auth     core.Auth
	Hints    Hints
	Logger   *slog.Logger

	// PostPlay ranks the personalized hook queue (optional; #30). With
	// it set, the end of a movie or season/series finale pre-buffers the
	// #1 pick instead of relying on next-episode prefetch.
	PostPlay core.PostPlayer
	// Prewarmer warms the pick through the playback manager when it
	// implements core.Prewarmer; nil falls back to resolve + Engine.Prefetch.
	Prewarmer core.Prewarmer
	// Markers supplies credits ranges through the markers service API
	// (optional; without it the trigger is duration − 3 minutes).
	Markers MarkerSource
	// PostPlayEnabled reports the owner's switch (nil = on).
	PostPlayEnabled func() bool
}

type Hints interface {
	// ResumePoint is the release that last served a user's title.
	ResumePoint(ctx context.Context, userID int64, key core.RatingKey) (*playback.ResumePoint, error)
	// ResumeFor is the stored release a Prepare from this client would open.
	ResumeFor(ctx context.Context, user *core.User, key core.RatingKey, caps core.ClientCaps) (*playback.ResumePoint, error)
	// Remember stores a prefetched resolution so playback opens the same release.
	Remember(ctx context.Context, user *core.User, key core.RatingKey, caps core.ClientCaps, res *core.Resolution) error
	// ClientCaps returns the caps of the user's session for key (live) or
	// of the user's latest session.
	ClientCaps(userID int64, key core.RatingKey) (caps core.ClientCaps, live bool, ok bool)
}

type MarkerSource interface {
	Markers(ctx context.Context, key core.RatingKey, info core.MediaInfo) ([]markers.Marker, error)
}

type Options struct {
	// Concurrency is the global limit of prefetch jobs running at once (default 2).
	Concurrency int
	// QueueSize bounds queued jobs; more are dropped (default 128).
	QueueSize int
	// WarmInterval is how often in-progress resume points are warmed (default 15m).
	WarmInterval time.Duration
	// WarmBehind is pulled before the resume point, for the client's
	// rewind-on-resume (default 4 MiB). The window after it is
	// Cache.PrefetchBytes.
	WarmBehind int64
	// InProgressLimit is how many in-progress titles per user are warmed (default 20).
	InProgressLimit int
	// DoneTTL suppresses repeating a finished next-episode job (default 6h).
	DoneTTL time.Duration
	// RetryAfter suppresses retrying a failed job (default 30m).
	RetryAfter time.Duration
	// JobTimeout bounds one job (default 10m).
	JobTimeout time.Duration
	// PostPlayBytes is how much of the #1 post-play pick to pre-buffer
	// (default 40 MiB, inside the 32–48 MiB the countdown needs).
	PostPlayBytes int64
	// Now is the clock (tests).
	Now func() time.Time
}

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

type Stats struct {
	Queued    int   `json:"queued"`
	Running   int   `json:"running"`
	Completed int64 `json:"completed"`
	Failed    int64 `json:"failed"`
	Dropped   int64 `json:"dropped"`
}