WyriHaximus\Travis\Transport\Client

Complexity

Total Complexity

12

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes	3
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	2
A	request()	0	11	1
A	hydrateFQCN()	0	6	1
A	hydrate()	0	7	1
A	extractFQCN()	0	4	1
A	extract()	0	5	1
A	getHydrator()	0	14	3
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;
use WyriHaximus\Travis\Resource\Async;
use WyriHaximus\Travis\Resource\Sync;

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';
    const RESOURCE_NAMESPACE = 'WyriHaximus\Travis\Resource\\';

    /**
     * @var callable
     */
    protected $handler;
    protected $loop;
    protected $options = [];

    protected $hydrators = [];

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

        $this->handler = $handler;
        $this->options = $options;
    }

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

    public function hydrateFQCN($class, $json)
    {
        $object = new $class();
        $object->setTransport($this);
        return $this->getHydrator($class)->hydrate($json, $object);
    }

    public function hydrate($class, $json)
    {
        $fullClassName = self::RESOURCE_NAMESPACE . $this->options['resource_namespace'] . '\\' . $class;
        $object = new $fullClassName();
        $object->setTransport($this);
        return $this->getHydrator($fullClassName)->hydrate($json, $object);
    }

    public function extractFQCN($class, $object)
    {
        return $this->getHydrator($class)->extract($object);
    }

    public function extract($class, $object)
    {
        $fullClassName = self::RESOURCE_NAMESPACE . $this->options['resource_namespace'] . '\\' . $class;
        return $this->getHydrator($fullClassName)->extract($object);
    }

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

        $config = new Configuration($class);
        if (isset($this->options['resource_hydrator_cache_dir'])) {
            $config->setGeneratedClassesTargetDir($this->options['resource_hydrator_cache_dir']);
        }
        $hydrator = $config->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;
    }
}