Phaim\Server\Wamp\Monitor\SubscriptionMonitor

Complexity

Total Complexity

16

Size/Duplication

Total Lines	144
Duplicated Lines	15.97 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	1
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	start()	0	7	1
A	stop()	0	4	1
A	getSessionInfo()	0	11	1
A	getSessionIds()	0	7	2
A	startSubscriptions()	0	11	1
A	createHandler()	4	8	2
A	deleteHandler()	4	7	2
A	subHandler()	0	17	1
A	stopSubscriptions()	0	4	1
A	getSubscriptionDetail()	0	10	1
A	retrieveSubscriptionIds()	15	15	2
A	getList()	0	3	1

<?php
namespace Phaim\Server\Wamp\Monitor;

/*
 * Copyright 2015 Timo.
 *
 * For the full copyright and license information, please view the LICENSE file
 * that was distributed with this source code.
 */
use Phaim\Server\Wamp\Util;

/**
 * Description of SessionMonitor
 *
 * @author Timo
 */
class SubscriptionMonitor  
    implements 

The implements keyword must be on the same line as the class name

        MonitorInterface {

Expected 4 spaces before interface name; 8 found

   
    use MonitorTrait {
        start as doStart;
        stop as doStop;
    }

    const SUBSCRIPTION_CREATE_TOPIC   = 'wamp.subscription.on_create';
    const SUBSCRIPTION_SUB_TOPIC      = 'wamp.subscription.on_subscribe';
    const SUBSCRIPTION_UNSUB_TOPIC    = 'wamp.subscription.on_unsubscribe';
    const SUBSCRIPTION_DELETE_TOPIC   = 'wamp.subscription.on_delete';
    const SUBSCRIPTION_LIST_TOPIC     = 'wamp.subscription.list';
    const SUBSCRIPTION_LOOKUP_TOPIC   = 'wamp.subscription.lookup';
    const SUBSCRIPTION_MATCH_TOPIC    = 'wamp.subscription.match';
    const SUBSCRIPTION_GET_TOPIC      = 'wamp.subscription.get';
    const SUBSCRIPTION_SUBLIST_TOPIC  = 'wamp.subscription.list_subscribers';
    const SUBSCRIPTION_SUBCOUNT_TOPIC = 'wamp.subscription.count_subscribers';
    
    const LOOKUP_MATCH_WILDCARD       = 'wildcard';
    const LOOKUP_MATCH_PREFIX         = 'prefix';

    protected $sessionIds = [];
    protected $subscriptionIds = [];
    
    public function start() {
        $this->once('list', function(){
            $this->startSubscriptions();
            $this->doStart();
        });
        $this->retrieveSubscriptionIds();
    }

    public function stop() {
        $this->stopSubscriptions();
        $this->doStart();
    }
    
    public function getSessionInfo($sessionId, callable $callback) {
        return $this->session->call(self::SUBSCRIPTION_INFO_TOPIC, $sessionId)->then(
            function ($res)use($callback){
                $this->emit('info', $res);
                $callback($res[0]);
            },
            function ($error) {
                $this->emit('error', [$error]);
            }
        );    
    }
    
    public function getSessionIds(callable $callback) {
        if(!count($this->subscriptionIds)){
            $this->retrieveSubscriptionIds($callback);
        }else{
            $callback($this->subscriptionIds);
        }
    }
    
    protected function startSubscriptions() {
        $this->session->subscribe(self::SUBSCRIPTION_CREATE_TOPIC, function($res){
            return $this->createHandler($res);
        });
        $this->session->subscribe(self::SUBSCRIPTION_DELETE_TOPIC, function($res){
            return $this->deleteHandler($res);
        });
        $this->session->subscribe(self::SUBSCRIPTION_SUB_TOPIC, function($res){
            return $this->subHandler($res);
        });
    }
    
    protected function createHandler($res) {
        $sessionInfo = $res[0];
        $sessionId = $sessionInfo['session'];
        if(($key = array_search($sessionId, $this->subscriptionIds)) === false) {

This code seems to be duplicated across your project.

            $this->subscriptionIds[] = $sessionId;
            $this->emit('create', [$sessionInfo]);
        }
    }
    
    protected function deleteHandler($res) {
        $sessionId = $res[0];
        if(($key = array_search($sessionId, $this->subscriptionIds)) !== false) {

This code seems to be duplicated across your project.

            unset($this->subscriptionIds[$key]);
            $this->emit('delete', [$sessionId]);
        }
    }
    
    protected function subHandler($res) {
        $sessionId = $res[0];
        $subId = $res[1];
        $this->getSubscriptionDetail($subId)->then(
            function ($res)use($sessionId, $subId){    
                $this->emit('sub', [$sessionId, $subId, $res[0]]);            
            },
            function ($error) {                

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

                $this->emit('sub', [$sessionId, $subId, [

The variable $sessionId does not exist. Did you forget to declare it?

The variable $subId does not exist. Did you forget to declare it?

                    'id'        => $subId,
                    'created'   => null,
                    'uri'       => null,
                    'match'     => null
                ]]);
            }
        );    
    }


    protected function stopSubscriptions() {       
        Util::unsubscribe($this->session, self::SUBSCRIPTION_JOIN_TOPIC);
        Util::unsubscribe($this->session, self::SUBSCRIPTION_LEAVE_TOPIC);
    }
    
    public function getSubscriptionDetail($subId) {
        return $this->session->call(self::SUBSCRIPTION_GET_TOPIC, [$subId])->then(
            function ($res){

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

                    
            },
            function ($error) {

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

              
            }
        );
    }
    
    protected function retrieveSubscriptionIds($callback = null) {

This method seems to be duplicated in your project.

        return $this->session->call(self::SUBSCRIPTION_LIST_TOPIC, [])->then(
            function ($res)use($callback){
                $this->subscriptionIds = $res[0];
                $this->emit('list', [$this->subscriptionIds]);
                if($callback){
                    $callback($this->subscriptionIds);
                }
            },
            function ($error) {
                $this->emit('error', [$error]);
            }
        );  
        
    }
    
    protected function getList() {
        return $this->subscriptionIds;
    }
    
}