prerolls

type Activity interface {
	History(ctx context.Context, userID int64, since time.Time, limit int) ([]core.HistoryEntry, error)
	InProgress(ctx context.Context, userID int64, limit int) ([]core.WatchStatus, error)
}

type Audience struct {
	Mode    string  `json:"mode"` // everyone | only | except
	Viewers []int64 `json:"viewers"`
}

type Candidate struct {
	ID      string   `json:"id"`
	Name    string   `json:"name"`
	Plays   bool     `json:"plays"`
	Reasons []Reason `json:"reasons"`
}

type Converter interface {
	// Probe reads the source's streams and duration.
	Probe(ctx context.Context, path string) (*core.MediaInfo, error)
	// Convert writes an H.264 High / AAC stereo MP4 (at most 1080p,
	// faststart) to out.
	Convert(ctx context.Context, in, out string, info *core.MediaInfo) error
	// Thumbnail writes one JPEG frame taken at offset to out.
	Thumbnail(ctx context.Context, in, out string, at time.Duration) error
}

type Decision struct {
	Winner     *Winner     `json:"winner"`
	Candidates []Candidate `json:"candidates"`
	// contains filtered or unexported fields
}

type FFmpeg struct {
	// Path returns the ffmpeg executable; "" means unavailable.
	Path func() string
	// ProbeFunc reads media info (the transcoder's ffprobe).
	ProbeFunc func(ctx context.Context, input string) (*core.MediaInfo, error)
}

type Frequency struct {
	Mode  string `json:"mode"`
	Hours int    `json:"hours"`
}

type Input struct {
	Name      string    `json:"name"`
	Rules     Rules     `json:"rules"`
	Frequency Frequency `json:"frequency"`
	Priority  int       `json:"priority"`
	Order     string    `json:"order"`
	Enabled   *bool     `json:"enabled"`
}

type Options struct {
	DB *sql.DB
	// Dir holds converted clips and thumbnails (<data>/prerolls).
	Dir string
	// MaxFileBytes caps one source file; MaxTotalBytes caps the folder.
	MaxFileBytes, MaxTotalBytes int64
	// Converter probes and converts clips; nil leaves new clips processing
	// until FFmpeg is available.
	Converter Converter
	// Activity feeds the binge rule; nil disables it.
	Activity Activity
	// Title loads one title (an episode's show for its genres, rating and
	// collections; a simulated feature). Nil skips the show lookup.
	Title func(ctx context.Context, key core.RatingKey) (*core.Title, error)
	// InCollection reports whether key is a member of owner collection id.
	// Nil makes collection rules never match.
	InCollection func(ctx context.Context, id string, key core.RatingKey) bool
	// Viewer loads a viewer for the simulator.
	Viewer func(ctx context.Context, id int64) (*core.User, error)
	Logger *slog.Logger
	Now    func() time.Time
	// Rand returns a number in [0,n); nil uses math/rand.
	Rand func(n int) int
}

type PlayRow struct {
	ViewerID   int64     `json:"viewerId"`
	ViewerName string    `json:"viewerName"`
	Title      string    `json:"title"`
	RatingKey  string    `json:"ratingKey"`
	At         time.Time `json:"at"`
	Client     string    `json:"client"`
}

type Preroll struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	Enabled   bool      `json:"enabled"`
	Video     Video     `json:"video"`
	Rules     Rules     `json:"rules"`
	Frequency Frequency `json:"frequency"`
	Priority  int       `json:"priority"`
	Order     string    `json:"order"`
	Plays30d  int       `json:"plays30d"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
	// contains filtered or unexported fields
}

type Reason struct {
	Code string `json:"code"`
	OK   bool   `json:"ok"`
}

type Rules struct {
	Kinds            []string `json:"kinds"`
	FirstEpisodeOnly bool     `json:"firstEpisodeOnly"`
	BingeGapMinutes  int      `json:"bingeGapMinutes"`
	Genres           []string `json:"genres"`
	ExcludeGenres    []string `json:"excludeGenres"`
	Collections      []string `json:"collections"`
	MaxContentRating string   `json:"maxContentRating"`
	DateFrom         string   `json:"dateFrom"` // MM-DD, inclusive
	DateTo           string   `json:"dateTo"`   // MM-DD, inclusive; may wrap the new year
	Audience         Audience `json:"audience"`
	Network          string   `json:"network"`
	Devices          []string `json:"devices"`
}

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

type SimulateInput struct {
	ViewerID  int64  `json:"viewerId"`
	RatingKey string `json:"ratingKey"`
	Device    string `json:"device"`
	Away      bool   `json:"away"`
	Resume    bool   `json:"resume"`
	At        string `json:"at"`
	// Client optionally names the app, to explain unsupported apps.
	Client string `json:"client,omitempty"`
}

type ValidationError struct{ Field, Message string }

type Video struct {
	State      string `json:"state"`
	DurationMs int64  `json:"durationMs"`
	Width      int    `json:"width"`
	Height     int    `json:"height"`
	ThumbURL   string `json:"thumbUrl"`
	PreviewURL string `json:"previewUrl"`
	Problem    string `json:"problem"`
	Source     string `json:"source"`
}

type Winner struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}