Setono\SyliusStockMovementPlugin\Provider\StockMovementProvider

Complexity

Total Complexity

5

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	addFilter()	0	3	1
A	getStockMovements()	0	19	3

<?php

declare(strict_types=1);

namespace Setono\SyliusStockMovementPlugin\Provider;

use Doctrine\ORM\EntityRepository;
use Generator;
use Pagerfanta\Adapter\DoctrineORMAdapter;
use Pagerfanta\Pagerfanta;
use Setono\SyliusStockMovementPlugin\Filter\FilterInterface;

class StockMovementProvider implements StockMovementProviderInterface
{
    /** @var FilterInterface[] */
    protected $filters = [];

    /** @var EntityRepository */
    private $repository;

    public function __construct(EntityRepository $repository)
    {
        $this->repository = $repository;
    }

    public function addFilter(FilterInterface $filter): void
    {
        $this->filters[] = $filter;
    }

    public function getStockMovements(): Generator
    {
        $qb = $this->repository->createQueryBuilder('o');

        foreach ($this->filters as $filter) {
            $filter->filter($qb);
        }

        // Use output walkers option in DoctrineORMAdapter should be false as it affects performance greatly. (see https://github.com/Sylius/Sylius/issues/3775)
        $paginator = new Pagerfanta(new DoctrineORMAdapter($qb, false, false));
        $paginator->setNormalizeOutOfRangePages(true);

        $paginator->setMaxPerPage(100);
        $pages = $paginator->getNbPages();

        for ($page = 1; $page <= $pages; ++$page) {
            $paginator->setCurrentPage($page);

            yield from $paginator->getCurrentPageResults();
        }
    }
}