Gladyshev\Yandex\Direct\AbstractService

Complexity

Total Complexity

14

Size/Duplication

Total Lines	143
Duplicated Lines	0 %

Test Coverage

Coverage

9.09%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	getServiceName()	0	3	1
A	getCredentials()	0	3	1
A	call()	0	12	1
A	getBody()	0	9	2
A	getUri()	0	3	1
A	getHeaders()	0	17	4
A	handleResponse()	0	42	3

<?php

declare(strict_types=1);

namespace Gladyshev\Yandex\Direct;

abstract class AbstractService implements ServiceInterface
{
    /**
     * @var string
     */
    private $serviceName;

    /**
     * @var \Gladyshev\Yandex\Direct\CredentialsInterface
     */
    private $credentials;

    /**
     * @var \Psr\Http\Client\ClientInterface
     */
    private $httpClient;

    public function __construct(
        string $serviceName,
        \Gladyshev\Yandex\Direct\CredentialsInterface $credentials,
        \Psr\Http\Client\ClientInterface $httpClient
    ) {
        $this->serviceName = $serviceName;
        $this->credentials = $credentials;
        $this->httpClient = $httpClient;
    }

    public function call(array $params = []): array
    {
        $request = new \GuzzleHttp\Psr7\Request(
            'POST',
            $this->getUri(),
            $this->getHeaders(),
            $this->getBody($params)
        );

        $response = $this->httpClient->sendRequest($request);

        return $this->handleResponse($request, $response);
    }

    protected function getServiceName(): string
    {
        return $this->serviceName;
    }

    protected function getCredentials(): \Gladyshev\Yandex\Direct\CredentialsInterface
    {
        return $this->credentials;
    }

    /**
     * @return string
     */
    protected function getUri(): string
    {
        return $this->getCredentials()->getBaseUrl() . '/json/v5/' . mb_strtolower($this->getServiceName());
    }

    /**
     * @return array
     */
    protected function getHeaders(): array
    {
        $headers = [
            'Content-Type' => 'application/json; charset=utf-8',
            'Accept' => 'application/json',
            'Authorization' => 'Bearer ' . $this->getCredentials()->getToken(),
            'Accept-Language' => $this->getCredentials()->getLanguage()
        ];

        if ($this->getCredentials()->isAgency()) {
            $headers['Use-Operator-Units'] = $this->getCredentials()->getUseOperatorUnits() ? 'true' : 'false';
            if ($this->getCredentials()->getClientLogin()) {
                $headers['Client-Login'] = $this->getCredentials()->getClientLogin();
            }
        }

        return $headers;
    }

    /**
     * @param array $params
     * @return string
     */
    protected function getBody(array $params): string
    {
        if (empty($params['params'])) {
            $params = new \StdClass();
        } else {
            $params['params'] = array_filter($params['params']);
        }

        return json_encode($params);
    }

    /**
     * @param \Psr\Http\Message\RequestInterface $request
     * @param \Psr\Http\Message\ResponseInterface $response
     * @return array
     */
    protected function handleResponse(
        \Psr\Http\Message\RequestInterface $request,
        \Psr\Http\Message\ResponseInterface $response
    ): array {
        $contents = $response->getBody()->getContents();
        $parsedBody = json_decode($contents, true);

        if (!is_array($parsedBody)) {
            throw new \Gladyshev\Yandex\Direct\Exception\ErrorResponseException(
                'Unexpected API response.',
                $contents,
                0,
                $request,
                $response
            );
        }

        if (!empty($parsedBody['error'])) {
            throw new \Gladyshev\Yandex\Direct\Exception\ErrorResponseException(
                $parsedBody['error']['error_string'],
                $parsedBody['error']['error_detail'],
                (int) $parsedBody['error']['error_code'],
                $request,
                $response
            );
        }

        $unitsUsedLogin = current($response->getHeader('Units-Used-Login'));

        $requestId = current($response->getHeader('RequestId'));

        [$debit, $rest, $limit] = explode('/', current($response->getHeader('Units')));

        return [
            'request_id' => $requestId,
            'units' => [
                'debit' => $debit,
                'rest' => $rest,
                'limit' => $limit
            ],
            'units_used_login' => $unitsUsedLogin,
            'result' => $parsedBody['result'] ?? $parsedBody
        ];
    }
}