ApiClients\Client\Twitter\Client

Complexity

Total Complexity

8

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	withAccessToken()	0	6	1
A	withOutAccessToken()	0	6	1
A	stream()	0	12	2
A	tweet()	0	7	1
A	profile()	0	7	1
A	user()	0	7	1

<?php declare(strict_types=1);

namespace ApiClients\Client\Twitter;

use ApiClients\Client\Twitter\Resource\ProfileInterface;
use ApiClients\Client\Twitter\Resource\TweetInterface;
use ApiClients\Client\Twitter\Resource\UserInterface;
use React\EventLoop\Factory as LoopFactory;
use React\EventLoop\LoopInterface;
use function Clue\React\Block\await;

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

    /**
     * @var AsyncClient
     */
    protected $client;

    /**
     * @var StreamingClient
     */
    protected $streamingClient;

    public function __construct(
        string $consumerKey,
        string $consumerSecret
    ) {
        $this->loop = LoopFactory::create();
        $this->client = new AsyncClient($consumerKey, $consumerSecret, $this->loop);
    }

    public function withAccessToken(string $accessToken, string $accessTokenSecret): Client
    {
        $clone = clone $this;
        $clone->client = $this->client->withAccessToken($accessToken, $accessTokenSecret);
        return $clone;
    }

    public function withOutAccessToken(): Client
    {
        $clone = clone $this;
        $clone->client = $this->client->withOutAccessToken();
        return $clone;
    }

    public function stream(): StreamingClient
    {
        if (!($this->streamingClient instanceof StreamingClient)) {
            $this->streamingClient = new StreamingClient(
                $this->loop,
                $this->client->getCommandBus(),
                $this->client->stream()
            );
        }

        return $this->streamingClient;
    }

    public function tweet(string $tweet): TweetInterface
    {
        return await(
            $this->client->tweet($tweet),

The method tweet() does not seem to exist on object<ApiClients\Client\Twitter\AsyncClient>.

            $this->loop
        );
    }

    public function profile(): ProfileInterface
    {
        return await(
            $this->client->profile(),
            $this->loop
        );
    }

    public function user(string $tweet): UserInterface
    {
        return await(
            $this->client->user($tweet),
            $this->loop
        );
    }
}