MetricaClient::sendRequest() - Code Metrics - nixsolutions/yandex-php-library - Measure and Improve Code Quality continuously with Scrutinizer

MetricaClient::sendRequest() B
last analyzed 2021-05-31 12:34 UTC

↳ Parent: MetricaClient

Complexity

Conditions	9
Paths	16

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	23
CRAP Score	9

Importance

Changes

Metric	Value
dl	0
loc	41
ccs	23
cts	23
cp	1
rs	7.7084
c	0
b	0
f	0
cc	9
nc	16
nop	3
crap	9

<?php
/**
 * Yandex PHP Library
 *
 * @copyright NIX Solutions Ltd.
 * @link https://github.com/nixsolutions/yandex-php-library
 */

/**
 * @namespace
 */
namespace Yandex\Metrica;

use GuzzleHttp\ClientInterface;
use Yandex\Common\AbstractServiceClient;
use GuzzleHttp\Psr7\Response;
use GuzzleHttp\Exception\ClientException;
use Yandex\Common\Exception\ForbiddenException;
use Yandex\Common\Exception\UnauthorizedException;
use Yandex\Common\Exception\TooManyRequestsException;
use Yandex\Metrica\Exception\BadRequestException;
use Yandex\Metrica\Exception\MetricaException;

/**
 * Class MetricaClient
 *
 * @category Yandex
 * @package Metrica
 *
 * @author   Alexander Khaylo <[email protected]>
 * @created  12.02.14 15:46
 */
class MetricaClient extends AbstractServiceClient
{
    /**
     * API domain
     *
     * @var string
     */
    protected $serviceDomain = 'api-metrika.yandex.ru/management/v1';

    /**
     * @param string $token access token
     * @param ClientInterface $client
     */
    public function __construct($token = '', ClientInterface $client = null)
    {
        $this->setAccessToken($token);
        if (!is_null($client)) {
            $this->setClient($client);
        }
    }

    /**
     * Get url to service resource with parameters
     *
     * @param string $resource
     * @param array $params
     * @see http://api.yandex.ru/metrika/doc/ref/concepts/method-call.xml
     * @return string
     */
    public function getServiceUrl($resource = '', $params = [])
    {
        $format = $resource === '' ? '' : '.json';
        $url = $this->serviceScheme . '://' . $this->serviceDomain . '/'
            . $resource . $format;

        if ($params) {

            $url .= '?' . http_build_query($params);
        }

        return $url;
    }

    /**
     * Sends a request
     *
     * @param string              $method  HTTP method
     * @param string $uri     URI object or string.
     * @param array               $options Request options to apply.
     *
     * @return Response
     *
     * @throws BadRequestException
     * @throws ForbiddenException
     * @throws MetricaException
     * @throws TooManyRequestsException
     * @throws UnauthorizedException
     */
    protected function sendRequest($method, $uri, array $options = [])
    {
        try {
            $response = $this->getClient()->request($method, $uri, $options);
        } catch (ClientException $ex) {
            $result = $ex->getResponse();
            $code = $result->getStatusCode();
            $message = $result->getReasonPhrase();

            $body = $result->getBody();
            if ($body) {
                $jsonBody = json_decode($body);
                if ($jsonBody && isset($jsonBody->message)) {
                    $message = $jsonBody->message;
                }
            }

            if ($code === 400) {
                throw new BadRequestException($message);
            }

            if ($code === 403) {
                throw new ForbiddenException($message);
            }

            if ($code === 401) {
                throw new UnauthorizedException($message);
            }

            if ($code === 429) {
                throw new TooManyRequestsException($message);
            }

            throw new MetricaException(
                'Service responded with error code: "' . $code . '" and message: "' . $message . '"',
                $code
            );
        }

        return $response;
    }

    /**
     * Send GET request to API resource
     *
     * @param string $resource
     * @param array $params
     * @return array
     */
    protected function sendGetRequest($resource, $params = [])
    {
        $response = $this->sendRequest(
            'GET',
            $this->getServiceUrl($resource, $params),
            [
                'headers' => [
                    'Accept' => 'application/x-yametrika+json',
                    'Content-Type' => 'application/x-yametrika+json',
                    'Authorization' => 'OAuth ' . $this->getAccessToken(),
                ]
            ]
        );

        $decodedResponseBody = $this->getDecodedBody($response->getBody());

        if (isset($decodedResponseBody['links']) && isset($decodedResponseBody['links']['next'])) {

            $url = $decodedResponseBody['links']['next'];
            unset($decodedResponseBody['rows']);
            unset($decodedResponseBody['links']);
            return $this->getNextPartOfList($url, $decodedResponseBody);
        }
        return $decodedResponseBody;
    }

    /**
     * Send custom GET request to API resource
     *
     * @param string $url
     * @param array $data
     * @return array
     */
    protected function getNextPartOfList($url, $data = [])
    {
        $response = $this->sendRequest(
            'GET',
            $url,
            [
                'headers' => [
                    'Accept' => 'application/x-yametrika+json',
                    'Content-Type' => 'application/x-yametrika+json',
                    'Authorization' => 'OAuth ' . $this->getAccessToken(),
                ]
            ]
        );

        $decodedResponseBody = $this->getDecodedBody($response->getBody());

        $mergedDecodedResponseBody = array_merge_recursive($data, $decodedResponseBody);

        if (isset($mergedDecodedResponseBody['links']) && isset($mergedDecodedResponseBody['links']['next'])) {

            $url = $mergedDecodedResponseBody['links'];
            unset($mergedDecodedResponseBody['rows']);
            unset($mergedDecodedResponseBody['links']);
            return $this->getNextPartOfList($url, $response);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }

        return $mergedDecodedResponseBody;
    }

    /**
     * Send POST request to API resource
     *
     * @param string $resource
     * @param array $params
     * @return array
     */
    protected function sendPostRequest($resource, $params)

    {
        $response = $this->sendRequest(
            'POST',
            $this->getServiceUrl($resource),
            [
                'headers' => [
                    'Accept' => 'application/x-yametrika+json',
                    'Content-Type' => 'application/x-yametrika+json',
                    'Authorization' => 'OAuth ' . $this->getAccessToken(),
                ],
                'json' => $params
            ]
        );

        return $this->getDecodedBody($response->getBody());
    }

    /**
     * Send PUT request to API resource
     *
     * @param string $resource
     * @param array $params
     * @return array
     */
    protected function sendPutRequest($resource, $params)

    {
        $response = $this->sendRequest(
            'PUT',
            $this->getServiceUrl($resource),
            [
                'headers' => [
                    'Accept' => 'application/x-yametrika+json',
                    'Content-Type' => 'application/x-yametrika+json',
                    'Authorization' => 'OAuth ' . $this->getAccessToken(),
                ],
                'json' => $params
            ]
        );

        return $this->getDecodedBody($response->getBody());
    }

    /**
     * Send DELETE request to API resource
     *
     * @param string $resource
     * @return array
     */
    protected function sendDeleteRequest($resource)
    {
        $response = $this->sendRequest(
            'DELETE',
            $this->getServiceUrl($resource),
            [
                'headers' => [
                    'Accept' => 'application/x-yametrika+json',
                    'Content-Type' => 'application/x-yametrika+json',
                    'Authorization' => 'OAuth ' . $this->getAccessToken(),
                ]
            ]
        );

        return $this->getDecodedBody($response->getBody());
    }
}


1			<?php
2			/**
3			* Yandex PHP Library
4			*
5			* @copyright NIX Solutions Ltd.
6			* @link https://github.com/nixsolutions/yandex-php-library
7			*/
8
9			/**
10			* @namespace
11			*/
12			namespace Yandex\Metrica;
13
14			use GuzzleHttp\ClientInterface;
15			use Yandex\Common\AbstractServiceClient;
16			use GuzzleHttp\Psr7\Response;
17			use GuzzleHttp\Exception\ClientException;
18			use Yandex\Common\Exception\ForbiddenException;
19			use Yandex\Common\Exception\UnauthorizedException;
20			use Yandex\Common\Exception\TooManyRequestsException;
21			use Yandex\Metrica\Exception\BadRequestException;
22			use Yandex\Metrica\Exception\MetricaException;
23
24			/**
25			* Class MetricaClient
26			*
27			* @category Yandex
28			* @package Metrica
29			*
30			* @author Alexander Khaylo <[email protected]>
31			* @created 12.02.14 15:46
32			*/
33			class MetricaClient extends AbstractServiceClient
34			{
35			/**
36			* API domain
37			*
38			* @var string
39			*/
40			protected $serviceDomain = 'api-metrika.yandex.ru/management/v1';
41
42			/**
43			* @param string $token access token
44			* @param ClientInterface $client
45			*/
46	58		public function __construct($token = '', ClientInterface $client = null)
47			{
48	58		$this->setAccessToken($token);
49	58		if (!is_null($client)) {
50	1		$this->setClient($client);
51			}
52	58		}
53
54			/**
55			* Get url to service resource with parameters
56			*
57			* @param string $resource
58			* @param array $params
59			* @see http://api.yandex.ru/metrika/doc/ref/concepts/method-call.xml
60			* @return string
61			*/
62	29		public function getServiceUrl($resource = '', $params = [])
63			{
64	29		$format = $resource === '' ? '' : '.json';
65	29		$url = $this->serviceScheme . '://' . $this->serviceDomain . '/'
66	29		. $resource . $format;
67
68	29		if ($params) {
			0 ignored issues – show Bug Best Practice introduced 2019-01-10 13:48 UTC by Report Bug Copy Issue Report The expression `$params` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `! empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
69	2		$url .= '?' . http_build_query($params);
70			}
71
72	29		return $url;
73			}
74
75			/**
76			* Sends a request
77			*
78			* @param string $method HTTP method
79			* @param string $uri URI object or string.
80			* @param array $options Request options to apply.
81			*
82			* @return Response
83			*
84			* @throws BadRequestException
85			* @throws ForbiddenException
86			* @throws MetricaException
87			* @throws TooManyRequestsException
88			* @throws UnauthorizedException
89			*/
90	27		protected function sendRequest($method, $uri, array $options = [])
91			{
92			try {
93	27		$response = $this->getClient()->request($method, $uri, $options);
94	5		} catch (ClientException $ex) {
95	5		$result = $ex->getResponse();
96	5		$code = $result->getStatusCode();
97	5		$message = $result->getReasonPhrase();
98
99	5		$body = $result->getBody();
100	5		if ($body) {
101	5		$jsonBody = json_decode($body);
102	5		if ($jsonBody && isset($jsonBody->message)) {
103	1		$message = $jsonBody->message;
104			}
105			}
106
107	5		if ($code === 400) {
108	1		throw new BadRequestException($message);
109			}
110
111	4		if ($code === 403) {
112	1		throw new ForbiddenException($message);
113			}
114
115	3		if ($code === 401) {
116	1		throw new UnauthorizedException($message);
117			}
118
119	2		if ($code === 429) {
120	1		throw new TooManyRequestsException($message);
121			}
122
123	1		throw new MetricaException(
124	1		'Service responded with error code: "' . $code . '" and message: "' . $message . '"',
125	1		$code
126			);
127			}
128
129	22		return $response;
130			}
131
132			/**
133			* Send GET request to API resource
134			*
135			* @param string $resource
136			* @param array $params
137			* @return array
138			*/
139	6		protected function sendGetRequest($resource, $params = [])
140			{
141	6		$response = $this->sendRequest(
142	6		'GET',
143	6		$this->getServiceUrl($resource, $params),
144			[
145			'headers' => [
146	6		'Accept' => 'application/x-yametrika+json',
147	6		'Content-Type' => 'application/x-yametrika+json',
148	6		'Authorization' => 'OAuth ' . $this->getAccessToken(),
149			]
150			]
151			);
152
153	1		$decodedResponseBody = $this->getDecodedBody($response->getBody());
154
155	1	View Code Duplication	if (isset($decodedResponseBody['links']) && isset($decodedResponseBody['links']['next'])) {
			0 ignored issues – show Duplication introduced 2015-11-23 12:09 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
156			$url = $decodedResponseBody['links']['next'];
157			unset($decodedResponseBody['rows']);
158			unset($decodedResponseBody['links']);
159			return $this->getNextPartOfList($url, $decodedResponseBody);
160			}
161	1		return $decodedResponseBody;
162			}
163
164			/**
165			* Send custom GET request to API resource
166			*
167			* @param string $url
168			* @param array $data
169			* @return array
170			*/
171			protected function getNextPartOfList($url, $data = [])
172			{
173			$response = $this->sendRequest(
174			'GET',
175			$url,
176			[
177			'headers' => [
178			'Accept' => 'application/x-yametrika+json',
179			'Content-Type' => 'application/x-yametrika+json',
180			'Authorization' => 'OAuth ' . $this->getAccessToken(),
181			]
182			]
183			);
184
185			$decodedResponseBody = $this->getDecodedBody($response->getBody());
186
187			$mergedDecodedResponseBody = array_merge_recursive($data, $decodedResponseBody);
188
189		View Code Duplication	if (isset($mergedDecodedResponseBody['links']) && isset($mergedDecodedResponseBody['links']['next'])) {
			0 ignored issues – show Duplication introduced 2015-11-23 12:09 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
190			$url = $mergedDecodedResponseBody['links'];
191			unset($mergedDecodedResponseBody['rows']);
192			unset($mergedDecodedResponseBody['links']);
193			return $this->getNextPartOfList($url, $response);
			0 ignored issues – show Documentation introduced 2015-11-23 12:09 UTC by Report Bug Copy Issue Report `$response` is of type `object<GuzzleHttp\Psr7\Response>`, but the function expects a `array`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
194			}
195
196			return $mergedDecodedResponseBody;
197			}
198
199			/**
200			* Send POST request to API resource
201			*
202			* @param string $resource
203			* @param array $params
204			* @return array
205			*/
206	7	View Code Duplication	protected function sendPostRequest($resource, $params)
			0 ignored issues – show Duplication introduced 2017-10-22 15:29 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
207			{
208	7		$response = $this->sendRequest(
209	7		'POST',
210	7		$this->getServiceUrl($resource),
211			[
212			'headers' => [
213	7		'Accept' => 'application/x-yametrika+json',
214	7		'Content-Type' => 'application/x-yametrika+json',
215	7		'Authorization' => 'OAuth ' . $this->getAccessToken(),
216			],
217	7		'json' => $params
218			]
219			);
220
221	7		return $this->getDecodedBody($response->getBody());
222			}
223
224			/**
225			* Send PUT request to API resource
226			*
227			* @param string $resource
228			* @param array $params
229			* @return array
230			*/
231	7	View Code Duplication	protected function sendPutRequest($resource, $params)
			0 ignored issues – show Duplication introduced 2017-10-22 15:29 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
232			{
233	7		$response = $this->sendRequest(
234	7		'PUT',
235	7		$this->getServiceUrl($resource),
236			[
237			'headers' => [
238	7		'Accept' => 'application/x-yametrika+json',
239	7		'Content-Type' => 'application/x-yametrika+json',
240	7		'Authorization' => 'OAuth ' . $this->getAccessToken(),
241			],
242	7		'json' => $params
243			]
244			);
245
246	7		return $this->getDecodedBody($response->getBody());
247			}
248
249			/**
250			* Send DELETE request to API resource
251			*
252			* @param string $resource
253			* @return array
254			*/
255	7		protected function sendDeleteRequest($resource)
256			{
257	7		$response = $this->sendRequest(
258	7		'DELETE',
259	7		$this->getServiceUrl($resource),
260			[
261			'headers' => [
262	7		'Accept' => 'application/x-yametrika+json',
263	7		'Content-Type' => 'application/x-yametrika+json',
264	7		'Authorization' => 'OAuth ' . $this->getAccessToken(),
265			]
266			]
267			);
268
269	7		return $this->getDecodedBody($response->getBody());
270			}
271			}
272

nixsolutions / yandex-php-library

MetricaClient::sendRequest() B last analyzed 2021-05-31 12:34 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MetricaClient::sendRequest() B
last analyzed 2021-05-31 12:34 UTC