WyriHaximus\Ratchet\Event\ConstructListener

Complexity

Total Complexity

5

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	implementedEvents()	0	6	1
A	construct()	0	21	2
A	setUpRealm()	0	12	2

<?php

/*
 * This file is part of Ratchet.
 *
 ** (c) 2016 Cees-Jan Kiewiet
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace WyriHaximus\Ratchet\Event;

use Cake\Core\Configure;
use Cake\Event\EventListenerInterface;
use Cake\Event\EventManager;
use React\EventLoop\LoopInterface;
use Thruway\Authentication\AuthenticationManager;
use Thruway\Peer\Router;
use Thruway\Transport\RatchetTransportProvider;
use WyriHaximus\Ratchet\Security\AuthorizationManager;
use WyriHaximus\Ratchet\Security\JWTAuthProvider;
use WyriHaximus\Ratchet\Security\WampCraAuthProvider;
use WyriHaximus\Ratchet\Websocket\InternalClient;

final class ConstructListener implements EventListenerInterface
{
    /**
     * @var Router
     */
    private $router;

    /**
     * @var LoopInterface
     */
    private $loop;

    /**
     * @return array
     */
    public function implementedEvents()
    {
        return [
            ConstructEvent::EVENT => 'construct',
        ];
    }

    /**
     * @param ConstructEvent $event
     */
    public function construct(ConstructEvent $event)
    {
        $this->loop = $event->getLoop();
        $this->router = new Router($this->loop);

        $this->router->registerModule(new AuthenticationManager());

        foreach (Configure::read('WyriHaximus.Ratchet.realms') as $realm => $config) {
            $this->setUpRealm($realm, $config, $event->getEventManager());
        }
        $this->router->addTransportProvider(
            new RatchetTransportProvider(
                Configure::read('WyriHaximus.Ratchet.internal.address'),
                Configure::read('WyriHaximus.Ratchet.internal.port')
            )
        );

        $event->getEventManager()->dispatch(WebsocketStartEvent::create($this->loop));

        $this->router->start(false);
    }

    protected function setUpRealm($realm, array $config, EventManager $eventManager)
    {
        $internalClient = new InternalClient($realm, $this->loop);
        $internalClient->setEventManager($eventManager);
        $this->router->addInternalClient($internalClient);
        if (!\igorw\get_in($config, ['auth'], false)) {
            return;
        }

        $this->router->registerModule(new AuthorizationManager($realm, $this->loop));
        $this->router->addInternalClient((new JWTAuthProvider([$realm], $this->loop))->setKey($config['auth_key']));
    }
}