feedsmanager

Documentation

Index

• type FeedFetcher
• type FeedItemStore
• type FeedStore
• type FeedsManager
  • func New(store FeedStore, feedProvider FeedItemStore, feedFetcher FeedFetcher, ...) *FeedsManager
  • func (fm *FeedsManager) Delete(ctx context.Context, id uuid.UUID) error
  • func (fm *FeedsManager) FeedExternalURL(f models.Feed) (string, error)
  • func (fm *FeedsManager) Get(ctx context.Context, id uuid.UUID) (models.Feed, error)
  • func (fm *FeedsManager) GetFeedItem(ctx context.Context, feedItemID uuid.UUID) (*models.FeedItem, error)
  • func (fm *FeedsManager) List(ctx context.Context) ([]models.Feed, error)
  • func (fm *FeedsManager) RecentFeedItems(ctx context.Context, feed *models.Feed, filterExpression models.FeedItemFilter, ...) ([]models.RecentFeedItem, error)
  • func (fm *FeedsManager) RecentFeedItemsFromAllFeeds(ctx context.Context, filterExpression models.FeedItemFilter, page, count int) ([]models.RecentFeedItem, error)
  • func (fm *FeedsManager) Save(ctx context.Context, feed *models.Feed) error
  • func (fm *FeedsManager) SaveFeedItem(ctx context.Context, feedItem *models.FeedItem) error
  • func (fm *FeedsManager) UpdateAllFeeds(ctx context.Context) error
  • func (fm *FeedsManager) UpdateFeed(ctx context.Context, id uuid.UUID) error
• type RulesStore
• type VideoDownloader
• type VideoStore

Types

type FeedFetcher

type FeedFetcher interface {
	GetForFeed(ctx context.Context, feed models.Feed) ([]models.FetchedFeedItem, error)
	FeedExternalURL(feed models.Feed) (string, error)
	FeedHints(feed models.Feed) models.FeedHints
}

type FeedItemStore

type FeedItemStore interface {
	Save(ctx context.Context, feedItem *models.FeedItem) error
	Get(ctx context.Context, id uuid.UUID) (*models.FeedItem, error)
	ListRecentsFromAllFeeds(ctx context.Context, filterExpression models.FeedItemFilter, page, count int) ([]models.FeedItem, error)
	ListRecent(ctx context.Context, feedID uuid.UUID, filterExpression models.FeedItemFilter, page int) ([]models.FeedItem, error)
	PutIfAbsent(ctx context.Context, item *models.FeedItem) (wasInserted bool, err error)
}

type FeedStore

type FeedStore interface {
	List(ctx context.Context) ([]models.Feed, error)
	Save(ctx context.Context, feed *models.Feed) error
	Get(ctx context.Context, id uuid.UUID) (models.Feed, error)
	Delete(ctx context.Context, id uuid.UUID) error
}

type FeedsManager

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

func New

func New(
	store FeedStore,
	feedProvider FeedItemStore,
	feedFetcher FeedFetcher,
	favouriteService *favourites.Service,
	rulesStore RulesStore,
	videoStore VideoStore,
	videoDownloader VideoDownloader,
) *FeedsManager

func (*FeedsManager) Delete

func (fm *FeedsManager) Delete(ctx context.Context, id uuid.UUID) error

func (*FeedsManager) FeedExternalURL

func (fm *FeedsManager) FeedExternalURL(f models.Feed) (string, error)

func (*FeedsManager) Get

func (fm *FeedsManager) Get(ctx context.Context, id uuid.UUID) (models.Feed, error)

func (*FeedsManager) GetFeedItem

func (fm *FeedsManager) GetFeedItem(ctx context.Context, feedItemID uuid.UUID) (*models.FeedItem, error)

func (*FeedsManager) List

func (fm *FeedsManager) List(ctx context.Context) ([]models.Feed, error)

func (*FeedsManager) RecentFeedItems

func (fm *FeedsManager) RecentFeedItems(ctx context.Context, feed *models.Feed, filterExpression models.FeedItemFilter, page int) ([]models.RecentFeedItem, error)

func (*FeedsManager) RecentFeedItemsFromAllFeeds

func (fm *FeedsManager) RecentFeedItemsFromAllFeeds(ctx context.Context, filterExpression models.FeedItemFilter, page, count int) ([]models.RecentFeedItem, error)

func (*FeedsManager) Save

func (fm *FeedsManager) Save(ctx context.Context, feed *models.Feed) error

func (*FeedsManager) SaveFeedItem

func (fm *FeedsManager) SaveFeedItem(ctx context.Context, feedItem *models.FeedItem) error

func (*FeedsManager) UpdateAllFeeds

func (fm *FeedsManager) UpdateAllFeeds(ctx context.Context) error

func (*FeedsManager) UpdateFeed

func (fm *FeedsManager) UpdateFeed(ctx context.Context, id uuid.UUID) error

type RulesStore

type RulesStore interface {
	List(ctx context.Context) ([]*models.Rule, error)
}

type VideoDownloader

type VideoDownloader interface {
	QueueForDownload(ctx context.Context, videoRef models.VideoRef, feed *models.Feed) error
}

type VideoStore

type VideoStore interface {
	FindWithExtID(videoRef models.VideoRef) (*models.SavedVideo, error)
}