processor

package

v0.3.0 Latest Latest Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Closeable interface {
	CloseFile(path string, finalSize int64) error
	PreAllocate(path string, size int64) error
}

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

func NewFileProcessor(l *logger.Logger, ex *extraction.Manager, w Closeable, downloadCfg *config.DownloadConfig) *FileProcessor

func (p *FileProcessor) Finalize(ctx context.Context, tasks []*domain.DownloadFile) error

Finalize renames .part to final names

func (p *FileProcessor) PostProcess(ctx context.Context, tasks []*domain.DownloadFile) error

PostProcess handles the modular repair and extraction logic

func (p *FileProcessor) Prepare(nzb *domain.NZB) ([]*domain.DownloadFile, error)

Prepare sanitizes names and creates sparse files. Returns our internal Tasks.