Spires\Irc\Client

Complexity

Total Complexity

21

Size/Duplication

Total Lines	173
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	connection()	0	4	1
A	channel()	0	4	1
A	user()	0	4	1
A	socket()	0	4	1
A	connect()	0	16	1
A	read()	0	4	1
A	write()	0	7	1
A	logCore()	0	14	3
A	log()	0	7	1
A	logNewLine()	0	4	1
A	logLine()	0	4	1
A	logHeading()	0	12	1
A	logDebug()	0	4	1
A	logRead()	0	4	1
A	logWrite()	0	4	1
B	run()	0	26	3

<?php
declare(strict_types=1);

namespace Spires\Irc;

use Spires\Contracts\Core\Core;
use Spires\Core\Dispatcher;
use Spires\Irc\Message\Inbound\RawMessage;

class Client
{
    /**
     * @var Core
     */
    private $core;

    /**
     * @var Connection
     */
    private $connection;

    /**
     * @var User
     */
    private $user;

    /**
     * @var resource
     */
    private $socket;

    /**
     * @var Dispatcher
     */
    private $dispatcher;

    public function __construct(Core $core, Connection $connection, User $user, Dispatcher $dispatcher)
    {
        $this->core = $core;
        $this->connection = $connection;
        $this->user = $user;
        $this->dispatcher = $dispatcher;
    }

    public function connection() : Connection
    {
        return $this->connection;
    }

    public function channel() : string
    {
        return $this->connection()->channel();
    }

    public function user() : User
    {
        return $this->user;
    }

    public function socket() : resource
    {
        return $this->socket;
    }

    public function connect()
    {
        $this->logHeading('Spires connecting');

        $this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

        $isConnected = socket_connect(

$isConnected is not used, you could remove the assignment.

            $this->socket,
            $this->connection()->server(),
            $this->connection()->port()
        );

        $this->write("NICK {$this->user()->nickname()}");
        $this->write("USER {$this->user()->username()} {$this->user()->usermode()} * :{$this->user()->realname()}");
        $this->write("JOIN {$this->connection()->channel()}");
    }

    public function read()
    {
        return socket_read($this->socket, 2048, PHP_NORMAL_READ);
    }

    public function write(string $response)
    {
        $response = trim($response);

        $this->logWrite($response);
        return socket_write($this->socket, $response . "\r\n");
    }

    public function logCore(Core $core)
    {
        $this->logHeading('Spires booted');

        $this->logDebug("Providers:");
        foreach ($core->getLoadedProviders() as $provider => $active) {
            $this->logDebug("  - " . $provider);
        }

        $this->logDebug("Plugins:");
        foreach ($core->getPlugins() as $name => $plugin) {
            $this->logDebug("  - " . $name);
        }
    }

    public function log(string $title, string $string)
    {
        $time = date('H:i:s');
        $title = str_pad($title, 8, ' ', STR_PAD_RIGHT);

        fwrite(STDOUT, "[{$time}|{$title}]: " . $string . "\n");
    }

    public function logNewLine()
    {
        fwrite(STDOUT, "\n");
    }

    public function logLine()
    {
        fwrite(STDOUT, str_repeat('_', 80) . "\n");
    }

    public function logHeading(string $title)
    {
        $title = str_repeat('=', 5) . ' ' . $title . ' ';
        $title = str_pad($title, 60, '=', STR_PAD_RIGHT);
        $line = str_repeat('=', 60);

        $this->logNewLine();
        $this->log('debug', $line);
        $this->log('debug', $title);
        $this->log('debug', $line);
        $this->logNewLine();
    }

    public function logDebug(string $string)
    {
        $this->log('debug', $string);
    }

    public function logRead(string $string)
    {
        $this->log('read', $string);
    }

    public function logWrite(string $string)
    {
        $this->log('write', $string);
    }

    public function run()
    {
        $this->logHeading('Spires listening');

        $parser = new Parser();

        while ($raw = $this->read()) {
            if (!$raw = trim($raw)) {
                continue;
            }
            $this->logLine();
            $this->logRead($raw);
            $messageArray = $parser->parse($raw . "\r\n");

            $message = new RawMessage(
                $messageArray['nickname'],
                $messageArray['username'],
                $messageArray['hostname'],
                $messageArray['serverName'],
                $messageArray['command'],
                $messageArray['params']
            );

            $this->dispatcher->dispatch($message);
        }
    }
}