PHPDaemon\Servers\IRCBouncer\Pool

Complexity

Total Complexity

14

Size/Duplication

Total Lines	154
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	8	1
A	getConfigDefaults()	0	28	1
A	applyConfig()	0	8	2
A	onReady()	0	6	1
B	getConnection()	0	48	9

<?php
namespace PHPDaemon\Servers\IRCBouncer;

use PHPDaemon\Core\Daemon;
use PHPDaemon\Network\Server;
use PHPDaemon\Structures\ObjectStorage;

class Pool extends Server
{

    /**
     * @var Pool
     */
    public $client;

    /**
     * @var Connection
     */
    public $conn;

    /**
     * @var boolean
     */
    public $protologging = false;

    /**
     * @var Pool
     */
    public $db;

    /**
     * @var object
     */
    public $messages;

    /**
     * @var object
     */
    public $channels;

    /**
     * @TODO DESCR
     */
    protected function init()
    {
        $this->client = Pool::getInstance();

It seems like \PHPDaemon\Servers\IRCBouncer\Pool::getInstance() of type object<PHPDaemon\Network\this> is incompatible with the declared type object<PHPDaemon\Servers\IRCBouncer\Pool> of property $client.

        $this->client->protologging = $this->protologging;
        $this->db = Pool::getInstance();

It seems like \PHPDaemon\Servers\IRCBouncer\Pool::getInstance() of type object<PHPDaemon\Network\this> is incompatible with the declared type object<PHPDaemon\Servers\IRCBouncer\Pool> of property $db.

        $this->messages = $this->db->{$this->config->dbname->value . '.messages'};

The property dbname does not seem to exist in PHPDaemon\Config\Section.

        $this->channels = $this->db->{$this->config->dbname->value . '.channels'};
    }

    /**
     * Setting default config options
     * Overriden from ConnectionPool::getConfigDefaults
     * @return array|bool
     */
    protected function getConfigDefaults()
    {
        return [
            /* [string|array] Listen addresses */
            'listen' => '0.0.0.0',

            /* [integer] Listen port */
            'port' => 6667,

            /* [string] URL */
            'url' => 'irc://user@host/nickname/realname',

            /* [string] Server name */
            'servername' => 'bnchost.tld',

            /* [string] Default channels */
            'defaultchannels' => '',

            /* [boolean] Logging? */
            'protologging' => 0,

            /* [string] Database name */
            'dbname' => 'bnc',

            /* [string] Password */
            'password' => 'SecretPwd',
        ];
    }

    /**
     * @TODO DESCR
     */
    public function applyConfig()
    {
        parent::applyConfig();
        $this->protologging = (bool)$this->config->protologging->value;

The property protologging does not seem to exist in PHPDaemon\Config\Section.

        if (isset($this->client)) {
            $this->client->protologging = $this->protologging;
        }
    }

    /**
     * @TODO DESCR
     */
    public function onReady()
    {
        parent::onReady();
        $this->client->onReady();
        $this->getConnection($this->config->url->value);

The property url does not seem to exist in PHPDaemon\Config\Section.

    }

    /**
     * @TODO DESCR
     * @param string $url
     */
    public function getConnection($url)
    {
        $this->client->getConnection($url, function ($conn) use ($url) {

The call to Pool::getConnection() has too many arguments starting with function ($conn) use($url) { $this->conn = $conn; $conn->attachedClients = new \PHPDaemon\Structures\ObjectStorage(); if ($conn->connected) { \PHPDaemon\Core\Daemon::log('IRC bot connected at ' . $url); $conn->join($this->config->defaultchannels->value); $conn->bind('motd', function ($conn) { }); foreach ($this as $bouncerConn) { if (!$bouncerConn->attachedServer) { $bouncerConn->attachTo($conn); } } $conn->bind('command', function ($conn, $from, $cmd, $args) { if ($cmd === 'PONG') { return; } elseif ($cmd === 'PING') { return; } if ($from['orig'] === $conn->servername) { $from['orig'] = $this->config->servername->value; } $conn->attachedClients->each('commandArr', $from['orig'], $cmd, $args); }); $conn->bind('privateMsg', function ($conn, $msg) { \PHPDaemon\Core\Daemon::log('IRCBouncer: got private message \'' . $msg['body'] . '\' from \'' . $msg['from']['orig'] . '\''); }); $conn->bind('msg', function ($conn, $msg) { $msg['ts'] = microtime(true); $msg['dir'] = 'i'; $this->messages->insert($msg); }); $conn->bind('disconnect', function ($conn) use($url) { foreach ($this as $bouncerConn) { if ($bouncerConn->attachedServer === $conn) { $bouncerConn->detach(); } } $this->getConnection($url); }); } else { \PHPDaemon\Core\Daemon::log('IRCBouncer: unable to connect (' . $url . ')'); } }.

            $this->conn = $conn;
            $conn->attachedClients = new ObjectStorage;
            if ($conn->connected) {
                Daemon::log('IRC bot connected at ' . $url);
                $conn->join($this->config->defaultchannels->value);

The property defaultchannels does not seem to exist in PHPDaemon\Config\Section.

                $conn->bind('motd', function ($conn) {

The parameter $conn is not used and could be removed.

                    //Daemon::log($conn->motd);
                });
                foreach ($this as $bouncerConn) {
                    if (!$bouncerConn->attachedServer) {
                        $bouncerConn->attachTo($conn);
                    }
                }
                $conn->bind('command', function ($conn, $from, $cmd, $args) {
                    if ($cmd === 'PONG') {
                        return;
                    } elseif ($cmd === 'PING') {
                        return;
                    }
                    if ($from['orig'] === $conn->servername) {
                        $from['orig'] = $this->config->servername->value;

The property servername does not seem to exist in PHPDaemon\Config\Section.

                    }
                    $conn->attachedClients->each('commandArr', $from['orig'], $cmd, $args);
                });
                $conn->bind('privateMsg', function ($conn, $msg) {
                    Daemon::log('IRCBouncer: got private message \'' . $msg['body'] . '\' from \'' . $msg['from']['orig'] . '\'');
                });
                $conn->bind('msg', function ($conn, $msg) {
                    $msg['ts'] = microtime(true);
                    $msg['dir'] = 'i';
                    $this->messages->insert($msg);
                });
                $conn->bind('disconnect', function ($conn) use ($url) {
                    foreach ($this as $bouncerConn) {
                        if ($bouncerConn->attachedServer === $conn) {
                            $bouncerConn->detach();
                        }
                    }
                    $this->getConnection($url);
                });
            } else {
                Daemon::log('IRCBouncer: unable to connect (' . $url . ')');
            }
        });
    }
}