watchlist

type Item struct {
	Title       core.Title `json:"title"`
	Sources     []string   `json:"sources"`
	AddedAt     time.Time  `json:"addedAt"`
	CheckedAt   time.Time  `json:"checkedAt,omitempty"`
	AvailableAt time.Time  `json:"availableAt,omitempty"`
}

type Notifier interface {
	TitleAvailable(context.Context, string) error
}

type OnceNotifier interface {
	TitleAvailableOnce(ctx context.Context, key, title string) error
}

type Options struct {
	Logger       *slog.Logger
	Catalog      core.Catalog
	Resolver     core.Resolver
	Engine       core.Engine
	Trakt        Source
	Tokens       func(context.Context, int64) (string, error)
	Users        func(context.Context) ([]core.User, error)
	Allowed      func(*core.User, *core.Title) bool
	Notifier     Notifier
	Client       *http.Client
	PlexBaseURL  string
	Now          func() time.Time
	PrewarmBytes int64
	// SyncInterval is how often Run passes over every viewer (30m).
	SyncInterval time.Duration
	// ResumeSchedule makes Run wait until SyncInterval has passed since the
	// last pass recorded in the database (by any node) before its first
	// pass, instead of passing at once. A cluster sets it because Run
	// restarts on every leader handoff.
	ResumeSchedule bool
}

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

type Settings struct {
	Enabled       bool `json:"enabled"`
	Plex          bool `json:"plex"`
	Trakt         bool `json:"trakt"`
	Notify        bool `json:"notify"`
	Prewarm       bool `json:"prewarm"`
	CheckHours    int  `json:"checkHours"`
	NaturalSearch bool `json:"naturalSearch"`
	Recaps        bool `json:"recaps"`
}

type Source interface {
	Watchlist(context.Context, int64, int) ([]core.Title, error)
}