Sylius\ShopApiPlugin\ViewRepository\ProductReviewsViewRepository

Complexity

Total Complexity

8

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	12

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	getByProductSlug()	0	12	1
A	getByProductCode()	0	13	1
A	assertLocaleSupport()	0	9	2
A	getChannel()	0	9	1
A	createProductReviewPage()	0	15	2

<?php

declare(strict_types = 1);

namespace Sylius\ShopApiPlugin\ViewRepository;

use Pagerfanta\Adapter\ArrayAdapter;
use Pagerfanta\Pagerfanta;
use Sylius\Component\Channel\Repository\ChannelRepositoryInterface;
use Sylius\Component\Core\Model\ChannelInterface;
use Sylius\Component\Core\Repository\ProductRepositoryInterface;
use Sylius\Component\Core\Repository\ProductReviewRepositoryInterface;
use Sylius\Component\Locale\Model\Locale;
use Sylius\Component\Review\Model\ReviewInterface;
use Sylius\ShopApiPlugin\Factory\PageViewFactoryInterface;
use Sylius\ShopApiPlugin\Factory\ProductReviewViewFactoryInterface;
use Sylius\ShopApiPlugin\Model\PaginatorDetails;
use Sylius\ShopApiPlugin\View\PageView;
use Webmozart\Assert\Assert;

final class ProductReviewsViewRepository implements ProductReviewsViewRepositoryInterface
{
    /** @var ChannelRepositoryInterface */
    private $channelRepository;

    /** @var ProductReviewRepositoryInterface */
    private $productReviewRepository;

    /** @var ProductRepositoryInterface */
    private $productRepository;

    /** @var ProductReviewViewFactoryInterface */
    private $productReviewViewFactory;

    /** @var PageViewFactoryInterface */
    private $pageViewFactory;

    public function __construct(
        ChannelRepositoryInterface $channelRepository,
        ProductReviewRepositoryInterface $productReviewRepository,
        ProductRepositoryInterface $productRepository,
        ProductReviewViewFactoryInterface $productReviewViewFactory,
        PageViewFactoryInterface $pageViewFactory
    ) {
        $this->channelRepository = $channelRepository;
        $this->productReviewRepository = $productReviewRepository;
        $this->productRepository = $productRepository;
        $this->productReviewViewFactory = $productReviewViewFactory;
        $this->pageViewFactory = $pageViewFactory;
    }

    public function getByProductSlug(string $productSlug, ?string $localeCode, string $channelCode, PaginatorDetails $paginatorDetails): PageView
    {
        $channel = $this->getChannel($channelCode);
        $localeCode = $localeCode ?? $channel->getDefaultLocale()->getCode();
        $this->assertLocaleSupport($localeCode, $channel->getLocales());

$channel->getLocales() is of type object<Doctrine\Common\Collections\Collection>|array<integer,object<Sylius\Component\Locale\Model\LocaleInterface>>, but the function expects a object<Sylius\ShopApiPlugin\ViewRepository\iterable>|array<integer,object<Sylius\Component\Locale\Model\Locale>>.

        $reviews = $this->productReviewRepository->findAcceptedByProductSlugAndChannel($productSlug, $localeCode, $channel);

        $paginatorDetails->addToParameters('slug', $productSlug);

        return $this->createProductReviewPage($reviews, $paginatorDetails);
    }

    public function getByProductCode(string $productCode, string $channelCode, PaginatorDetails $paginatorDetails): PageView
    {
        $channel = $this->getChannel($channelCode);

        $product = $this->productRepository->findOneByCode($productCode);
        Assert::true($product->hasChannel($channel));

        $reviews = $this->productReviewRepository->findBy(['reviewSubject' => $product->getId(), 'status' => ReviewInterface::STATUS_ACCEPTED]);

        $paginatorDetails->addToParameters('code', $productCode);

        return $this->createProductReviewPage($reviews, $paginatorDetails);
    }

    /**
     * @param string $localeCode
     * @param iterable|Locale[] $supportedLocales
     */
    private function assertLocaleSupport(string $localeCode, iterable $supportedLocales)
    {
        $supportedLocaleCodes = [];
        foreach ($supportedLocales as $locale) {
            $supportedLocaleCodes[] = $locale->getCode();
        }

        Assert::oneOf($localeCode, $supportedLocaleCodes);
    }

    private function getChannel(string $channelCode): ChannelInterface
    {
        /** @var ChannelInterface $channel */
        $channel = $this->channelRepository->findOneByCode($channelCode);

        Assert::notNull($channel, sprintf('Channel with code %s has not been found.', $channelCode));

        return $channel;
    }

    private function createProductReviewPage(array $reviews, PaginatorDetails $paginatorDetails): PageView
    {
        $pagerfanta = new Pagerfanta(new ArrayAdapter($reviews));

        $pagerfanta->setMaxPerPage($paginatorDetails->limit());
        $pagerfanta->setCurrentPage($paginatorDetails->page());

        $pageView = $this->pageViewFactory->create($pagerfanta, $paginatorDetails->route(), $paginatorDetails->parameters());

        foreach ($pagerfanta->getCurrentPageResults() as $currentPageResult) {
            $pageView->items[] = $this->productReviewViewFactory->create($currentPageResult);
        }

        return $pageView;
    }
}