ApiClients\Client\Travis\Client

Complexity

Total Complexity

12

Size/Duplication

Total Lines	163
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

84.91%

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	create()	0	12	1
A	createFromClient()	0	4	1
A	hydrate()	0	7	1
A	extract()	0	7	1
A	repository()	0	7	1
A	user()	0	7	1
A	sshKey()	0	7	1
A	hooks()	0	9	1
A	repositories()	0	9	1
A	accounts()	0	9	1
A	broadcasts()	0	9	1

<?php
declare(strict_types=1);

namespace ApiClients\Client\Travis;

use ApiClients\Client\Travis\Resource\RepositoryInterface;
use ApiClients\Client\Travis\Resource\SSHKeyInterface;
use ApiClients\Client\Travis\Resource\UserInterface;
use ApiClients\Foundation\Factory;
use ApiClients\Foundation\Resource\ResourceInterface;
use React\EventLoop\Factory as LoopFactory;
use React\EventLoop\LoopInterface;
use Rx\React\Promise;
use function ApiClients\Tools\Rx\setAsyncScheduler;
use function Clue\React\Block\await;

final class Client implements ClientInterface
{
    /**
     * @var LoopInterface
     */
    private $loop;

    /**
     * @var AsyncClientInterface
     */
    private $asyncClient;

    /**
     * @param LoopInterface        $loop
     * @param AsyncClientInterface $asyncClient
     */
    private function __construct(LoopInterface $loop, AsyncClientInterface $asyncClient)
    {
        $this->loop = $loop;
        $this->asyncClient = $asyncClient;
    }

    /**
     * Create a new AsyncClient based on the loop and other options pass.
     *
     * @param  string $token   Instructions to fetch the token: https://blog.travis-ci.com/2013-01-28-token-token-token/
     * @param  array  $options
     * @return Client
     */
    public static function create(
        string $token = '',
        array $options = []
    ): self {
        $loop = LoopFactory::create();
        $options = ApiSettings::getOptions($token, 'Sync', $options);
        $client = Factory::create($loop, $options);
        setAsyncScheduler($loop);
        $asyncClient = AsyncClient::createFromClient($client);

        return self::createFromClient($loop, $asyncClient);
    }

    /**
     * Create an Client from a AsyncClientInterface.
     * Be sure to pass in a client with the options from ApiSettings and the Sync namespace suffix,
     * and pass in the same loop as associated with the AsyncClient you're passing in.
     *
     * @param  LoopInterface        $loop
     * @param  AsyncClientInterface $asyncClient
     * @return Client
     */
    public static function createFromClient(LoopInterface $loop, AsyncClientInterface $asyncClient): self
    {
        return new self($loop, $asyncClient);
    }

    public function hydrate(string $resource): ResourceInterface
    {
        return await(
            $this->asyncClient->hydrate($resource),
            $this->loop
        );
    }

    public function extract(ResourceInterface $resource): string
    {
        return await(
            $this->asyncClient->extract($resource),
            $this->loop
        );
    }

    /**
     * {@inheritdoc}
     */
    public function repository(string $repository): RepositoryInterface
    {
        return await(
            $this->asyncClient->repository($repository),
            $this->loop
        );
    }

    /**
     * {@inheritdoc}
     */
    public function user(): UserInterface
    {
        return await(
            $this->asyncClient->user(),
            $this->loop
        );
    }

    /**
     * {@inheritdoc}
     */
    public function sshKey(int $id): SSHKeyInterface
    {
        return await(
            $this->asyncClient->sshKey($id),
            $this->loop
        );
    }

    /**
     * {@inheritdoc}
     */
    public function hooks(): array
    {
        return await(
            Promise::fromObservable(
                $this->asyncClient->hooks()->toArray()
            ),
            $this->loop
        );
    }

    /**
     * Warning this a intensive operation as it has to make a call for each hook
     * to turn it into a Repository!!!
     *
     * Take a look at examples/repositories-async.php on how to limit the amount of
     * concurrent requests.
     *
     * {@inheritdoc}
     */
    public function repositories(callable $filter = null): array
    {
        return await(
            Promise::fromObservable(
                $this->asyncClient->repositories($filter)->toArray()
            ),
            $this->loop
        );
    }

    /**
     * {@inheritdoc}
     */
    public function accounts(): array
    {
        return await(
            Promise::fromObservable(
                $this->asyncClient->accounts()->toArray()
            ),
            $this->loop
        );
    }

    /**
     * {@inheritdoc}
     */
    public function broadcasts(): array
    {
        return await(
            Promise::fromObservable(
                $this->asyncClient->broadcasts()->toArray()
            ),
            $this->loop
        );
    }
}