Paysera\Pagination\Service\ODM\ResultIterator::iterate()

Complexity

Conditions	6
Paths	20

Size

Total Lines

30

Duplication

Lines	30
Ratio	100 %

Code Coverage

Tests	0
CRAP Score	42

Importance

Changes

0

<?php
    public function iterate(ConfiguredQuery $configuredQuery, Pager $startPager = null): Generator
    {
        $pager = $startPager !== null ? clone $startPager : new Pager();
        if ($pager->getLimit() === null) {
            $pager->setLimit($this->defaultPageSize);
        }

        while (true) {
            $result = $this->resultProvider->getResultForQuery($configuredQuery, $pager);

            foreach ($result->getItems() as $item) {
                yield $item;
            }

            $this->handleCycleEnd();

            if (!$result->hasNext()) {
                $this->logger->info('Finished iterating');
                return;
            }

            $pager = (new Pager())
                ->setOrderingPairs($pager->getOrderingPairs())
                ->setLimit($pager->getLimit())
                ->setAfter($result->getNextCursor())
            ;

            $this->logger->info('Continuing with iteration', ['after' => $result->getNextCursor()]);
        }
    }