Spike\Client\Subscriber\LoggerSubscriber

Complexity

Total Complexity

7

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Importance

Changes	1
Bugs	0	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getEvents()	0	10	1
A	onReceiveMessage()	0	4	1
A	onClientRun()	0	4	1
A	onSocketError()	0	4	1
A	onConnectionError()	0	4	1
A	onConnectToServer()	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;
use Symfony\Component\Console\Output\OutputInterface;

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

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


    public function getEvents()
    {
        return [
            EventStore::CLIENT_RUN => 'onClientRun',
            EventStore::RECEIVE_MESSAGE => 'onReceiveMessage',
            EventStore::SOCKET_ERROR => 'onSocketError',
            EventStore::CONNECTION_ERROR => 'onConnectionError',
            EventStore::CONNECT_TO_SERVER => 'onConnectToServer',
        ];
    }

    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 onSocketError(Event $event)

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

    {
        $this->logger->error("Client error.");
    }

    public function onConnectionError(Event $event)
    {
        $this->logger->warning($event->getArgument('exception')->getMessage());
    }

    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.");
    }
}