WyriHaximus\Travis\AsyncClient

Complexity

Total Complexity

7

Size/Duplication

Total Lines	60
Duplicated Lines	68.33 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	11	15	3
A	repository()	0	6	1
A	hooks()	10	10	1
A	accounts()	10	10	1
A	broadcasts()	10	10	1

<?php
declare(strict_types=1);

namespace WyriHaximus\Travis;

use React\EventLoop\LoopInterface;
use React\Promise\PromiseInterface;
use Rx\Observable;
use Rx\ObservableInterface;
use Rx\React\Promise;
use WyriHaximus\ApiClient\Transport\Client as Transport;
use WyriHaximus\ApiClient\Transport\Factory;
use function React\Promise\resolve;

class AsyncClient
{
    protected $transport;

    public function __construct(LoopInterface $loop, string $token = '', Transport $transport = null)
    {
        if (!($transport instanceof Transport)) {

This code seems to be duplicated across your project.

            $options = [
                'resource_namespace' => 'Async',
            ] + ApiSettings::TRANSPORT_OPTIONS;

            if ($token !== '') {
                $options['headers']['Authorization'] = 'token ' . $token;
            }

            $transport = Factory::create($loop, $options);
        }
        $this->transport = $transport;
    }

    public function repository(string $repository): PromiseInterface
    {
        return $this->transport->request('repos/' . $repository)->then(function ($json) {
            return resolve($this->transport->getHydrator()->hydrate('Repository', $json['repo']));
        });
    }

    public function hooks(): ObservableInterface

This method seems to be duplicated in your project.

    {
        return Promise::toObservable(
            $this->transport->request('hooks')
        )->flatMap(function ($response) {
            return Observable::fromArray($response['hooks']);
        })->map(function ($hook) {
            return $this->transport->getHydrator()->hydrate('Hook', $hook);
        });
    }

    public function accounts(): ObservableInterface

This method seems to be duplicated in your project.

    {
        return Promise::toObservable(
            $this->transport->request('accounts')
        )->flatMap(function ($response) {
            return Observable::fromArray($response['accounts']);
        })->map(function ($account) {
            return $this->transport->getHydrator()->hydrate('Account', $account);
        });
    }

    public function broadcasts(): ObservableInterface

This method seems to be duplicated in your project.

    {
        return Promise::toObservable(
            $this->transport->request('broadcasts')
        )->flatMap(function ($response) {
            return Observable::fromArray($response['broadcasts']);
        })->map(function ($broadcast) {
            return $this->getTransport()->getHydrator()->hydrate('Broadcast', $broadcast);

The method getTransport() does not seem to exist on object<WyriHaximus\Travis\AsyncClient>.

        });
    }
}