Yandex\Direct\Service

Complexity

Total Complexity

8

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

21.95%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	setName()	0	4	1
A	setTransport()	0	4	1
A	setCredentials()	0	4	1
A	setUseOperatorUnits()	0	4	1
B	request()	0	24	1
A	handleErrorResponse()	0	15	3

<?php
/**
 * @author Dmitry Gladyshev <deel@email.ru>
 * @date 17/08/2016 11:28
 */

namespace Yandex\Direct;

use Yandex\Direct\Exception\ErrorResponseException;
use Yandex\Direct\Transport\TransportInterface;
use Yandex\Direct\Transport\TransportRequest;
use Yandex\Direct\Transport\TransportResponse;


/**
 * Class Service
 * @package Yandex\Direct
 */
abstract class Service implements ConfigurableInterface
{
    use ConfigurableTrait;

    /**
     * @var string
     */
    protected $name;

    /**
     * @var TransportInterface
     */
    protected $transport;

    /**
     * @var CredentialsInterface
     */
    protected $credentials;

    /**
     * @var bool
     */
    private $useOperatorUnits = true;

    /**
     * @param string $name
     */
    public function setName($name)
    {
        $this->name = $name;
    }

    /**
     * @param TransportInterface $transport
     */
    public function setTransport(TransportInterface $transport)
    {
        $this->transport = $transport;
    }

    /**
     * @param CredentialsInterface $credentials
     */
    public function setCredentials(CredentialsInterface $credentials)
    {
        $this->credentials = $credentials;
    }

    /**
     * @param bool $useOperatorUnits
     */
    public function setUseOperatorUnits($useOperatorUnits)
    {
        $this->useOperatorUnits = $useOperatorUnits;
    }

    /**
     * Do API request with needle headers
     *
     * @param array $params
     * @param array $headers
     * @return mixed
     */
    public function request(array $params, $headers = [])
    {
        $response = $this->transport->request(new TransportRequest([
            'service' => $this->name,
            'credentials' => $this->credentials,
            'params' => $params,
            'headers' => $headers,
            'useOperatorUnits' => $this->useOperatorUnits
        ]));

        self::handleErrorResponse($response);

        $result = json_decode($response->getBody(), true);

        $result['units'] = [
            'debit' => $response->getUnitsDebit(),
            'limit' => $response->getUnitsLimit(),
            'rest' => $response->getUnitsRest()
        ];

        $result['request_id'] = $response->getRequestId();

        return $result;
    }

    /**
     * @param TransportResponse $response
     * @throws ErrorResponseException
     */
    protected static function handleErrorResponse(TransportResponse $response)
    {
        $json = json_decode($response->getBody(), true);

        if (isset($json['error'])
            && $json['error']
        ) {
            throw new ErrorResponseException(
                $json['error']['error_string'],
                $json['error']['error_detail'],
                $json['error']['error_code'],
                $json['error']['request_id']
            );
        }
    }
}