Spike\Client\Subscriber\LoggerSubscriber

Complexity

Total Complexity

10

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Importance

Changes	1
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getEvents()	0	13	1
A	onAuthError()	0	4	1
A	onRegisterTunnelError()	0	7	1
A	onDisconnectFromServer()	0	4	1
A	onReceiveMessage()	0	4	1
A	onClientRun()	0	4	1
A	onConnectionError()	0	7	1
A	onConnectToServer()	0	4	1
A	onCannotConnectToServer()	0	4	1

<?php
/**
 * Spike library
 * @author Tao <taosikai@yeah.net>
 */
namespace Spike\Client\Subscriber;

use Slince\Event\Event;
use Spike\Client\Application;
use Spike\Client\EventStore;
use Spike\Logger\Logger;

/**
 * @codeCoverageIgnore
 */
class LoggerSubscriber extends Subscriber
{
    /**
     * @var Logger
     */
    protected $logger;

    public function __construct(Application $client)
    {
        parent::__construct($client);
        $this->logger =  $client->getLogger();
    }

    /**
     * {@inheritdoc}
     */
    public function getEvents()
    {
        return [
            EventStore::CLIENT_RUN => 'onClientRun',
            EventStore::CONNECT_TO_SERVER => 'onConnectToServer',
            EventStore::CANNOT_CONNECT_TO_SERVER => 'onCannotConnectToServer',
            EventStore::RECEIVE_MESSAGE => 'onReceiveMessage',
            EventStore::CONNECTION_ERROR => 'onConnectionError',
            EventStore::AUTH_ERROR => 'onAuthError',
            EventStore::REGISTER_TUNNEL_ERROR => 'onRegisterTunnelError',
            EventStore::DISCONNECT_FROM_SERVER => 'onDisconnectFromServer'
        ];
    }

    public function onAuthError(Event $event)

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

    {
        $this->logger->error('Auth error, please checks your configuration file');
    }

    public function onRegisterTunnelError(Event $event)
    {
        $this->logger->error(sprintf('Registers the tunnel "%s" error, message: %s',
            $event->getArgument('tunnel'),
            $event->getArgument('errorMessage')
        ));
    }

    public function onDisconnectFromServer(Event $event)

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

    {
        $this->logger->error('Disconnect from the server');
    }

    public function onReceiveMessage(Event $event)
    {
        $this->logger->info("Received a message:\r\n" . $event->getArgument('message'));
    }

    public function onClientRun(Event $event)

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

    {
        $this->logger->info("The client is running ...");
    }

    public function onConnectionError(Event $event)
    {
        $this->logger->warning(sprintf('Got a bad protocol message: "%s" from "%s"',
            $event->getArgument('exception')->getMessage(),
            $event->getArgument('connection')->getRemoteAddress()
        ));
    }

    public function onConnectToServer(Event $event)

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

    {
        $this->logger->info("The client has connected to the server.");
    }

    public function onCannotConnectToServer(Event $event)

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

    {
        $this->logger->error("Cannot connect to the server. the server may not be available");
    }
}