playlist

type CatalogStore interface {
	UpsertPlaylistItems(ctx context.Context, items []Item) error
}

type Fetcher interface {
	FetchAndParse(ctx context.Context, playlistURL string) ([]Item, error)
}

type Group struct {
	Name  string `json:"name"`
	Count int    `json:"count"`
}

type Item struct {
	ItemKey            string
	ChannelKey         string
	Name               string
	Group              string
	StreamURL          string
	TVGID              string
	TVGLogo            string
	PlaylistSourceID   int64
	PlaylistSourceName string
	Attrs              map[string]string
	FirstSeenAt        int64
	LastSeenAt         int64
	Active             bool
}

type ItemStream func(yield func(Item) error) error

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

type PlaylistSource struct {
	SourceID    int64  `json:"source_id"`
	SourceKey   string `json:"source_key"`
	Name        string `json:"name"`
	PlaylistURL string `json:"playlist_url"`
	TunerCount  int    `json:"tuner_count"`
	Enabled     bool   `json:"enabled"`
	OrderIndex  int    `json:"order_index"`
	CreatedAt   int64  `json:"created_at"`
	UpdatedAt   int64  `json:"updated_at"`
}

type PlaylistSourceBulkUpdate struct {
	SourceID    int64
	Name        string
	PlaylistURL string
	TunerCount  int
	Enabled     bool
}

type PlaylistSourceCreate struct {
	Name        string `json:"name"`
	PlaylistURL string `json:"playlist_url"`
	TunerCount  int    `json:"tuner_count"`
	Enabled     *bool  `json:"enabled,omitempty"`
}

type PlaylistSourceUpdate struct {
	Name        *string `json:"name,omitempty"`
	PlaylistURL *string `json:"playlist_url,omitempty"`
	TunerCount  *int    `json:"tuner_count,omitempty"`
	Enabled     *bool   `json:"enabled,omitempty"`
}

type Query struct {
	SourceIDs   []int64
	Group       string
	GroupNames  []string
	Search      string
	SearchRegex bool
	Limit       int
	Offset      int
}

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

type SourceCatalogStore interface {
	UpsertPlaylistItemsForSource(ctx context.Context, sourceID int64, items []Item) error
}

type StreamingCatalogStore interface {
	UpsertPlaylistItemsStream(ctx context.Context, stream ItemStream) (int, error)
}

type StreamingFetcher interface {
	FetchAndParseEach(ctx context.Context, playlistURL string, onItem func(Item) error) (int, error)
}

type StreamingSourceCatalogStore interface {
	UpsertPlaylistItemsStreamForSource(ctx context.Context, sourceID int64, stream ItemStream) (int, error)
}