task

type BlobCleaner interface {
	EntryExists(ctx context.Context, checksum string) (bool, error)
}

type BlobStoreMigrator interface {
	Count(ctx context.Context) (int, error)
	FindBlobs(ctx context.Context, n uint, lastChecksum string) ([]string, error)
	MigrateBlob(ctx context.Context, checksum string, deleteOld bool) error
}

type CleanGeneratedJob struct {
	Options CleanGeneratedOptions

	Paths                    *paths.Paths
	BlobsStorageType         config.BlobsStorageType
	VideoFileNamingAlgorithm models.HashAlgorithm

	BlobCleaner BlobCleaner
	Repository  models.Repository
	// contains filtered or unexported fields
}

type CleanGeneratedOptions struct {
	BlobFiles bool `json:"blobs"`

	Sprites     bool `json:"sprites"`
	Screenshots bool `json:"screenshots"`
	Transcodes  bool `json:"transcodes"`

	Markers bool `json:"markers"`

	ImageThumbnails bool `json:"imageThumbnails"`

	DryRun bool `json:"dryRun"`
}

type DownloadFFmpegJob struct {
	ConfigDirectory string
	OnComplete      func(ctx context.Context)
	// contains filtered or unexported fields
}

type InstallPackagesJob struct {
	PackagesJob
	Packages []*models.PackageSpecInput
}

type MigrateBlobsJob struct {
	TxnManager txn.Manager
	BlobStore  BlobStoreMigrator
	Vacuumer   Vacuumer
	DeleteOld  bool
}

type MigrateJob struct {
	BackupPath string
	Config     migrateJobConfig
	Database   *sqlite.Database
}

type MigrateSceneScreenshotsJob struct {
	ScreenshotsPath string
	Input           scene.MigrateSceneScreenshotsInput
	SceneRepo       scene.HashFinderCoverUpdater
	TxnManager      txn.Manager
}

type PackagesJob struct {
	PackageManager *pkg.Manager
	OnComplete     func()
}

type UninstallPackagesJob struct {
	PackagesJob
	Packages []*models.PackageSpecInput
}

type UpdatePackagesJob struct {
	PackagesJob
	Packages []*models.PackageSpecInput
}

type Vacuumer interface {
	Vacuum(ctx context.Context) error
}