api

type AniSource interface {
	Parse(opt *models.AnimeParseOptions) *models.AnimeEntity
}

type CacheGetter interface {
	Get(bucket string, key, val interface{}) error
	GetValue(bucket string, key interface{}) (int64, string, error)
	GetAll(bucket string, tk, tv interface{}, fn func(k, v interface{}))
	ListBucket() []string
	ListKey(bucket string) []string
}

type CacheOpener interface {
	Open(file string)
	Close()
}

type CacheSetter interface {
	Add(bucket string)
	Put(bucket string, key, val interface{}, ttl int64)
	BatchPut(bucket string, key, val []interface{}, ttl int64)
	Delete(bucket string, key interface{}) error
}

type Cacher interface {
	CacheOpener
	CacheSetter
	CacheGetter
}

type Downloader interface {
	Connected() bool
	Start(ctx context.Context)
	List(opt *models.ClientListOptions) []*models.TorrentItem
	Add(opt *models.ClientAddOptions)
	Delete(opt *models.ClientDeleteOptions)
	GetContent(opt *models.ClientGetOptions) []*models.TorrentContentItem
}

type DownloaderManagerCacheDeleter interface {
	DeleteCache(fullname string)
}

type Feed interface {
	Parse(opts ...any) []*models.FeedItem
}

type Filter interface {
	Filter([]*models.FeedItem) []*models.FeedItem
}

type FilterManager interface {
	Update(ctx context.Context, items []*models.FeedItem)
}

type Plugin interface {
	Type() string
	PluginLoader
	PluginRunner
	PluginVariable
}

type PluginLoader interface {
	Load(opts *models.PluginLoadOptions)
}

type PluginRunner interface {
	Run(function string, params models.Object) models.Object
}

type PluginVariable interface {
	Get(varName string) interface{}
	Set(varName string, val interface{})
}

type Task interface {
	Cron() string
	NextTime() time.Time
	Name() string
	Run(params ...interface{})
}