unreal4u\TelegramAPI\HttpClientRequestHandlerAmp

Complexity

Total Complexity

7

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	get()	0	5	1
A	post()	0	11	3
A	processRequest()	0	11	2

<?php

declare(strict_types=1);

namespace unreal4u\TelegramAPI;

use Amp\Artax\DefaultClient;
use Amp\Artax\Request;
use Amp\Artax\Response;
use Amp\Promise;
use React\Promise\PromiseInterface;
use unreal4u\TelegramAPI\Exceptions\ClientException;
use unreal4u\TelegramAPI\InternalFunctionality\TelegramResponse;

/**
 * @param Promise $promise
 * @return \React\Promise\PromiseInterface
 */
function reactAdapt(Promise $promise) {
    $deferred = new \React\Promise\Deferred();

    $promise->onResolve(function ($error = null, $result = null) use ($deferred) {
        if ($error) {
            $deferred->reject($error);
        } else {
            $deferred->resolve($result);
        }
    });

    return $deferred->promise();
}

class HttpClientRequestHandlerAmp implements RequestHandlerInterface {

    /**
     * @var DefaultClient
     */
    private $client;

    public function __construct() {
        $this->client = new DefaultClient;
    }

    /**
     * @param string $uri
     *
     * @return PromiseInterface
     */
    public function get(string $uri): PromiseInterface {
         $request = (new Request($uri))->withMethod('GET');

         return $this->processRequest($request);
    }

    /**
     * @param string $uri
     * @param array $formFields
     *
     * @return PromiseInterface
     */
    public function post(string $uri, array $formFields): PromiseInterface {
        $request = (new Request($uri))->withMethod('POST');

        if (!empty($formFields['headers']))
            $request = $request->withHeaders($formFields['headers']);

        if (!empty($formFields['body']))
            $request = $request->withBody($formFields['body']);

        return $this->processRequest($request);
    }

    /**
     * @param Request $request
     *
     * @return PromiseInterface
     */
    private function processRequest(Request $request) {
        return reactAdapt(\Amp\call(function () use ($request) {
            /** @var Response $response */
            $response = yield $this->client->request($request);

            if ($response->getStatus() >= 400)
                throw new ClientException($response->getReason(), $response->getStatus());

            return new TelegramResponse(yield $response->getBody(), $response->getHeaders());
        }));
    }
}