Function worker

cmd/batch.go:254–277

(ctx context.Context, jobs <-chan FileJob, results chan<- FileResult, wg *sync.WaitGroup, cfg *config.Config)

}

func worker(ctx context.Context, jobs <-chan FileJob, results chan<- FileResult, wg *sync.WaitGroup, cfg *config.Config) {
	defer wg.Done()

	editor := mp3.NewTagEditor()

	var lyricsFetcher fetcher.LyricsFetcher
	if cfg.GeniusAPIKey != "" {
		lyricsFetcher = fetcher.NewLyricsFetcherWithConfig(cfg.GeniusAPIKey)
	} else {
		lyricsFetcher = fetcher.NewLyricsFetcher()
	}

	artworkFetcher := fetcher.NewArtworkFetcher()

	for job := range jobs {
		select {
		case <-ctx.Done():
			return
		default:
			result := processFile(job.filepath, editor, lyricsFetcher, artworkFetcher)
			results <- result
		}
	}
}

func processFile(filePath string, editor mp3.TagEditor, lyricsFetcher fetcher.LyricsFetcher, artworkFetcher fetcher.ArtworkFetcher) FileResult {
	result := FileResult{filepath: filePath}