ApiClients\Client\AppVeyor\Client

Complexity

Total Complexity

5

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	create()	0	19	2
A	projects()	0	9	1
A	project()	0	7	1

<?php declare(strict_types=1);

namespace ApiClients\Client\AppVeyor;

use ApiClients\Client\AppVeyor\Resource\Sync\Project;
use ApiClients\Foundation\Factory as FoundationClientFactory;
use React\EventLoop\Factory as LoopFactory;
use React\EventLoop\LoopInterface;
use Rx\React\Promise;
use Rx\Scheduler;
use function Clue\React\Block\await;

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

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

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

    /**
     * @param  string $token
     * @param  array  $options
     * @return Client
     */
    public static function create(
        string $token,
        array $options = []
    ): self {
        $loop = LoopFactory::create();
        $options = ApiSettings::getOptions($token, $options, 'Sync');
        $client = FoundationClientFactory::create($loop, $options);

        try {
            Scheduler::setAsyncFactory(function () use ($loop) {
                return new Scheduler\EventLoopScheduler($loop);

$loop is of type object<React\EventLoop\LoopInterface>, but the function expects a callable.

            });
        } catch (\Throwable $t) {

Consider adding a comment why this CATCH block is empty.

        }

        $asyncClient = AsyncClient::createFromClient($client);

        return new self($loop, $asyncClient);
    }

    public function projects(): array
    {
        return await(
            Promise::fromObservable(
                $this->client->projects()->toArray()
            ),
            $this->loop
        );
    }

    public function project(string $repository): Project
    {
        return await(
            $this->client->project($repository),
            $this->loop
        );
    }
}