PtrTn\Battlerite\ApiClient

Complexity

Total Complexity

14

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	sendRequestToEndPoint()	0	10	2
A	createRequestForEndpoint()	0	16	2
B	sendRequest()	0	18	5
A	getDataFromResponse()	0	15	4

<?php

namespace PtrTn\Battlerite;

use GuzzleHttp\ClientInterface;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Psr7\Request;
use InvalidArgumentException;
use Psr\Http\Message\ResponseInterface;
use PtrTn\Battlerite\Exception\FailedRequestException;
use PtrTn\Battlerite\Exception\InvalidRequestException;
use PtrTn\Battlerite\Exception\InvalidResourceException;
use PtrTn\Battlerite\Query\QueryInterface;

class ApiClient
{
    private const BASE_URL = 'https://api.dc01.gamelockerapp.com';

    /**
     * @var string
     */
    private $apiKey;

    /**
     * @var ClientInterface
     */
    private $httpClient;

    public function __construct(string $apiKey, ClientInterface $httpClient)
    {
        $this->apiKey = $apiKey;
        $this->httpClient = $httpClient;
    }

    public function sendRequestToEndPoint(string $endpoint, ?QueryInterface $query = null)
    {
        $request = $this->createRequestForEndpoint(
            $endpoint,
            $query ? $query->toQueryString() : null
        );
        $response = $this->sendRequest($request);

        return $this->getDataFromResponse($response);
    }

    private function createRequestForEndpoint(string $endpoint, string $query = null): Request
    {
        $uri = self::BASE_URL . $endpoint;
        if (isset($query)) {
            $uri .= '?' . $query;
        }

        return new Request(
            'GET',
            $uri,
            [
                'Accept' => 'application/json',
                'Authorization' => $this->apiKey
            ]
        );
    }

    private function sendRequest($request): ResponseInterface
    {
        try {
            return $this->httpClient->send($request);
        } catch (ClientException $e) {
            if ($e->getResponse()->getStatusCode() === 401) {
                throw InvalidRequestException::invalidApiKey($this->apiKey);
            }
            if ($e->getResponse()->getStatusCode() === 429) {
                throw InvalidRequestException::rateLimitReached();
            }
            if ($e->getResponse()->getStatusCode() === 404) {
                throw InvalidResourceException::resourceNotFound();
            }

            throw FailedRequestException::createForException($e);
        }
    }

    private function getDataFromResponse(ResponseInterface $response): array
    {
        $responseBody = $response->getBody()->getContents();
        if (!isset($responseBody) || $responseBody === '') {
            throw new FailedRequestException('No response');
        }

        try {
            $responseData = \GuzzleHttp\json_decode($responseBody, true, 512, JSON_BIGINT_AS_STRING);
        } catch (InvalidArgumentException $e) {
            throw FailedRequestException::invalidResponseJson($e);
        }

        return $responseData;
    }
}