Uxmp\Core\Component\Catalog\Manage\CatalogUpdater

Complexity

Total Complexity

7

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
B	update()	0	61	6

<?php

declare(strict_types=1);

namespace Uxmp\Core\Component\Catalog\Manage;

use Ahc\Cli\IO\Interactor;
use Uxmp\Core\Component\Catalog\Manage\Update\AudioFileRetrieverInterface;
use Uxmp\Core\Component\Catalog\Manage\Update\RecursiveFileReaderInterface;
use Uxmp\Core\Component\Catalog\Scanner\DiscCacheInterface;
use Uxmp\Core\Component\Tag\Container\AudioFileInterface;
use Uxmp\Core\Orm\Repository\CatalogRepositoryInterface;
use Uxmp\Core\Orm\Repository\SongRepositoryInterface;

/**
 * Updates the media files of a catalog
 */
final class CatalogUpdater implements CatalogUpdaterInterface
{
    public function __construct(
        private readonly CatalogRepositoryInterface $catalogRepository,
        private readonly SongRepositoryInterface $songRepository,
        private readonly DiscCacheInterface $discCache,
        private readonly RecursiveFileReaderInterface $recursiveFileReader,
        private readonly AudioFileRetrieverInterface $audioFileRetriever,
    ) {
    }

    public function update(Interactor $io, int $catalogId): void
    {
        $catalog = $this->catalogRepository->find($catalogId);
        if ($catalog === null) {
            $io->error(
                sprintf('Catalog `%d` not found', $catalogId),
                true
            );
            return;
        }

        $directory = $catalog->getPath();

        if (!is_dir($directory)) {
            $io->error(
                sprintf('The path `%s` is not accessible', $directory),
                true
            );
            return;
        }

        $io->info(
            sprintf('Updating catalog from `%s`', $directory),
            true
        );

        $reader = $this->audioFileRetriever->retrieve(
            $this->recursiveFileReader->read($directory)
        );

        foreach ($reader as $audioFile) {
            /** @var AudioFileInterface|null $audioFile */
            if ($audioFile === null) {
                $io->error('.');
                continue;
            }

            $io->info('.');

            $song = $this->songRepository->findByMbId($audioFile->getMbid());
            if ($song === null) {
                $song = $this->songRepository->prototype();
            }

            $disc = $this->discCache->retrieve($catalog, $audioFile);

            $song
                ->setDisc($disc)
                ->setArtist($disc->getAlbum()->getArtist())
                ->setCatalog($catalog)
            ;

            // apply the audiofile state onto the song
            $audioFile->apply($song);

            $this->songRepository->save($song);

            $disc->addSong($song);
        }

        $io->eol();
    }
}