Overblog\GraphQLBundle\Relay\Connection\Paginator

Complexity

Total Complexity

17

Size/Duplication

Total Lines	151
Duplicated Lines	7.95 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

96.23%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	backward()	6	17	1
B	forward()	6	24	5
A	auto()	0	22	3
A	handleEntities()	0	8	2
A	protectArgs()	0	4	2
A	computeTotalCount()	0	10	3

<?php

namespace Overblog\GraphQLBundle\Relay\Connection;

use Overblog\GraphQLBundle\Definition\Argument;
use Overblog\GraphQLBundle\Relay\Connection\Output\Connection;
use Overblog\GraphQLBundle\Relay\Connection\Output\ConnectionBuilder;

class Paginator
{
    const MODE_REGULAR = false;
    const MODE_PROMISE = true;

    /** @var callable */
    private $fetcher;

    /** @var bool */
    private $promise;

    /** @var int */
    private $totalCount;

    /**
     * @param callable $fetcher
     * @param bool     $promise
     */
    public function __construct(callable $fetcher, $promise = self::MODE_REGULAR)
    {
        $this->fetcher = $fetcher;
        $this->promise = $promise;
    }

    /**
     * @param Argument     $args
     * @param int|callable $total
     * @param array        $callableArgs
     *
     * @return Connection|object A connection or a promise
     */
    public function backward($args, $total, array $callableArgs = [])
    {
        $total = $this->computeTotalCount($total, $callableArgs);

It seems like $total defined by $this->computeTotalCount($total, $callableArgs) on line 42 can also be of type callable; however, Overblog\GraphQLBundle\Relay\Connection\Paginator::computeTotalCount() does only seem to accept integer, maybe add an additional type check?

        $args = $this->protectArgs($args);
        $limit = $args['last'];
        $offset = max(0, ConnectionBuilder::getOffsetWithDefault($args['before'], $total) - $limit);

        $entities = call_user_func($this->fetcher, $offset, $limit);

        return $this->handleEntities($entities, function ($entities) use ($args, $offset, $total) {

This code seems to be duplicated across your project.

            return ConnectionBuilder::connectionFromArraySlice($entities, $args, [
                'sliceStart' => $offset,
                'arrayLength' => $total,
            ]);
        });
    }

    /**
     * @param Argument $args
     *
     * @return Connection|object A connection or a promise
     */
    public function forward($args)
    {
        $args = $this->protectArgs($args);
        $limit = $args['first'];
        $offset = ConnectionBuilder::getOffsetWithDefault($args['after'], 0);

        // If we don't have a cursor or if it's not valid, then we must not use the slice method
        if (!is_numeric(ConnectionBuilder::cursorToOffset($args['after'])) || !$args['after']) {
            $entities = call_user_func($this->fetcher, $offset, $limit ? $limit + 1 : $limit);

            return $this->handleEntities($entities, function ($entities) use ($args) {
                return ConnectionBuilder::connectionFromArray($entities, $args);
            });
        } else {
            $entities = call_user_func($this->fetcher, $offset, $limit ? $limit + 2 : $limit);

            return $this->handleEntities($entities, function ($entities) use ($args, $offset) {

This code seems to be duplicated across your project.

                return ConnectionBuilder::connectionFromArraySlice($entities, $args, [
                    'sliceStart' => $offset,
                    'arrayLength' => $offset + count($entities),
                ]);
            });
        }
    }

    /**
     * @param Argument     $args
     * @param int|callable $total
     * @param array        $callableArgs
     *
     * @return Connection|object A connection or a promise
     */
    public function auto($args, $total, $callableArgs = [])
    {
        $args = $this->protectArgs($args);

        if ($args['last']) {
            $connection = $this->backward($args, $total, $callableArgs);
        } else {
            $connection = $this->forward($args);
        }

        if ($this->promise) {
            return $connection->then(function (Connection $connection) use ($total, $callableArgs) {
                $connection->totalCount = $this->computeTotalCount($total, $callableArgs);

It seems like $total defined by parameter $total on line 95 can also be of type callable; however, Overblog\GraphQLBundle\Relay\Connection\Paginator::computeTotalCount() does only seem to accept integer, maybe add an additional type check?

                return $connection;
            });
        } else {
            $connection->totalCount = $this->computeTotalCount($total, $callableArgs);

It seems like $total defined by parameter $total on line 95 can also be of type callable; however, Overblog\GraphQLBundle\Relay\Connection\Paginator::computeTotalCount() does only seem to accept integer, maybe add an additional type check?

            return $connection;
        }
    }

    /**
     * @param array|object $entities An array of entities to paginate or a promise
     * @param callable     $callback
     *
     * @return Connection|object A connection or a promise
     */
    private function handleEntities($entities, callable $callback)
    {
        if ($this->promise) {
            return $entities->then($callback);
        }

        return call_user_func($callback, $entities);
    }

    /**
     * @param Argument|array $args
     *
     * @return Argument
     */
    private function protectArgs($args)
    {
        return $args instanceof Argument ? $args : new Argument($args);
    }

    /**
     * @param int   $total
     * @param array $callableArgs
     *
     * @return int|mixed
     */
    private function computeTotalCount($total, array $callableArgs = [])
    {
        if (null !== $this->totalCount) {
            return $this->totalCount;
        }

        $this->totalCount = is_callable($total) ? call_user_func_array($total, $callableArgs) : $total;

        return $this->totalCount;
    }
}