manager

type EnqueueReprocessTorrentsBatchRequest struct {
	Purge               bool
	BatchSize           uint
	ChunkSize           uint
	ContentTypes        []model.NullContentType
	Orphans             bool
	ClassifyMode        processor.ClassifyMode
	ClassifierWorkflow  string
	ClassifierFlags     classifier.Flags
	ApisDisabled        bool
	LocalSearchDisabled bool
}

type Manager interface {
	PurgeJobs(context.Context, PurgeJobsRequest) error
	EnqueueReprocessTorrentsBatch(context.Context, EnqueueReprocessTorrentsBatchRequest) error
}

type Params struct {
	fx.In
	Dao lazy.Lazy[*dao.Query]
	DB  lazy.Lazy[*gorm.DB]
}

type PurgeJobsRequest struct {
	Queues   []string
	Statuses []model.QueueJobStatus
}

type Result struct {
	fx.Out
	Manager lazy.Lazy[Manager]
}