Skobkin\Bundle\PointToolsBundle\Service\Api\AbstractApi

Complexity

Total Complexity

18

Size/Duplication

Total Lines	158
Duplicated Lines	12.66 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	sendGetRequest()	10	10	2
A	sendPostRequest()	10	10	2
A	getGetResponseBody()	0	8	1
A	getPostResponseBody()	0	8	1
A	getGetJsonData()	0	9	1
A	getPostJsonData()	0	9	1
C	checkResponse()	0	24	9

<?php

namespace Skobkin\Bundle\PointToolsBundle\Service\Api;

use GuzzleHttp\ClientInterface;
use GuzzleHttp\Exception\TransferException;
use JMS\Serializer\DeserializationContext;
use JMS\Serializer\Serializer;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;
use Psr\Log\LoggerInterface;
use Skobkin\Bundle\PointToolsBundle\Exception\Api\ForbiddenException;
use Skobkin\Bundle\PointToolsBundle\Exception\Api\NetworkException;
use Skobkin\Bundle\PointToolsBundle\Exception\Api\NotFoundException;
use Skobkin\Bundle\PointToolsBundle\Exception\Api\ServerProblemException;
use Skobkin\Bundle\PointToolsBundle\Exception\Api\UnauthorizedException;
use Symfony\Component\HttpFoundation\Response as SymfonyResponse;

class AbstractApi
{
    /**
     * @var ClientInterface HTTP-client from Guzzle
     */
    protected $client;

    /**
     * @var Serializer
     */
    protected $serializer;

    /**
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * @var string Authentication token for API
     */
    protected $authToken;

    /**
     * @var string CSRF-token for API
     */
    protected $csRfToken;


    public function __construct(ClientInterface $httpClient, Serializer $serializer, LoggerInterface $logger)
    {
        $this->client = $httpClient;
        $this->serializer = $serializer;
        $this->logger = $logger;
    }

    /**
     * @param string $path Request path
     * @param array $parameters Key => Value array of query parameters
     *
     * @return ResponseInterface
     *
     * @throws NetworkException
     */
    public function sendGetRequest(string $path, array $parameters = []): ResponseInterface

This method seems to be duplicated in your project.

    {
        $this->logger->debug('Sending GET request', ['path' => $path, 'parameters' => $parameters]);

        try {
            return $this->client->request('GET', $path, ['query' => $parameters]);
        } catch (TransferException $e) {
            throw new NetworkException('Request error', $e->getCode(), $e);
        }
    }

    /**
     * @param string $path Request path
     * @param array $parameters Key => Value array of request data
     *
     * @return ResponseInterface
     *
     * @throws NetworkException
     */
    public function sendPostRequest(string $path, array $parameters = []): ResponseInterface

This method seems to be duplicated in your project.

    {
        $this->logger->debug('Sending POST request', ['path' => $path, 'parameters' => $parameters]);

        try {
            return $this->client->request('POST', $path, ['form_params' => $parameters]);
        } catch (TransferException $e) {
            throw new NetworkException('Request error', $e->getCode(), $e);
        }
    }

    /**
     * Make GET request and return response body
     */
    public function getGetResponseBody($path, array $parameters = []): StreamInterface
    {
        $response = $this->sendGetRequest($path, $parameters);

        $this->checkResponse($response);

        return $response->getBody();
    }

    /**
     * Make POST request and return response body
     */
    public function getPostResponseBody(string $path, array $parameters = []): StreamInterface
    {
        $response = $this->sendPostRequest($path, $parameters);

        $this->checkResponse($response);

        return $response->getBody();
    }

    /**
     * Make GET request and return DTO objects
     *
     * @return array|object
     */
    public function getGetJsonData(string $path, array $parameters = [], string $type, DeserializationContext $context = null)
    {
        return $this->serializer->deserialize(
            $this->getGetResponseBody($path, $parameters),
            $type,
            'json',
            $context
        );
    }

    /**
     * Make POST request and return DTO objects
     *
     * @return array|object
     */
    public function getPostJsonData(string $path, array $parameters = [], string $type, DeserializationContext $context = null)
    {
        return $this->serializer->deserialize(
            $this->getPostResponseBody($path, $parameters),
            $type,
            'json',
            $context
        );
    }

    /**
     * @throws ForbiddenException
     * @throws NotFoundException
     * @throws ServerProblemException
     * @throws UnauthorizedException
     */
    private function checkResponse(ResponseInterface $response): void
    {
        $code = $response->getStatusCode();
        $reason = $response->getReasonPhrase();

        switch ($code) {
            case SymfonyResponse::HTTP_UNAUTHORIZED:
                throw new UnauthorizedException($reason, $code);
                break;

break; does not seem to be reachable.

            case SymfonyResponse::HTTP_FORBIDDEN:
                throw new ForbiddenException($reason, $code);
                break;

break; does not seem to be reachable.

            case SymfonyResponse::HTTP_NOT_FOUND:
                throw new NotFoundException($reason, $code);
                break;

break; does not seem to be reachable.

            case SymfonyResponse::HTTP_INTERNAL_SERVER_ERROR:
            case SymfonyResponse::HTTP_NOT_IMPLEMENTED:
            case SymfonyResponse::HTTP_BAD_GATEWAY:
            case SymfonyResponse::HTTP_SERVICE_UNAVAILABLE:
            case SymfonyResponse::HTTP_GATEWAY_TIMEOUT:
                throw new ServerProblemException($reason, $code);
                break;

break; does not seem to be reachable.

        }
    }
}