TelegramBot\Api\Http\PsrHttpClient

Complexity

Total Complexity

8

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	doDownload()	0	8	2
A	doRequest()	0	18	3
A	jsonValidate()	0	10	2
A	__construct()	0	4	1

<?php

namespace TelegramBot\Api\Http;

use Psr\Http\Client\ClientExceptionInterface;

The type Psr\Http\Client\ClientExceptionInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Http\Client\ClientInterface;

The type Psr\Http\Client\ClientInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Http\Message\RequestFactoryInterface;

The type Psr\Http\Message\RequestFactoryInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use TelegramBot\Api\HttpException;
use TelegramBot\Api\InvalidJsonException;

class PsrHttpClient extends AbstractHttpClient
{
    /**
     * @var ClientInterface
     */
    private $http;

    /**
     * @var RequestFactoryInterface
     */
    private $requestFactory;

    public function __construct(ClientInterface $http, RequestFactoryInterface $requestFactory)
    {
        $this->http = $http;
        $this->requestFactory = $requestFactory;
    }

    /**
     * @inheritDoc
     */
    protected function doRequest($url, array $data = null)
    {
        if ($data) {
            $method = 'POST';
        } else {
            $method = 'GET';
        }

        $request = $this->requestFactory->createRequest($method, $url);
        try {
            $response = $this->http->sendRequest($request);
        } catch (ClientExceptionInterface $exception) {
            throw new HttpException($exception->getMessage(), $exception->getCode(), $exception);
        }

        $content = $response->getBody()->getContents();

        return self::jsonValidate($content);
    }

    /**
     * @inheritDoc
     */
    protected function doDownload($url)
    {
        $request = $this->requestFactory->createRequest('GET', $url);

        try {
            return $this->http->sendRequest($request)->getBody()->getContents();
        } catch (ClientExceptionInterface $exception) {
            throw new HttpException($exception->getMessage(), $exception->getCode(), $exception);
        }
    }

    /**
     * @param string $jsonString
     * @return array
     * @throws InvalidJsonException
     */
    private static function jsonValidate($jsonString)
    {
        /** @var array $json */
        $json = json_decode($jsonString, true);

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new InvalidJsonException(json_last_error_msg(), json_last_error());
        }

        return $json;
    }
}