PHPDaemon\Clients\WebSocket\Example

Complexity

Total Complexity

9

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	6	2
A	onReady()	0	7	2
A	connect()	0	17	2
A	onShutdown()	0	7	2
A	getConfigDefaults()	0	8	1

<?php
namespace PHPDaemon\Clients\WebSocket;

use PHPDaemon\Core\AppInstance;

/**
 * @package    Clients
 * @subpackage WebSocket
 *
 * @author     Vasily Zorin <maintainer@daemon.io>
 */
class Example extends AppInstance
{

    public $wsclient;

    public $wsconn;

    /**
     * Constructor.
     * @return void
     */
    public function init()
    {
        if ($this->isEnabled()) {
            $this->wsclient = Pool::getInstance($this->config->wsclientname->value);
        }
    }

    /**
     * Called when the worker is ready to go.
     * @return void
     */
    public function onReady()
    {
        if ($this->wsclient) {
            $this->wsclient->onReady();
            $this->connect();
        }
    }

    public function connect()
    {
        $this->wsclient->getConnection($this->config->url->value, function ($conn) {
            $this->wsconn = $conn;
            if ($conn->connected) {
                $conn->sendFrame('foobar');
                $conn->on('disconnect', function ($conn) {

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

                    $this->log('Connection lost... Reconnect in ' . $this->config->reconnect->value . ' sec');
                    $this->connect();
                })->on('frame', function ($conn, $frame) {
                    $this->log('Got frame: ' . $frame);
                });
            } else {
                $this->log('Couldn\'t connect to ' . $this->config->url->value);
            }
        });
    }

    /**
     * Called when application instance is going to shutdown.
     * @return boolean Ready to shutdown?
     */
    public function onShutdown($graceful = false)
    {
        if ($this->wsclient) {
            return $this->wsclient->onShutdown();
        }
        return true;
    }

    /**
     * Setting default config options
     * Overriden from AppInstance::getConfigDefaults
     * @return array|false
     */
    protected function getConfigDefaults()
    {
        return [
            'url' => 'tcp://echo.websocket.org:80/',
            'reconnect' => 1,
            'wsclient-name' => ''
        ];
    }
}