Skobkin\Bundle\PointToolsBundle\Service\AbstractApi

Complexity

Total Complexity

8

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

20%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	sendGetRequest()	0	6	1
A	sendPostRequest()	0	6	1
A	getGetRequestData()	0	6	1
A	getPostRequestData()	0	6	1
A	processResponse()	0	12	3

<?php

namespace Skobkin\Bundle\PointToolsBundle\Service;

use GuzzleHttp\ClientInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Log\LoggerInterface;

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

    /**
     * @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, LoggerInterface $logger)
    {
        $this->client = $httpClient;
        $this->logger = $logger;
    }

    /**
     * @param string $path Request path
     * @param array $parameters Key => Value array of query parameters
     *
     * @return ResponseInterface
     */
    public function sendGetRequest(string $path, array $parameters = []): ResponseInterface
    {
        $this->logger->debug('Sending GET request', ['path' => $path, 'parameters' => $parameters]);

        return $this->client->request('GET', $path, ['query' => $parameters]);
    }

    /**
     * @param string $path Request path
     * @param array $parameters Key => Value array of request data
     *
     * @return ResponseInterface
     */
    public function sendPostRequest(string $path, array $parameters = []): ResponseInterface
    {
        $this->logger->debug('Sending POST request', ['path' => $path, 'parameters' => $parameters]);

        return $this->client->request('POST', $path, ['form_params' => $parameters]);
    }

    /**
     * Make GET request and return data from response
     *
     * @param string $path Path template
     * @param array $parameters Parameters array used to fill path template
     * @param bool $decodeJsonResponse Decode JSON or return plaintext
     * @param bool $decodeJsonToObjects Decode JSON objects to PHP objects instead of arrays
     *
     * @return mixed
     */
    public function getGetRequestData($path, array $parameters = [], bool $decodeJsonResponse = false, bool $decodeJsonToObjects = false)
    {
        $response = $this->sendGetRequest($path, $parameters);

        return $this->processResponse($response, $decodeJsonResponse, $decodeJsonToObjects);
    }

    /**
     * Make POST request and return data from response
     *
     * @param string $path Path template
     * @param array $parameters Parameters array used to fill path template
     * @param bool $decodeJson Decode JSON or return plaintext
     * @param bool $decodeToObjects Decode JSON objects to PHP objects instead of arrays
     *
     * @return mixed
     */
    public function getPostRequestData($path, array $parameters = [], bool $decodeJson = false, bool $decodeToObjects = false)
    {
        $response = $this->sendPostRequest($path, $parameters);

        return $this->processResponse($response, $decodeJson, $decodeToObjects);
    }

    /**
     * @param ResponseInterface $response
     * @param bool $decodeJson
     * @param bool $decodeToObjects
     *
     * @return string|array|object
     */
    private function processResponse(ResponseInterface $response, bool $decodeJson = false, bool $decodeToObjects = false)
    {
        if ($decodeJson) {
            if ($decodeToObjects) {
                return json_decode($response->getBody());
            } else {
                return json_decode($response->getBody(), true);
            }
        } else {
            return $response->getBody();
        }
    }
}