WyriHaximus\Ratchet\Event\AuthorizeEvent

Complexity

Total Complexity

8

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	realmEvent()	0	4	1
A	create()	0	8	1
A	__construct()	0	5	1
A	getRealm()	0	4	1
A	getSession()	0	4	1
A	getActionMessage()	0	4	1
A	promise()	0	4	1
A	reject()	0	4	1

<?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\Event\Event;
use Cake\Event\EventManager;
use React\EventLoop\LoopInterface;
use React\Promise\Deferred;
use React\Promise\PromiseInterface;
use Thruway\Message\ActionMessageInterface;
use Thruway\Session;

class AuthorizeEvent extends Event
{
    const EVENT = 'WyriHaximus.Ratchet.%s.authorize';

    public static function realmEvent($realm)
    {
        return sprintf(self::EVENT, $realm);
    }

    /**
     * @var Deferred
     */
    private $deferred;

    /**
     * @param LoopInterface $loop

There is no parameter named $loop. Was it maybe removed?

     * @return static
     */
    public static function create($realm, Session $session, ActionMessageInterface $actionMsg)
    {
        return new static(self::realmEvent($realm), $actionMsg, [
            'realm' => $realm,
            'session' => $session,
            'actionMessage' => $actionMsg,
        ]);
    }

    public function __construct($name, $subject = null, $data = null)
    {
        parent::__construct($name, $subject, $data);
        $this->deferred = new Deferred();
    }

    /**
     * @return Session
     */
    public function getRealm()
    {
        return $this->data()['realm'];
    }

    /**
     * @return Session
     */
    public function getSession()
    {
        return $this->data()['session'];
    }

    /**
     * @return ActionMessageInterface
     */
    public function getActionMessage()
    {
        return $this->data()['actionMessage'];
    }

    /**
     * @return PromiseInterface
     */
    public function promise()
    {
        return $this->deferred->promise();
    }

    public function reject()
    {
        $this->deferred->reject();
    }
}