PHPDaemon\Examples\ExampleAsteriskClient

Complexity

Total Complexity

9

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

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

<?php
namespace PHPDaemon\Examples;

use PHPDaemon\Clients\Asterisk\Pool;
use PHPDaemon\Core\AppInstance;

/**
 * @package    Examples
 * @subpackage Asterisk
 *
 * @author     TyShkan <denis@tyshkan.ru>
 */
class ExampleAsteriskClient extends AppInstance
{

    public $asteriskclient;

    public $asteriskconn;

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

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

    public function connect()
    {
        $this->asteriskclient->getConnection($this->config->url->value, function ($conn) {
            $this->asteriskconn = $conn;
            if ($conn->connected) {
                $conn->bind('disconnect', function ($conn) {

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

                    \PHPDaemon\Core\Daemon::log('Connection lost... Reconnect in ' . $this->config->reconnect->value . ' sec');
                    $this->connect();
                });
            } else {
                \PHPDaemon\Core\Daemon::log(get_class($this) . ': 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->asteriskclient) {
            return $this->asteriskclient->onShutdown();
        }
        return true;
    }

    /**
     * Setting default config options
     * Overriden from AppInstance::getConfigDefaults
     * @return array|false
     */
    protected function getConfigDefaults()
    {
        return [
            'url' => 'tcp://user:password@localhost:5038',
            'reconnect' => 1,
            'asteriskclient-name' => ''
        ];
    }
}