Spike\Client\Listener\ClientListener

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	6

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	onClientAction()	0	9	1
A	createMessageHandler()	0	20	4
A	getSubscribedEvents()	0	6	1

<?php

/*
 * This file is part of the slince/spike package.
 *
 * (c) Slince <taosikai@yeah.net>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Spike\Client\Listener;

use React\Socket\ConnectionInterface;
use Slince\EventDispatcher\SubscriberInterface;
use Spike\Client\Client;
use Spike\Common\Exception\InvalidArgumentException;
use Spike\Common\Protocol\SpikeInterface;
use Spike\Client\Event\Events;
use Spike\Client\Event\FilterActionHandlerEvent;
use Spike\Client\Handler;

class ClientListener implements SubscriberInterface
{
    /**
     * {@inheritdoc}
     */
    public static function getSubscribedEvents()
    {
        return [
            Events::CLIENT_ACTION => 'onClientAction',
        ];
    }

    /**
     * @param FilterActionHandlerEvent $event
     */
    public function onClientAction(FilterActionHandlerEvent $event)
    {
        $actionHandler = $this->createMessageHandler(
            $event->getSubject(),

$event->getSubject() is of type null|object, but the function expects a object<Spike\Client\Client>.

            $event->getMessage(),
            $event->getConnection()
        );
        $event->setActionHandler($actionHandler);
    }

    /**
     * Creates the handler for the received message.
     *
     * @param Client              $client
     * @param SpikeInterface      $message
     * @param ConnectionInterface $connection
     *
     * @return Handler\ActionHandlerInterface
     * @codeCoverageIgnore
     */
    protected function createMessageHandler(Client $client, SpikeInterface $message, ConnectionInterface $connection)
    {
        switch ($message->getAction()) {
            case 'auth_response':
                $handler = new Handler\AuthResponseHandler($client, $connection);
                break;
            case 'register_tunnel_response':
                $handler = new Handler\RegisterTunnelResponseHandler($client, $connection);
                break;
            case 'request_proxy':
                $handler = new Handler\RequestProxyHandler($client, $connection);
                break;
            default:
                throw new InvalidArgumentException(sprintf('Cannot find handler for the message: "%s"',
                    $message->getAction()
                ));
        }

        return $handler;
    }
}