tidal / WampWatch

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 [];
     }
  

src/Tidal/WampWatch/SessionMonitor.php

Unused Use Statements -2 removed lines

@@ -8,9 +8,7 @@
  * that was distributed with this source code.
  */
 use Phaim\Server\Wamp\Util;
-use Thruway\ClientSession;
 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((array_search($sessionId, $this->sessionIds)) === false) {
+            if ((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]);
             }
         );