Walker::query() - 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

Walker::query() A

↳ Parent: Walker

Complexity

Conditions	2
Paths	2

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	2

Importance

Changes

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

<?php

namespace Bdf\Prime\Query\Pagination;

use BadMethodCallException;
use Bdf\Prime\Connection\ConnectionInterface;
use Bdf\Prime\Exception\PrimeException;
use Bdf\Prime\PrimeSerializable;
use Bdf\Prime\Query\Contract\Limitable;
use Bdf\Prime\Query\Contract\Orderable;
use Bdf\Prime\Query\Contract\Paginable;
use Bdf\Prime\Query\Contract\ReadOperation;
use Bdf\Prime\Query\Pagination\WalkStrategy\PaginationWalkStrategy;
use Bdf\Prime\Query\Pagination\WalkStrategy\WalkCursor;
use Bdf\Prime\Query\Pagination\WalkStrategy\WalkStrategyInterface;
use Bdf\Prime\Query\ReadCommandInterface;
use Iterator;
use LogicException;

/**
 * Query Walker
 * 
 * Permet de parcourir des collections contenant de gros volume d'entités.
 * Le parcourt se fait par paquet d'entités définis par la limit de la query
 * Une fois la limite atteinte, la classe lance la requête suivante

 * 
 * Attention, le walker ne gère pas les objects collection
 *
 * @template R as array|object
 *
 * @implements PaginatorInterface<R>
 * @implements Iterator<array-key, R>
 */
class Walker extends PrimeSerializable implements Iterator, PaginatorInterface
{
    const DEFAULT_PAGE  = 1;
    const DEFAULT_LIMIT = 150;
    
    /**
     * First page
     * 
     * @var int

     */
    protected $startPage;

    /**
     * The current offset
     *
     * @var int|null

     */
    protected $offset;

    /**
     * @var R[]
     */
    private $collection = [];

    /**
     * @var WalkStrategyInterface<R>

     */
    private $strategy;

    /**
     * @var WalkCursor<R>

     */
    private $cursor;

    /**
     * @var ReadCommandInterface<ConnectionInterface, R>

     */
    private $query;

    /**
     * @var int

     */
    private $page;

    /**
     * @var int

     */
    private $maxRows;

    /**
     * Create a query walker
     * 
     * @param ReadCommandInterface<ConnectionInterface, R> $query

     * @param int            $maxRows

     * @param int            $page

     */
    public function __construct(ReadCommandInterface $query, $maxRows = null, $page = null)
    {
        $this->query = $query;
        $this->page = 0;
        $this->maxRows = $maxRows ?: self::DEFAULT_LIMIT;

        $this->startPage = $page ?: self::DEFAULT_PAGE;

    }

    /**
     * Change the walk strategy
     *
     * @param WalkStrategyInterface<R> $strategy

     *
     * @return $this
     */

    public function setStrategy(WalkStrategyInterface $strategy): self
    {
        if ($this->cursor !== null) {
            throw new LogicException('Cannot change walk strategy during walk');
        }

        $this->strategy = $strategy;

        return $this;
    }

    /**
     * Get the current active walk strategy
     *
     * @return WalkStrategyInterface<R>

     */
    public function getStrategy(): WalkStrategyInterface
    {
        if ($this->strategy) {
            return $this->strategy;
        }

        /**

         * @var WalkStrategyInterface<R>
         * @psalm-suppress InvalidPropertyAssignmentValue
         */
        return $this->strategy = new PaginationWalkStrategy();

    }

    /**
     * Load the first page of collection
     *
     * @throws PrimeException
     */
    #[ReadOperation]
    public function load()
    {
        $this->page = $this->startPage;
        $this->cursor = $this->getStrategy()->initialize($this->query, $this->maxRows, $this->page);
        $this->loadCollection();
    }

    /**
     * @return ReadCommandInterface<ConnectionInterface, R>
     */
    public function query(): ReadCommandInterface
    {
        if ($this->cursor) {
            return $this->cursor->query;
        }

        return $this->query;
    }

    /**
     * {@inheritdoc}
     */
    public function collection()
    {
        return $this->collection;
    }

    /**
     * {@inheritdoc}
     */

    public function size()
    {
        if (!$this->query instanceof Paginable) {
            throw new BadMethodCallException(__METHOD__.' should be called with a Paginable query');
        }

        return $this->query->paginationCount();
    }

    /**

     * {@inheritdoc}
     */
    public function order($attribute = null)
    {
        $query = $this->query();

        if (!$query instanceof Orderable) {
            return $attribute ? null : [];

        }

        $orders = $query->getOrders();

        if ($attribute === null) {
            return $orders;
interface HasName {
    /** @return string */
    public function getName();
}

class Name {
    public $name;
}

class User implements HasName {
    /** @return string|Name */
    public function getName() {
        return new Name('foo'); // This is a violation of the ``HasName`` interface
                                // which only allows a string value to be returned.
    }
}
        }

        return $orders[$attribute] ?? null;

    }

    /**
     * {@inheritdoc}
     */
    public function limit(): ?int
    {
        if ($this->cursor->query instanceof Limitable) {
            return $this->cursor->query->getLimit();
        }

        return 0;
    }

    /**
     * {@inheritdoc}
     */
    public function offset(): ?int
    {
        if ($this->cursor->query instanceof Limitable) {
            return $this->cursor->query->getOffset();
        }

        return 0;
    }

    /**
     * {@inheritdoc}
     */
    public function page()
    {
        return $this->page;
    }

    /**
     * {@inheritdoc}
     */
    public function pageMaxRows()
    {
        return $this->maxRows;
    }

    /**
     * {@inheritdoc}
     */
    protected function loadCollection()
    {
        $this->cursor = $this->strategy->next($this->cursor);
        $this->collection = $this->cursor->entities;

        // Test if the collection has numerical keys.
        // We have to add the offset to the numerical key.
        if (isset($this->collection[0])) {
            $this->offset = ($this->page - $this->startPage) * $this->maxRows;

        } else {
            $this->offset = null;
        }
    }

    /**
     * SPL - Iterator
     *
     * {@inheritdoc}
     */
    public function current()
    {
        return current($this->collection);
    }
    
    /**
     * SPL - Iterator
     *
     * {@inheritdoc}
     */
    public function key()
    {
        if ($this->offset !== null) {
            /** @var array<int, mixed> $this->collection */

            return $this->offset + key($this->collection);

        }

        return key($this->collection);
    }
    
    /**
     * SPL - Iterator
     *
     * {@inheritdoc}
     *
     * @throws PrimeException
     */
    #[ReadOperation]
    public function next()
    {
        if (false === next($this->collection)) {
            $this->page++;
            $this->loadCollection();
        }
    }
    
    /**
     * SPL - Iterator
     *
     * {@inheritdoc}
     */
    public function valid()
    {
        return false !== current($this->collection);
    }
    
    /**
     * SPL - Iterator
     *
     * {@inheritdoc}
     *
     * @throws PrimeException
     */
    #[ReadOperation]
    public function rewind()
    {
        if (($this->page == $this->startPage) && count($this->collection)) {
            reset($this->collection);
        } else {
            $this->load();
        }
    }

    /**
     * {@inheritdoc}
     */
    public function count()
    {
        return count($this->collection);
    }

    /**

     * {@inheritdoc}
     */

    public function pushAll(array $items)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function push($item)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function put($key, $item)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**
     * {@inheritdoc}
     */

    public function all()
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function get($key, $default = null)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function has($key)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function remove($key)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**
     * {@inheritdoc}
     */

    public function clear()
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**
     * {@inheritdoc}
     */

    public function keys()
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**
     * {@inheritdoc}
     */

    public function isEmpty()
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function map($callback)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function filter($callback = null)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function groupBy($groupBy, $mode = self::GROUPBY)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function contains($element)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function indexOf($value, $strict = false)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function merge($items)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function sort(callable $callback = null)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function offsetExists($offset)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function offsetGet($offset)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function offsetSet($offset, $value)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }

    /**

     * {@inheritdoc}
     */

    public function offsetUnset($offset)
    {
        throw new BadMethodCallException('Collection methods are not supported by the Walker');
    }
}


1			<?php
2
3			namespace Bdf\Prime\Query\Pagination;
4
5			use BadMethodCallException;
6			use Bdf\Prime\Connection\ConnectionInterface;
7			use Bdf\Prime\Exception\PrimeException;
8			use Bdf\Prime\PrimeSerializable;
9			use Bdf\Prime\Query\Contract\Limitable;
10			use Bdf\Prime\Query\Contract\Orderable;
11			use Bdf\Prime\Query\Contract\Paginable;
12			use Bdf\Prime\Query\Contract\ReadOperation;
13			use Bdf\Prime\Query\Pagination\WalkStrategy\PaginationWalkStrategy;
14			use Bdf\Prime\Query\Pagination\WalkStrategy\WalkCursor;
15			use Bdf\Prime\Query\Pagination\WalkStrategy\WalkStrategyInterface;
16			use Bdf\Prime\Query\ReadCommandInterface;
17			use Iterator;
18			use LogicException;
19
20			/**
21			* Query Walker
22			*
23			* Permet de parcourir des collections contenant de gros volume d'entités.
24			* Le parcourt se fait par paquet d'entités définis par la limit de la query
25			* Une fois la limite atteinte, la classe lance la requête suivante
			0 ignored issues – show introduced 2020-05-22 09:38 UTC by Report Bug Copy Issue Report Doc comment long description must end with a full stop Loading history...
26			*
27			* Attention, le walker ne gère pas les objects collection
28			*
29			* @template R as array\|object
30			*
31			* @implements PaginatorInterface<R>
32			* @implements Iterator<array-key, R>
33			*/
34			class Walker extends PrimeSerializable implements Iterator, PaginatorInterface
35			{
36			const DEFAULT_PAGE = 1;
37			const DEFAULT_LIMIT = 150;
38
39			/**

b2pweb / bdf-prime

Pull Request — master (#29)

Walker::query() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like