core

Documentation

Index

• Variables
• type Core
  • func NewCore(userStorage storage.User, contentStorage storage.Content, ...) *Core
  • func NewCoreFormConfig() *Core
  • func (c *Core) AddSourceContents(ctx context.Context, source *model.Source, items []*gofeed.Item) ([]*model.Content, error)
  • func (c *Core) AddSubscription(ctx context.Context, userID int64, sourceID uint) error
  • func (c *Core) ClearSourceErrorCount(ctx context.Context, sourceID uint) error
  • func (c *Core) ContentHashIDExist(ctx context.Context, hashID string) (bool, error)
  • func (c *Core) CreateSource(ctx context.Context, sourceURL string) (*model.Source, error)
  • func (c *Core) DisableSourceUpdate(ctx context.Context, sourceID uint) error
  • func (c *Core) EnableSourceUpdate(ctx context.Context, sourceID uint) error
  • func (c *Core) FeedParser() *feed.FeedParser
  • func (c *Core) GetSource(ctx context.Context, id uint) (*model.Source, error)
  • func (c *Core) GetSourceAllSubscriptions(ctx context.Context, sourceID uint) ([]*model.Subscribe, error)
  • func (c *Core) GetSourceByURL(ctx context.Context, sourceURL string) (*model.Source, error)
  • func (c *Core) GetSources(ctx context.Context) ([]*model.Source, error)
  • func (c *Core) GetSubscription(ctx context.Context, userID int64, sourceID uint) (*model.Subscribe, error)
  • func (c *Core) GetUserSubscribedSources(ctx context.Context, userID int64) ([]*model.Source, error)
  • func (c *Core) HttpClient() *client.HttpClient
  • func (c *Core) Init() error
  • func (c *Core) SetSubscriptionInterval(ctx context.Context, userID int64, sourceID uint, interval int) error
  • func (c *Core) SetSubscriptionTag(ctx context.Context, userID int64, sourceID uint, tags []string) error
  • func (c *Core) SourceErrorCountIncr(ctx context.Context, sourceID uint) error
  • func (c *Core) ToggleSourceUpdateStatus(ctx context.Context, sourceID uint) error
  • func (c *Core) ToggleSubscriptionNotice(ctx context.Context, userID int64, sourceID uint) error
  • func (c *Core) ToggleSubscriptionTelegraph(ctx context.Context, userID int64, sourceID uint) error
  • func (c *Core) Unsubscribe(ctx context.Context, userID int64, sourceID uint) error
  • func (c *Core) UnsubscribeAllSource(ctx context.Context, userID int64) error

Variables

var (
	ErrSubscriptionExist    = errors.New("already subscribed")
	ErrSubscriptionNotExist = errors.New("subscription not exist")
	ErrSourceNotExist       = errors.New("source not exist")
	ErrContentNotExist      = errors.New("content not exist")
)

Types

type Core

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

func NewCore

func NewCore(
	userStorage storage.User,
	contentStorage storage.Content,
	sourceStorage storage.Source,
	subscriptionStorage storage.Subscription,
	parser *feed.FeedParser,
	httpClient *client.HttpClient,
) *Core

func NewCoreFormConfig

func NewCoreFormConfig() *Core

func (*Core) AddSourceContents

func (c *Core) AddSourceContents(
	ctx context.Context, source *model.Source, items []*gofeed.Item,
) ([]*model.Content, error)

func (*Core) AddSubscription

func (c *Core) AddSubscription(ctx context.Context, userID int64, sourceID uint) error

AddSubscription 添加订阅

func (*Core) ClearSourceErrorCount

func (c *Core) ClearSourceErrorCount(ctx context.Context, sourceID uint) error

ClearSourceErrorCount 清空订阅源错误计数

func (*Core) ContentHashIDExist

func (c *Core) ContentHashIDExist(
	ctx context.Context, hashID string,
) (bool, error)

func (*Core) CreateSource

func (c *Core) CreateSource(ctx context.Context, sourceURL string) (*model.Source, error)

CreateSource 创建订阅源

func (*Core) DisableSourceUpdate

func (c *Core) DisableSourceUpdate(ctx context.Context, sourceID uint) error

DisableSourceUpdate 关闭订阅源更新

func (*Core) EnableSourceUpdate

func (c *Core) EnableSourceUpdate(ctx context.Context, sourceID uint) error

EnableSourceUpdate 开启订阅源更新

func (*Core) FeedParser

func (c *Core) FeedParser() *feed.FeedParser

func (*Core) GetSource

func (c *Core) GetSource(ctx context.Context, id uint) (*model.Source, error)

GetSource 获取用户订阅的订阅源

func (*Core) GetSourceAllSubscriptions

func (c *Core) GetSourceAllSubscriptions(
	ctx context.Context, sourceID uint,
) ([]*model.Subscribe, error)

func (*Core) GetSourceByURL

func (c *Core) GetSourceByURL(ctx context.Context, sourceURL string) (*model.Source, error)

GetSourceByURL 获取用户订阅的订阅源

func (*Core) GetSources

func (c *Core) GetSources(ctx context.Context) ([]*model.Source, error)

GetSource 获取用户订阅的订阅源

func (*Core) GetSubscription

func (c *Core) GetSubscription(ctx context.Context, userID int64, sourceID uint) (*model.Subscribe, error)

GetSubscription 获取订阅

func (*Core) GetUserSubscribedSources

func (c *Core) GetUserSubscribedSources(ctx context.Context, userID int64) ([]*model.Source, error)

GetUserSubscribedSources 获取用户订阅的订阅源

func (*Core) HttpClient

func (c *Core) HttpClient() *client.HttpClient

func (*Core) Init

func (c *Core) Init() error

func (*Core) SetSubscriptionInterval

func (c *Core) SetSubscriptionInterval(ctx context.Context, userID int64, sourceID uint, interval int) error

SetSubscriptionInterval

func (*Core) SetSubscriptionTag

func (c *Core) SetSubscriptionTag(ctx context.Context, userID int64, sourceID uint, tags []string) error

SetSubscriptionTag 设置订阅标签

func (*Core) SourceErrorCountIncr

func (c *Core) SourceErrorCountIncr(ctx context.Context, sourceID uint) error

SourceErrorCountIncr 增加订阅源错误计数

func (*Core) ToggleSourceUpdateStatus

func (c *Core) ToggleSourceUpdateStatus(ctx context.Context, sourceID uint) error

func (*Core) ToggleSubscriptionNotice

func (c *Core) ToggleSubscriptionNotice(ctx context.Context, userID int64, sourceID uint) error

func (*Core) ToggleSubscriptionTelegraph

func (c *Core) ToggleSubscriptionTelegraph(ctx context.Context, userID int64, sourceID uint) error

func (*Core) Unsubscribe

func (c *Core) Unsubscribe(ctx context.Context, userID int64, sourceID uint) error

Unsubscribe 添加订阅

func (*Core) UnsubscribeAllSource

func (c *Core) UnsubscribeAllSource(ctx context.Context, userID int64) error

UnsubscribeAllSource 添加订阅