biz

README

Biz

Documentation

Index

• Variables
• type DownloadManager
  • func NewDownloadManager(repo DownloadManagerRepo, logger log.Logger) *DownloadManager
  • func (a *DownloadManager) AddTask(ctx context.Context, taskInfo *dtoDownloadmanager.DownloadTaskInfo) error
  • func (a *DownloadManager) DeleteTask(ctx context.Context, id int32) error
  • func (a *DownloadManager) GetDownloadTaskInfoByAnimeId(ctx context.Context, id string) (*dtoDownloadmanager.DownloadTaskInfo, error)
  • func (a *DownloadManager) GetDownloadTaskInfoById(ctx context.Context, id int32) (*dtoDownloadmanager.DownloadTaskInfo, error)
  • func (a *DownloadManager) ListTask(ctx context.Context) []*dtoDownloadmanager.DownloadTaskInfo
  • func (a *DownloadManager) Scan(ctx context.Context) ([]*DownloadTask, error)
  • func (a *DownloadManager) ScanTaskAndDownload(ctx context.Context) ([]*DownloadTask, error)
  • func (a *DownloadManager) UpdateTaskInfo(ctx context.Context, taskInfo *dtoDownloadmanager.DownloadTaskInfo) error
• type DownloadManagerRepo
• type DownloadTask

Variables

var ProviderSet = wire.NewSet(NewDownloadManager)

ProviderSet is biz providers.

Types

type DownloadManager

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

func NewDownloadManager

func NewDownloadManager(repo DownloadManagerRepo, logger log.Logger) *DownloadManager

func (*DownloadManager) AddTask

func (a *DownloadManager) AddTask(ctx context.Context, taskInfo *dtoDownloadmanager.DownloadTaskInfo) error

func (*DownloadManager) DeleteTask

func (a *DownloadManager) DeleteTask(ctx context.Context, id int32) error

func (*DownloadManager) GetDownloadTaskInfoByAnimeId

func (a *DownloadManager) GetDownloadTaskInfoByAnimeId(ctx context.Context, id string) (*dtoDownloadmanager.DownloadTaskInfo, error)

func (*DownloadManager) GetDownloadTaskInfoById

func (a *DownloadManager) GetDownloadTaskInfoById(ctx context.Context, id int32) (*dtoDownloadmanager.DownloadTaskInfo, error)

func (*DownloadManager) ListTask

func (a *DownloadManager) ListTask(ctx context.Context) []*dtoDownloadmanager.DownloadTaskInfo

func (*DownloadManager) Scan

func (a *DownloadManager) Scan(ctx context.Context) ([]*DownloadTask, error)

func (*DownloadManager) ScanTaskAndDownload

func (a *DownloadManager) ScanTaskAndDownload(ctx context.Context) ([]*DownloadTask, error)

func (*DownloadManager) UpdateTaskInfo

func (a *DownloadManager) UpdateTaskInfo(ctx context.Context, taskInfo *dtoDownloadmanager.DownloadTaskInfo) error

type DownloadManagerRepo

type DownloadManagerRepo interface {
	CreateDownloadTask(ctx context.Context, id int32, latestChapter int32, MagnetLink string) error
	GetAnimeMagnets(ctx context.Context) ([]*dtoSpider.AnimeMagnet, error)
	AddTaskInfo(context.Context, *dtoDownloadmanager.DownloadTaskInfo) error
	DeleteTask(ctx context.Context, id int32) error
	GetDownloadTaskInfos() []*dtoDownloadmanager.DownloadTaskInfo
	UpdateLatestChapter(ctx context.Context, id, latestChapter int32) error
	UpdateTaskInfo(ctx context.Context, taskInfo *dtoDownloadmanager.DownloadTaskInfo) error
	GetDownloadTaskInfoById(id int32) *dtoDownloadmanager.DownloadTaskInfo
	GetDownloadTaskInfoByAnimeId(id string) *dtoDownloadmanager.DownloadTaskInfo
}

type DownloadTask

type DownloadTask struct {
	TaskId       int32
	TaskName     string
	ChapterStart int32 // 存在 一个连接包含多集的情况，使用ChapterStart和ChapterEnd来表达
	ChapterEnd   int32
	MagnetLink   string
	StorePath    string
	AnimeId      string
}