Tidal\WampWatch\SessionMonitor

Complexity

Total Complexity

16

Size/Duplication

Total Lines	179
Duplicated Lines	10.06 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	7
Bugs	1	Features	1

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	start()	0	10	1
A	stop()	0	7	1
A	getSessionInfo()	0	12	1
A	getSessionIds()	0	8	2
A	startSubscriptions()	18	21	3
A	stopSubscriptions()	0	5	1
A	retrieveSessionIds()	0	17	2
A	setList()	0	4	1
A	getList()	0	4	1
A	removeOwnSessionId()	0	9	2

<?php

namespace Tidal\WampWatch;

/*
 * Copyright 2015 Timo.
 *
 * For the full copyright and license information, please view the LICENSE file
 * that was distributed with this source code.
 */

use Evenement\EventEmitterInterface;
use Tidal\WampWatch\ClientSessionInterface as ClientSession;


/**
 * Description of SessionMonitor.
 *
 * @author Timo
 */
class SessionMonitor implements MonitorInterface, EventEmitterInterface
{
    use
        MonitorTrait {
            start as doStart;
            stop as doStop;
        }

    const SESSION_JOIN_TOPIC = 'wamp.session.on_join';
    const SESSION_LEAVE_TOPIC = 'wamp.session.on_leave';
    const SESSION_COUNT_TOPIC = 'wamp.session.count';
    const SESSION_LIST_TOPIC = 'wamp.session.list';
    const SESSION_INFO_TOPIC = 'wamp.session.get';


    protected $sessionIds = [];


    /**
     * Constructor.
     *
     * @param ClientSession $session
     */
    public function __construct(ClientSession $session)
    {
        $this->setClientSession($session);
    }

    /**
     * Start the monitor.
     *
     * @return bool
     */
    public function start()
    {
        $this->once('list', function () {
            $this->doStart();
        });
        $this->startSubscriptions();
        $this->retrieveSessionIds();

        return true;
    }

    /**
     * Stop the monitor.
     * Returns boolean wether the monitor could be started.
     *
     * @return bool
     */
    public function stop()
    {
        $this->stopSubscriptions();
        $this->doStop();

        return true;
    }

    /**
     * Retrieves the session-info for given sessionId
     * and populates it in via given callback
     *
     * @param          $sessionId
     * @param callable $callback
     * @return mixed
     */
    public function getSessionInfo($sessionId, callable $callback)
    {
        return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(
            function ($res) use ($callback) {
                $this->emit('info', [$res[0]]);
                $callback($res[0]);
            },
            function ($error) {
                $this->emit('error', [$error]);
            }
        );
    }

    /**
     * Retrieves the Ids of the sessions currently
     * registered on the wamp-router in the monitor's realm
     * and populates the data via given callback,
     *
     * @param callable $callback
     * @return mixed
     */
    public function getSessionIds(callable $callback)
    {
        if (!count($this->sessionIds)) {
            $this->retrieveSessionIds($callback);
        } else {
            $callback($this->sessionIds);
        }
    }

    /**
     * Initializes the subscription to the meta-events
     */
    protected function startSubscriptions()
    {
        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function ($res) {

This code seems to be duplicated across your project.

            $sessionInfo = $res[0];
            $sessionId = $sessionInfo->session;
            if ((array_search($sessionId, $this->sessionIds)) === false) {
                $this->sessionIds[] = $sessionId;
                $this->emit('join', [$sessionInfo]);
            }
        });
        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function ($res) {

This code seems to be duplicated across your project.

            // @bug : wamp.session.on_leave is bugged as of crossbar.io 0.11.0
            // will provide sessionID when Browser closes/reloads,
            // but not when calling connection.close();
            $sessionId = $res[0];
            if (($key = array_search($sessionId, $this->sessionIds)) !== false) {
                unset($this->sessionIds[$key]);
                $this->emit('leave', [$sessionId]);
            }
        });
    }

    /**
     * Unsubscribes from the meta-events.
     */
    protected function stopSubscriptions()
    {
        Util::unsubscribe($this->session, self::SESSION_JOIN_TOPIC);

$this->session is of type object<Tidal\WampWatch\ClientSessionInterface>, but the function expects a object<Thruway\ClientSession>.

The call to Util::unsubscribe() has too many arguments starting with self::SESSION_JOIN_TOPIC.

        Util::unsubscribe($this->session, self::SESSION_LEAVE_TOPIC);

$this->session is of type object<Tidal\WampWatch\ClientSessionInterface>, but the function expects a object<Thruway\ClientSession>.

The call to Util::unsubscribe() has too many arguments starting with self::SESSION_LEAVE_TOPIC.

    }

    /**
     * Retrieves the list of current sessionIds on the router.
     *
     * @param callable|null $callback
     */
    protected function retrieveSessionIds(callable $callback = null)
    {
        $this->session->call(self::SESSION_LIST_TOPIC, [])->then(
            function ($res) use ($callback) {
                // remove our own sessionID from the tracked sessions
                $sessionIds = $this->removeOwnSessionId($res[0]);
                $this->setList($sessionIds);
                $this->emit('list', [$this->getList()]);
                if($callback !== null){
                    $callback($this->sessionIds);
                }
            },
            function ($error) {
                $this->emit('error', [$error]);
            }
        );
    }


    protected function setList($list)
    {
        $this->sessionIds = $list;
    }

    protected function getList()
    {
        return $this->sessionIds;
    }

    /**
     * remove the sessionID of the Monitor from the list
     * @param array $sessionsIds
     * @return mixed
     */
    protected function removeOwnSessionId(array $sessionsIds)
    {
        $key = array_search($this->session->getSessionId(), $sessionsIds);
        if($key >= 0){
            unset($sessionsIds[$key]);
        }

        return $sessionsIds;
    }
}