Core23\SetlistFm\Connection\PsrClientConnection

Complexity

Total Complexity

12

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	call()	0	16	4
A	parseResponse()	0	19	4
A	buildParameter()	0	4	1
A	buildRequest()	0	16	2

<?php

declare(strict_types=1);

/*
 * (c) Christian Gripp <mail@core23.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Core23\SetlistFm\Connection;

use Core23\SetlistFm\Exception\ApiException;
use Core23\SetlistFm\Exception\NotFoundException;
use Exception;
use Psr\Http\Client\ClientExceptionInterface;
use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\RequestFactoryInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

final class PsrClientConnection extends AbstractConnection
{
    /**
     * @var ClientInterface
     */
    private $client;

    /**
     * @var RequestFactoryInterface
     */
    private $requestFactory;

    /**
     * Initialize client.
     *
     * @param string $uri
     */
    public function __construct(ClientInterface $client, RequestFactoryInterface $requestFactory, string $apiKey, string $uri = null)
    {
        parent::__construct($apiKey, $uri);

        $this->client         = $client;
        $this->requestFactory = $requestFactory;
    }

    public function call(string $method, array $params = [], string $requestMethod = 'GET'): array
    {
        $request = $this->buildRequest($method, $params, $requestMethod);

        try {
            $response = $this->client->sendRequest($request);

            return $this->parseResponse($response);
        } catch (ApiException | NotFoundException $e) {
            throw $e;
        } catch (Exception $e) {
            throw new ApiException('Technical error occurred.', 500, $e);
        } catch (ClientExceptionInterface $e) {
            throw new ApiException('Technical error occurred.', 500, $e);
        }
    }

    /**
     * @throws ApiException
     * @throws NotFoundException
     */
    private function parseResponse(ResponseInterface $response): array
    {
        $content = $response->getBody()->getContents();
        $array   = json_decode($content, true);

        if (JSON_ERROR_NONE !== json_last_error()) {
            throw new ApiException('Server did not reply with a valid response.', $response->getStatusCode());
        }

        if (404 === $response->getStatusCode()) {
            throw new NotFoundException('Server did not find any entity for the request.');
        }

        if ($response->getStatusCode() >= 400) {
            throw new ApiException('Technical error occurred.', $response->getStatusCode());
        }

        return $array;
    }

    /**
     * Builds request parameter.
     */
    private static function buildParameter(array $parameter): string
    {
        return http_build_query($parameter);
    }

    private function buildRequest(string $method, array $params, string $requestMethod): RequestInterface
    {
        $data = self::buildParameter($params);

        if ('POST' === $requestMethod) {
            $request =  $this->requestFactory->createRequest($requestMethod, $this->getUri().$method);
            $request->getBody()->write($data);
        } else {
            $this->requestFactory->createRequest($requestMethod, $this->getUri().$method.'?'.$data);
        }

        return $request

The variable $request does not seem to be defined for all execution paths leading up to this point.

            ->withHeader('Accept', 'application/json')
            ->withHeader('x-api-key', $this->getApiKey())
        ;
    }
}