PaginationWalkStrategy::initialize() - Code Metrics - Inspection of "Psalm" - b2pweb/bdf-prime - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#29)

by Vincent

created 2021-03-25 08:31 UTC

PaginationWalkStrategy::initialize() A

↳ Parent: PaginationWalkStrategy

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	2.0078

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	7
dl	0
loc	13
ccs	7
cts	8
cp	0.875
rs	10
c	1
b	0
f	0
cc	2
nc	2
nop	3
crap	2.0078

<?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
{
    /**

     * {@inheritdoc}
     */

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

    {
        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;

        $query->limit($chunkSize);

        return $cursor;
    }

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

        $query = $cursor->query;

        $query->offset($cursor->cursor);
                offset($cursor->cursor);
        $cursor->cursor += $query->getLimit();
        $cursor->cursor += $query->/** @scrutinizer ignore-call */ getLimit();
        $cursor->entities = $query->all();


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

        return $cursor;
    }
}


b2pweb / bdf-prime

Pull Request — master (#29)

PaginationWalkStrategy::initialize() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like