WyriHaximus\Travis\Transport\Client

Complexity

Total Complexity

8

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	request()	0	11	1
A	hydrate()	0	5	1
A	getHydrator()	0	10	2
A	createRequest()	0	8	1
A	getLoop()	0	4	1

<?php
declare(strict_types=1);

namespace WyriHaximus\Travis\Transport;

use GeneratedHydrator\Configuration;
use GuzzleHttp\Psr7\Request;
use Psr\Http\Message\ResponseInterface;
use React\EventLoop\LoopInterface;
use React\Promise\Deferred;

class Client
{
    const VERSION = '0.0.1-alpha1';
    const USER_AGENT = 'wyrihaximus/travis-client/' . self::VERSION;
    const API_VERSION = 'application/vnd.travis-ci.2+json';
    const API_HOST_OPEN_SOURCE = 'api.travis-ci.org';
    const API_HOST_PRO = 'api.travis-ci.com';
    const API_HOST = self::API_HOST_OPEN_SOURCE;
    const API_SCHEMA = 'https';

    /**
     * @var callable
     */
    protected $handler;
    protected $loop;

    protected $hydrators = [];

    public function __construct(LoopInterface $loop, callable $handler = null)
    {
        $this->loop = $loop;
        if ($handler === null) {
            $handler = \Aws\default_http_handler();
        }

        $this->handler = $handler;
    }

    public function request($path)
    {
        $deferred = new Deferred();
        $handler = $this->handler;
        $handler($this->createRequest('GET', $path))->then(function (ResponseInterface $response) use ($deferred) {
            $deferred->resolve($response);
        }, function ($error) use ($deferred) {
            $deferred->reject($error);
        });
        return $deferred->promise();
    }

    public function hydrate($class, $response)
    {
        $json = json_decode($response->getBody()->getContents(), true);
        return $this->getHydrator($class)->hydrate($json['repo'], new $class);
    }

    protected function getHydrator($class)
    {
        if (isset($this->hydrators[$class])) {
            return $this->hydrators[$class];
        }

        $hydrator = (new Configuration($class))->createFactory()->getHydratorClass();
        $this->hydrators[$class] = new $hydrator;
        return $this->hydrators[$class];
    }

    protected function createRequest(string $method, string $path)
    {
        $url = self::API_SCHEMA . '://' . self::API_HOST . '/' . $path;
        return new Request($method, $url, [
            'User-Agent' => self::USER_AGENT,
            'Accept' => self::API_VERSION,
        ]);
    }

    /**
     * @return LoopInterface
     */
    public function getLoop()
    {
        return $this->loop;
    }
}