cachefill

type Cache interface {
	core.SegmentCache
	ReleaseBytes(string) int64
	Pins() map[string][]string
	Describe(string, string, int64)
}

type Catalog interface {
	Browse(context.Context, core.BrowseQuery) (core.Page, error)
	CachedTitle(context.Context, core.RatingKey) (*core.Title, error)
	Children(context.Context, core.RatingKey) ([]core.Title, error)
}

type Deps struct {
	Shared *SharedStore // nil for a node-local shelf
	// Household returns active members of the configured household scope.
	Household func(context.Context, string) ([]core.User, error)
	State     WatchReader
	Now       func() time.Time
	Catalog   Catalog
	Resolver  core.Resolver
	Engine    Engine
	Cache     Cache
	Owner     func(context.Context) (*core.User, error)
	Config    func() config.Cache
	Active    func() bool
	FreeBytes func() (int64, error)
	Remember  func(context.Context, *core.User, core.RatingKey, core.ClientCaps, *core.Resolution) error
	Logger    *slog.Logger
}

type Engine interface {
	core.Engine
	DurablePrefetch(context.Context, string, []byte, int64, int64) error
}

type Item struct {
	Key         core.RatingKey `json:"key"`
	Title       string         `json:"title"`
	ReleaseID   string         `json:"releaseId"`
	Size        int64          `json:"size"`
	Complete    bool           `json:"complete"`
	Reason      string         `json:"reason,omitempty"`
	Score       float64        `json:"score,omitempty"`
	StoredBytes int64          `json:"storedBytes"`
	Updated     time.Time      `json:"updated"`
}

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

type Selection struct {
	Key       core.RatingKey `json:"key"`
	Title     string         `json:"title"`
	Type      core.MediaType `json:"type"`
	Score     float64        `json:"score"`
	Catalogue float64        `json:"catalogue"`
	Household float64        `json:"household"`
	Reason    string         `json:"reason"`
}

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

type Status struct {
	State     string      `json:"state"`
	Message   string      `json:"message"`
	Title     string      `json:"title"`
	Fetched   int64       `json:"fetched"`
	Size      int64       `json:"size"`
	Allocated int64       `json:"allocated"`
	Ready     int         `json:"ready"`
	Failed    int         `json:"failed"`
	Paused    bool        `json:"paused"`
	Selection []Selection `json:"selection"`
	Viewers   int         `json:"viewers"`
	Items     []Item      `json:"items"`
}

type WatchReader interface {
	History(context.Context, int64, time.Time, int) ([]core.HistoryEntry, error)
	InProgress(context.Context, int64, int) ([]core.WatchStatus, error)
}