Bdf\Prime\Query\Pagination\WalkStrategy\PaginationWalkStrategy

Complexity

Total Complexity

4

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Test Coverage

Coverage

88.24%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	next()	0	16	2
A	initialize()	0	13	2

<?php

namespace Bdf\Prime\Query\Pagination\WalkStrategy;

use Bdf\Prime\Collection\CollectionInterface;
use Bdf\Prime\Connection\ConnectionInterface;
use Bdf\Prime\Query\Contract\Limitable;
use Bdf\Prime\Query\Contract\ReadOperation;
use Bdf\Prime\Query\ReadCommandInterface;
use InvalidArgumentException;

/**
 * Simple walk strategy using pagination
 * This strategy do not handle write on entities during the walk (like delete entities)
 *
 * @template R as array|object
 * @implements WalkStrategyInterface<R>
 */
final class PaginationWalkStrategy implements WalkStrategyInterface
{
    /**

Parameter $startPage should have a doc-comment as per coding-style.

Parameter $query should have a doc-comment as per coding-style.

Parameter $chunkSize should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */

Missing @throws tag in function comment

    public function initialize(ReadCommandInterface $query, int $chunkSize, int $startPage): WalkCursor

Expected 1 blank line before function; 0 found

    {
        if (!$query instanceof Limitable) {
            throw new InvalidArgumentException('The query must be an instance of '.Limitable::class);
        }

        $query = clone $query;
        $cursor = new WalkCursor($query);

        $cursor->cursor = ($startPage - 1) * $chunkSize;

Operation must be bracketed

        $query->limit($chunkSize);

        return $cursor;
    }

    /**
     * {@inheritdoc}
     */
    #[ReadOperation]
    public function next(WalkCursor $cursor): WalkCursor
    {
        $cursor = clone $cursor;
        /** @var Limitable&ReadCommandInterface<ConnectionInterface, R> $query */

Inline doc block comments are not allowed; use "/* Comment */" or "// Comment" instead

Block comments must be started with /*

The close comment tag must be the only content on the line

The open comment tag must be the only content on the line

        $query = $cursor->query;

        $query->offset($cursor->cursor);

The method offset() does not exist on Bdf\Prime\Query\ReadCommandInterface. It seems like you code against a sub-type of said class. However, the method does not exist in Bdf\Prime\Query\Contract\Query\KeyValueQueryInterface or Bdf\Prime\Query\QueryInterface. Are you sure you never get one of those?

        $cursor->cursor += $query->getLimit();

The method getLimit() does not exist on Bdf\Prime\Query\ReadCommandInterface. It seems like you code against a sub-type of said class. However, the method does not exist in Bdf\Prime\Query\Contract\Query\KeyValueQueryInterface or Bdf\Prime\Query\QueryInterface. Are you sure you never get one of those?

        $cursor->entities = $query->all();

It seems like $query->all() of type Bdf\Prime\Query\R[]&Bdf\Prime\Collection\CollectionInterface is incompatible with the declared type Bdf\Prime\Query\Pagination\WalkStrategy\R[]|null of property $entities.

        if ($cursor->entities instanceof CollectionInterface) {
            $cursor->entities = $cursor->entities->all();
        }

        return $cursor;
    }
}