Phauthentic\Pagination\Paginator\ElasticaPaginator

Complexity

Total Complexity

8

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Test Coverage

Coverage

69.57%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	paginate()	0	28	4
A	__construct()	0	3	1
A	setOrderMode()	0	9	3

<?php
/**
 * Copyright (c) Phauthentic (https://github.com/Phauthentic)
 *
 * Licensed under The MIT License
 * For full copyright and license information, please see the LICENSE.txt
 * Redistributions of files must retain the above copyright notice.
 *
 * @copyright     Copyright (c) Phauthentic (https://github.com/Phauthentic)
 * @link          https://github.com/Phauthentic
 * @license       https://opensource.org/licenses/mit-license.php MIT License
 */
declare(strict_types = 1);

namespace Phauthentic\Pagination\Paginator;

use Phauthentic\Pagination\PaginationParams;
use Phauthentic\Pagination\PaginationParamsInterface;
use Elastica\Query;
use Elastica\Type;
use InvalidArgumentException;

/**
 * Paginator for the ruflin/elastica library
 */
class ElasticaPaginator implements PaginatorInterface
{
    const ORDER_ADD = 'add';
    const ORDER_REPLACE = 'replace';

    /**
     * Elastica Type
     *
     * @var \Elastica\Type
     */
    protected $type;

    /**
     * Order Mode
     *
     * @var string
     */
    protected $orderMode = self::ORDER_ADD;

    /**
     * Constructor
     *
     * @param \Elastica\Type $type Elastica Type
     */
    public function __construct(Type $type)
    {
        $this->type = $type;
    }

    public function setOrderMode(string $mode): self
    {
        if ($mode !== self::ORDER_ADD || $model !== self::ORDER_REPLACE) {

The variable $model does not exist. Did you maybe mean $mode?

            throw new InvalidArgumentException();
        }

        $this->orderMode = $mode;

        return $this;
    }

    /**
     * Maps the params to the ES query
     *
     * @param \Phauthentic\Pagination\PaginationParamsInterface $paginationParams Pagination params
     * @param array $array
     * @return array
     */
    public function paginate($query, PaginationParamsInterface $paginationParams)
    {
        if (!$query instanceof Query) {
            throw new InvalidArgumentException();
        }

        $query->setSize($paginationParams->getLimit());
        $query->setFrom($paginationParams->getOffset());

        $sortBy = $paginationParams->getSortBy();
        if ($sortBy !== null) {
            $sort = [
                $paginationParams->getSortBy() => [
                    'order' => $paginationParams->getDirection()
                ]
            ];
            if ($this->orderMode === self::ORDER_ADD) {
                $query->addSort($sort);
            } else {
                $query->setSort($sort);
            }
        }

        $result = $this->type->search($query);

        $paginationParams->setCount($result->getTotalHits());

        return $result;

The expression return $result returns the type Elastica\ResultSet which is incompatible with the documented return type array.

    }
}