AcquiaCloudApi\Connector\Client

Complexity

Total Complexity

18

Size/Duplication

Total Lines	151
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	clearQuery()	0	3	1
A	getQuery()	0	3	1
A	factory()	0	7	1
A	__construct()	0	3	1
A	clearOptions()	0	3	1
A	processResponse()	0	19	6
A	addOption()	0	3	1
A	getOptions()	0	3	1
A	request()	0	19	4
A	addQuery()	0	3	1

<?php

namespace AcquiaCloudApi\Connector;

use Psr\Http\Message\ResponseInterface;
use GuzzleHttp\Exception\BadResponseException;
use AcquiaCloudApi\Exception\ApiErrorException;
use Psr\Http\Message\StreamInterface;

/**
 * Class Client
 *
 * @package AcquiaCloudApi\CloudApi
 */
class Client implements ClientInterface
{
    /**
     * @var ConnectorInterface The API connector.
     */
    protected $connector;

    /**
     * @var array Query strings to be applied to the request.
     */
    protected $query = [];

    /**
     * @var array Guzzle options to be applied to the request.
     */
    protected $options = [];

    /**
     * Client constructor.
     *
     * @param ConnectorInterface $connector
     */
    public function __construct(ConnectorInterface $connector)
    {
        $this->connector = $connector;
    }

    /**
     * Client factory method for instantiating .
     *
     * @param ConnectorInterface $connector
     *
     * @return static
     */
    public static function factory(ConnectorInterface $connector)
    {
        $client = new static(
            $connector
        );

        return $client;
    }

    /**
     * @inheritdoc
     */
    public function request(string $verb, string $path, array $options = [])
    {
        // @TODO follow this up by removing $options from the parameters able
        // to be passed into this function and instead solely relying on the
        // addOption() method as this can then be tested.
        $options = $this->options + $options;
        $options['query'] = $this->query;

        if (!empty($options['query']['filter']) && is_array($options['query']['filter'])) {
            // Default to an AND filter.
            $options['query']['filter'] = implode(',', $options['query']['filter']);
        }
        try {
            $request = $this->connector->createRequest($verb, $path);
            $response = $this->connector->sendRequest($request, $options);
        } catch (BadResponseException $e) {
            $response = $e->getResponse();
        }
        return $this->processResponse($response);

It seems like $response can also be of type null; however, parameter $response of AcquiaCloudApi\Connector\Client::processResponse() does only seem to accept Psr\Http\Message\ResponseInterface, maybe add an additional type check?

    }

    // /**
    //  * @inheritdoc
    //  */
    // public function makeRequest(string $verb, string $path, array $options = [])
    // {
    //     try {
    //         $response = $this->connector->sendRequest($verb, $path, $options);
    //     } catch (BadResponseException $e) {
    //         $response = $e->getResponse();
    //     }

    //     return $response;
    // }

    /**
     * @inheritdoc
     */
    public function processResponse(ResponseInterface $response)
    {

        $body = $response->getBody();

        $object = json_decode($body);
        if (json_last_error() !== JSON_ERROR_NONE) {
            return $body;
        }

        if (property_exists($object, '_embedded') && property_exists($object->_embedded, 'items')) {
            return $object->_embedded->items;
        }

        if (property_exists($object, 'error') && property_exists($object, 'message')) {
            throw new ApiErrorException($object);
        }

        return $object;
    }

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

    /**
     * @inheritdoc
     */
    public function clearQuery()
    {
        $this->query = [];
    }

    /**
     * @inheritdoc
     */
    public function addQuery($name, $value)
    {
        $this->query = array_merge_recursive($this->query, [$name => $value]);
    }

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

    /**
     * @inheritdoc
     */
    public function clearOptions()
    {
        $this->options = [];
    }

    /**
     * @inheritdoc
     */
    public function addOption($name, $value)
    {
        $this->options = array_merge_recursive($this->options, [$name => $value]);
    }
}