Nopolabs\Yabot\Slack\Client

Complexity

Total Complexity

28

Size/Duplication

Total Lines	184
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

22 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getRealTimeClient()	0	4	1
A	init()	0	7	1
A	update()	0	6	1
A	getAuthedUser()	0	4	1
A	getAuthedUsername()	0	4	1
A	connect()	0	4	1
A	disconnect()	0	4	1
A	useWebSocket()	0	4	1
B	say()	0	17	5
A	send()	0	4	1
A	post()	0	10	1
A	on()	0	6	1
A	getUserById()	0	4	1
A	getUserByName()	0	4	1
A	getChannelById()	0	4	1
A	getChannelByName()	0	4	1
A	updateUsers()	0	6	1
A	updateChannels()	0	6	1
A	updateAuthedUser()	0	7	1
A	initChannelUpdateHandlers()	0	7	2
A	initUserUpdateHandlers()	0	7	2

<?php

namespace Nopolabs\Yabot\Slack;


use Closure;
use Nopolabs\Yabot\Helpers\ConfigTrait;
use React\Promise\PromiseInterface;
use Slack\Channel;
use Slack\ChannelInterface;
use Slack\Payload;
use Slack\RealTimeClient;
use Slack\User;

class Client
{
    use ConfigTrait;

    /** @var RealTimeClient */
    private $realTimeClient;

    /** @var Users */
    private $users;

    /** @var Channels */
    private $channels;

    /** @var User */
    protected $authedUser;

    public function __construct(RealTimeClient $realTimeClient, Users $users, Channels $channels, array $config = [])
    {
        $this->realTimeClient = $realTimeClient;
        $this->users = $users;
        $this->channels = $channels;
        $this->setConfig($config);
    }

    public function getRealTimeClient()
    {
        return $this->realTimeClient;
    }

    public function init() : Client
    {
        $this->initChannelUpdateHandlers();
        $this->initUserUpdateHandlers();

        return $this;
    }

    public function update(Closure $authedUserUpdated)
    {
        $this->updateUsers();
        $this->updateChannels();
        $this->updateAuthedUser($authedUserUpdated);
    }

    public function getAuthedUser()
    {
        return $this->authedUser;
    }

    public function getAuthedUsername()
    {
        return $this->authedUser->getUsername();
    }

    public function connect() : PromiseInterface
    {
        return $this->realTimeClient->connect();
    }

    public function disconnect()
    {
        return $this->realTimeClient->disconnect();
    }

    public function useWebSocket() : bool
    {
        return (bool) $this->get('use.websocket', false);
    }

    public function say($text, $channel, array $additionalParameters = [])
    {
        if (!($channel instanceof ChannelInterface)) {
            $channel = $this->getChannelByName($channel);
            if (!$channel) {
                $channel = $this->getChannelById($channel);
            }
        }

        if (empty($additionalParameters) && $this->useWebSocket()) {
            // WebSocket send does not support message formatting.
            $this->send($text, $channel);

It seems like $channel can be null; however, send() does not accept null, maybe add an additional type check?

        } else {
            // Http post send supports message formatting.
            $this->post($text, $channel, $additionalParameters);

It seems like $channel can be null; however, post() does not accept null, maybe add an additional type check?

        }
    }

    public function send($text, ChannelInterface $channel)
    {
        $this->realTimeClient->send($text, $channel);
    }

    public function post($text, ChannelInterface $channel, array $additionalParameters = [])
    {
        $parameters = array_merge([
            'text' => $text,
            'channel' => $channel->getId(),
            'as_user' => true,
        ], $additionalParameters);

        $this->realTimeClient->apiCall('chat.postMessage', $parameters);
    }

    public function on($event, array $onMessage)
    {
        $this->realTimeClient->on($event, function (Payload $payload) use ($onMessage) {
            call_user_func($onMessage, $payload);
        });
    }

    /**
     * @param $id
     * @return null|User
     */
    public function getUserById($id)
    {
        return $this->users->byId($id);
    }

    /**
     * @param $name
     * @return null|User
     */
    public function getUserByName($name)
    {
        return $this->users->byName($name);
    }

    /**
     * @param $id
     * @return null|Channel
     */
    public function getChannelById($id)
    {
        return $this->channels->byId($id);
    }

    /**
     * @param $name
     * @return null|Channel
     */
    public function getChannelByName($name)
    {
        return $this->channels->byName($name);
    }

    public function updateUsers()
    {
        $this->realTimeClient->getUsers()->then(function(array $users) {
            $this->users->update($users);
        });
    }

    public function updateChannels()
    {
        $this->realTimeClient->getChannels()->then(function(array $channels) {
            $this->channels->update($channels);
        });
    }

    public function updateAuthedUser(Closure $authedUserUpdated)
    {
        $this->realTimeClient->getAuthedUser()->then(function (User $user) use ($authedUserUpdated) {
            $this->authedUser = $user;
            $authedUserUpdated($user);
        });
    }

    protected function initChannelUpdateHandlers()
    {
        $events = ['channel_created', 'channel_deleted', 'channel_rename'];
        foreach ($events as $event) {
            $this->on($event, [$this, 'updateChannels']);
        }
    }

    protected function initUserUpdateHandlers()
    {
        $events = ['user_change'];
        foreach ($events as $event) {
            $this->on($event, [$this, 'updateUsers']);
        }
    }
}