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
	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 Query struct {
	Group       string
	GroupNames  []string
	Search      string
	SearchRegex bool
	Limit       int
	Offset      int
}

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

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)
}