Uxmp\Core\Component\Catalog\Scanner\AlbumCache

Complexity

Total Complexity

4

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	retrieve()	0	41	3

<?php

declare(strict_types=1);

namespace Uxmp\Core\Component\Catalog\Scanner;

use DateTime;
use Psr\Container\ContainerInterface;
use Uxmp\Core\Component\Album\AlbumCoverUpdaterInterface;
use Uxmp\Core\Component\Event\EventHandlerInterface;
use Uxmp\Core\Component\Tag\Container\AudioFileInterface;
use Uxmp\Core\Orm\Model\AlbumInterface;
use Uxmp\Core\Orm\Model\CatalogInterface;
use Uxmp\Core\Orm\Repository\AlbumRepositoryInterface;

final class AlbumCache implements AlbumCacheInterface
{
    /** @var array<string, AlbumInterface> */
    private array $cache = [];

    public function __construct(
        private readonly AlbumRepositoryInterface $albumRepository,
        private readonly ArtistCacheInterface $artistCache,
        private readonly EventHandlerInterface $eventHandler,
        private readonly GenreCacheInterface $genreCache,
    ) {
    }

    public function retrieve(
        CatalogInterface $catalog,
        AudioFileInterface $audioFile,
    ): AlbumInterface {
        $albumMbid = $audioFile->getAlbumMbid();

        $album = $this->cache[$albumMbid] ?? null;
        if ($album === null) {
            $album = $this->albumRepository->findByMbId($albumMbid);

            $artist = $this->artistCache->retrieve($audioFile);

            if ($album === null) {
                $album = $this->albumRepository->prototype()
                    ->setMbid($albumMbid)
                    ->setCatalog($catalog)
                    ->setLastModified(new DateTime())
                    ->setArtist($artist)
                ;
                $artist->addAlbum($album);
            }

            $album
                ->setTitle($audioFile->getAlbumTitle())
                ->setSearchTitle($audioFile->getAlbumTitleClean())
                ->setYear($audioFile->getYear());

            $this->albumRepository->save($album);

            $this->eventHandler->fire(
                static function (ContainerInterface $c) use ($album, $audioFile): void {
                    $c->get(AlbumCoverUpdaterInterface::class)->update($album, $audioFile);
                }
            );

            $this->genreCache->enrich($album, $audioFile);

            $this->cache[$albumMbid] = $album;
        }

        return $album;
    }
}