Bitbucket\API\Http\Response\Pager

Complexity

Total Complexity

21

Size/Duplication

Total Lines	141
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

97.78%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	3
A	hasNext()	0	4	1
A	hasPrevious()	0	4	1
A	fetchNext()	0	10	2
A	fetchPrevious()	0	10	2
A	fetchAll()	0	32	5
A	getCurrent()	0	4	1
A	getContent()	0	17	6

<?php
/**
 * This file is part of the bitbucket-api package.
 *
 * (c) Alexandru G. <alex@gentle.ro>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace Bitbucket\API\Http\Response;

use Bitbucket\API\Http\HttpPluginClientBuilder;
use Http\Discovery\MessageFactoryDiscovery;
use Http\Message\MessageFactory;
use Psr\Http\Message\ResponseInterface;

/**
 * @author Alexandru Guzinschi <alex@gentle.ro>
 */
class Pager implements PagerInterface
{
    /** @var HttpPluginClientBuilder */
    private $httpPluginClientBuilder;
    /** @var MessageFactory */
    private $messageFactory;
    /** @var ResponseInterface */
    private $response;

    /**
     * @param HttpPluginClientBuilder $httpPluginClientBuilder
     * @param ResponseInterface $response
     * @param MessageFactory $messageFactory
     *
     * @throws \UnexpectedValueException
     */
    public function __construct(
        HttpPluginClientBuilder $httpPluginClientBuilder,
        ResponseInterface $response,
        MessageFactory $messageFactory = null
    ) {
        /** @var ResponseInterface $response */
        if ($response->getStatusCode() >= 400) {
            throw new \UnexpectedValueException("Can't paginate an unsuccessful response.");
        }

        $this->httpPluginClientBuilder = $httpPluginClientBuilder;
        $this->response = $response;
        $this->messageFactory = $messageFactory ? : MessageFactoryDiscovery::find();
    }

    /**
     * {@inheritDoc}
     */
    public function hasNext()
    {
        return array_key_exists('next', $this->getContent());
    }

    /**
     * {@inheritDoc}
     */
    public function hasPrevious()
    {
        return array_key_exists('previous', $this->getContent());
    }

    /**
     * {@inheritDoc}
     */
    public function fetchNext()
    {
        if ($this->hasNext()) {
            $content = $this->getContent();

            return $this->response = $this->httpPluginClientBuilder->getHttpClient()->get($content['next']);
        }

        return null;
    }

    /**
     * {@inheritDoc}
     */
    public function fetchPrevious()
    {
        if ($this->hasPrevious()) {
            $content = $this->getContent();

            return $this->response = $this->httpPluginClientBuilder->getHttpClient()->get($content['previous']);
        }

        return null;
    }

    /**
     * {@inheritDoc}
     */
    public function fetchAll()
    {
        $content = $this->getContent();
        $values = [];

        // merge all `values` and replace it inside the most recent response.
        while (true) {
            if (!array_key_exists('values', $content)) {
                break;
            }

            $values = (0 === count($values)) ? $content['values'] : array_merge($values, $content['values']);

            if (null !== $this->fetchNext()) {
                $content = $this->getContent();
                continue;
            }

            break;
        }

        $content['values'] = $values;
        $this->response = $this->messageFactory->createResponse(
            $this->response->getStatusCode(),
            $this->response->getReasonPhrase(),
            $this->response->getHeaders(),
            json_encode($content),
            $this->response->getProtocolVersion()
        );

        return $this->response;
    }

    /**
     * {@inheritDoc}
     */
    public function getCurrent()
    {
        return $this->response;
    }

    /**
     * @access private
     * @return array
     */
    private function getContent()
    {
        $content = json_decode($this->response->getBody()->getContents(), true);
        $this->response->getBody()->rewind();

        if (is_array($content) && JSON_ERROR_NONE === json_last_error()) {
            // replace reference inserted by `LegacyCollectionListener` with actual data.
            if (array_key_exists('values', $content) &&
                is_string($content['values']) &&
                strpos($content['values'], '.') !== false) {
                $content['values'] = $content[str_replace('.', '', $content['values'])];
            }
            return $content;
        }

        return [];
    }
}