tidal / WampWatch

src/Tidal/WampWatch/SessionMonitor.php

Doc Comments +11 added lines

@@ -100,8 +100,15 @@ 
     }

     

     

+    /**
+     * @param callable $callback
+     */
     protected function retrieveSessionIds($callback = null) {

         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(

+
+            /**
+             * @param callable $res
+             */
             function ($res)use($callback){

                 $this->sessionIds = $res[0];

                 $this->emit('list', [$this->sessionIds]);

@@ -109,6 +116,10 @@ 
                     $callback($this->sessionIds);

                 }

             },

+
+            /**
+             * @param callable $error
+             */
             function ($error) {

                 $this->emit('error', [$error]);

             }

Unused Use Statements +1 added lines, -3 removed lines

@@ -7,10 +7,8 @@
  * For the full copyright and license information, please view the LICENSE file

  * that was distributed with this source code.

  */

-use Phaim\Server\Wamp\Util;

-use Thruway\ClientSession;

+use Phaim\Server\Wamp\Util;
 use Evenement\EventEmitterInterface;

-use Evenement\EventEmitterTrait;

 

 /**

  * Description of SessionMonitor

Spacing +13 added lines, -13 removed lines

@@ -38,7 +38,7 @@ 
 

     

     public function start() {

-        $this->once('list', function(){

+        $this->once('list', function() {

             $this->doStart();

         });     

         $this->startSubscriptions();

@@ -53,41 +53,41 @@ 
     

     public function getSessionInfo($sessionId, callable $callback) {

         return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(

-            function ($res)use($callback){

+            function($res)use($callback){

                 $this->emit('info', [$res[0]]);

                 $callback($res[0]);

             },

-            function ($error) {

+            function($error) {

                 $this->emit('error', [$error]);

             }

         );    

     }

     

     public function getSessionIds(callable $callback) {

-        if(!count($this->sessionIds)){

+        if (!count($this->sessionIds)) {

             $this->retrieveSessionIds($callback);

-        }else{

+        }else {

             $callback($this->sessionIds);

         }

     }

     

     protected function startSubscriptions() { 

-        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function($res){

+        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function($res) {

             $sessionInfo = $res[0];

             $sessionId = $sessionInfo['session'];

-            if(($key = array_search($sessionId, $this->sessionIds)) === false) {

+            if (($key = array_search($sessionId, $this->sessionIds)) === false) {

                 $this->sessionIds[] = $sessionId;

                 $this->emit('join', [$sessionInfo]);

             }

-        })->then(function(){

+        })->then(function() {

             

         });

-        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function($res){

+        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function($res) {

             // @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) {

+            if (($key = array_search($sessionId, $this->sessionIds)) !== false) {

                 unset($this->sessionIds[$key]);

                 $this->emit('leave', [$sessionId]);

             }

@@ -102,14 +102,14 @@ 
     

     protected function retrieveSessionIds($callback = null) {

         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(

-            function ($res)use($callback){

+            function($res)use($callback){

                 $this->sessionIds = $res[0];

                 $this->emit('list', [$this->sessionIds]);

-                if($callback){

+                if ($callback) {

                     $callback($this->sessionIds);

                 }

             },

-            function ($error) {

+            function($error) {

                 $this->emit('error', [$error]);

             }

         );  

Braces +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
     public function getSessionIds(callable $callback) {

         if(!count($this->sessionIds)){

             $this->retrieveSessionIds($callback);

-        }else{

+        } else{

             $callback($this->sessionIds);

         }

     }

src/Tidal/WampWatch/Util.php

Unused Use Statements +3 added lines, -3 removed lines

@@ -8,9 +8,9 @@
  * that was distributed with this source code.

  */

 

-use Thruway\Common\Utils;

-use Thruway\ClientSession;

-use Thruway\Message\UnsubscribedMessage;

+use Thruway\Common\Utils;
+use Thruway\ClientSession;
+use Thruway\Message\UnsubscribedMessage;
 use React\Promise\Deferred;

 

 /**

src/Tidal/WampWatch/MonitorTrait.php

Spacing +2 added lines, -2 removed lines

@@ -62,7 +62,7 @@ 
      * @return boolean
      */ 
     public function stop() {
-        if(!$this->isRunning()){
+        if (!$this->isRunning()) {
             return false;
         }
         $this->isRunning = false;
@@ -71,7 +71,7 @@ 
         return true;
     }
     
-    protected function getList(){
+    protected function getList() {
         return [];
     }