alekciy\ofd\providers\yandex\Client

Complexity

Total Complexity

4

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	request()	0	16	2
A	sendRequest()	0	16	1
A	__construct()	0	16	1

<?php

namespace alekciy\ofd\providers\yandex;

use alekciy\ofd\Json;
use alekciy\ofd\Request;
use Exception;
use GuzzleHttp\Client as httpClient;
use GuzzleHttp\Exception\GuzzleException;
use Psr\Http\Message\ResponseInterface;

class Client
{
	/** @var httpClient HTTP клиент для низкоуровневой работы с API */
	protected $httpClient = null;

	/** @var Credentials Реквизиты доступа */
	protected $credentials = null;

	/** @var string Версия клиента */
	private $version = '0.1.0';

	/**
	 * @param Credentials $credentials Реквизиты доступа.
	 * @param array $clientConfig      Дополнительную настройки для Guzzle клиента.
	 * @throws Exception
	 */
	public function __construct(Credentials $credentials, array $clientConfig = [])
	{
		$this->credentials = $credentials;

		$httpClientConfig = [
			'base_uri' => 'https://' . $credentials->domain,
			'defaults' => [
				'headers' => [
					'Content-Type' => 'application/json',
					'Accept'       => 'application/json',
					'X-Yandex-Key' => $credentials->authenticationKey,
					'X-OFD-Key'    => $credentials->authorizationKey,
				],
			],
		];
		$this->httpClient = new httpClient(array_merge($clientConfig, $httpClientConfig));
	}

	/**
	 * Отправить запрос.
	 *
	 * @param Request $endpoint
	 * @return ResponseInterface
	 * @throws GuzzleException
	 * @throws Exception
	 */
	protected function sendRequest(Request $endpoint): ResponseInterface
	{
		return $this->httpClient->request(
			$endpoint->method,
			$endpoint->getPath(),
			[
				'debug' => $endpoint->debug,
				'exceptions' => false,
				'headers' => [
					'Accept'       => 'application/json',
					'User-Agent'   => 'PHP-OFD-SDK/' . $this->version,
					'X-Yandex-Key' => $this->credentials->authenticationKey,
					'X-OFD-Key'    => $this->credentials->authorizationKey,
				],
				'query' => $endpoint->getQuery(),
				'json' => $endpoint->getBody(),
			]
		);
	}

	/**
	 * Шлет запрос и обрабатывает результаты.
	 *
	 * @param Request $endpoint
	 * @return array
	 * @throws GuzzleException
	 * @throws Exception
	 * @see https://lk-ofd.taxcom.ru/ApiHelp/index.html?3___.htm Обработка ошибок
	 */
	public function request($endpoint): array
	{
		$response = $this->sendRequest($endpoint);
		$body = Json::decode($response->getBody()->getContents(), true);
		$errorCode = $body['code'] ?? 0;

		if (!empty($errorCode)) {
			$msg = $body['message'] ?? $body['description'];
			throw new Exception(sprintf('При запросе адреса %s возникла ошибка (status=%d): %s',
				$endpoint->getPath(),
				$response->getStatusCode(),
				$msg),
				$errorCode
			);
		}
		return $body;
	}
}