Yiisoft\Yii\Cycle\DataReader\OffsetDataReader

Complexity

Total Complexity

14

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	1	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	withOffset()	0	5	1
A	count()	0	3	1
A	setLimit()	0	5	2
A	setOffset()	0	5	2
A	withLimit()	0	5	1
A	read()	0	14	4
A	__construct()	0	13	3

<?php

namespace Yiisoft\Yii\Cycle\DataReader;

use Countable;
use Cycle\ORM\Select;
use InvalidArgumentException;
use Spiral\Database\Query\QueryInterface;
use Spiral\Pagination\PaginableInterface;
use Yiisoft\Data\Reader\CountableDataInterface;
use Yiisoft\Data\Reader\DataReaderInterface;
use Yiisoft\Data\Reader\OffsetableDataInterface;
use Yiisoft\Yii\Cycle\DataReader\Cache\CachedCount;
use Yiisoft\Yii\Cycle\DataReader\Cache\CachedCollection;

final class OffsetDataReader implements DataReaderInterface, OffsetableDataInterface, CountableDataInterface
{
    /** @var QueryInterface|Select */
    private $query;
    private ?int $limit = null;
    private ?int $offset = null;
    private CachedCount $countCache;
    private CachedCollection $itemsCache;

    /**
     * @param Select|QueryInterface $query
     */
    public function __construct($query)
    {
        if (!$query instanceof Countable) {
            throw new InvalidArgumentException(sprintf('Query should implement %s interface', Countable::class));
        }
        if (!$query instanceof PaginableInterface) {

$query is always a sub-type of Spiral\Pagination\PaginableInterface.

            throw new InvalidArgumentException(
                sprintf('Query should implement %s interface', PaginableInterface::class)
            );
        }
        $this->query = clone $query;
        $this->countCache = new CachedCount($this->query);
        $this->itemsCache = new CachedCollection();
    }
    public function withLimit(int $limit): self
    {
        $clone = clone $this;
        $clone->setLimit($limit);
        return $clone;
    }
    public function withOffset(int $offset): self
    {
        $clone = clone $this;
        $clone->setOffset($offset);
        return $clone;
    }
    public function count(): int
    {
        return $this->countCache->getCount();
    }
    public function read(): iterable
    {
        if ($this->itemsCache->getCollection() !== null) {
            return $this->itemsCache->getCollection();
        }
        $newQuery = clone $this->query;
        if ($this->offset !== null) {
            $newQuery->offset($this->offset);

The method offset() does not exist on Spiral\Database\Query\QueryInterface. It seems like you code against a sub-type of Spiral\Database\Query\QueryInterface such as Spiral\Database\Query\SelectQuery.

        }
        if ($this->limit !== null) {
            $newQuery->limit($this->limit);

The method limit() does not exist on Spiral\Database\Query\QueryInterface. It seems like you code against a sub-type of Spiral\Database\Query\QueryInterface such as Spiral\Database\Query\SelectQuery.

        }
        $this->itemsCache->setCollection($newQuery->fetchAll());

The method fetchAll() does not exist on Spiral\Database\Query\QueryInterface. It seems like you code against a sub-type of Spiral\Database\Query\QueryInterface such as Spiral\Database\Query\SelectQuery.

        return $this->itemsCache->getCollection();

The expression return $this->itemsCache->getCollection() returns the type null which is incompatible with the type-hinted return iterable.

Are you sure the usage of $this->itemsCache->getCollection() targeting Yiisoft\Yii\Cycle\DataReader\Cache\CachedCollection::getCollection() seems to always return null.

    }

    private function setLimit(?int $limit): void
    {
        if ($this->limit !== $limit) {
            $this->limit = $limit;
            $this->itemsCache = new CachedCollection();
        }
    }
    private function setOffset(?int $offset): void
    {
        if ($this->offset !== $offset) {
            $this->offset = $offset;
            $this->itemsCache = new CachedCollection();
        }
    }
}