tidal / WampWatch

src/Tidal/WampWatch/SubscriptionMonitor.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]);

             }

Spacing +13 added lines, -13 removed lines

@@ -41,7 +41,7 @@ 
 
     public function start()
     {
-        $this->once('list', function () {
+        $this->once('list', function() {
             $this->startSubscriptions();
             $this->doStart();
         });
@@ -57,11 +57,11 @@ 
     public function getSessionInfo($sessionId, callable $callback)
     {
         return $this->session->call(self::SUBSCRIPTION_INFO_TOPIC, $sessionId)->then(
-            function ($res) use ($callback) {
+            function($res) use ($callback) {
                 $this->emit('info', $res);
                 $callback($res[0]);
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );
@@ -71,20 +71,20 @@ 
     {
         if (!count($this->subscriptionIds)) {
             $this->retrieveSubscriptionIds($callback);
-        } else {
+        }else {
             $callback($this->subscriptionIds);
         }
     }
 
     protected function startSubscriptions()
     {
-        $this->session->subscribe(self::SUBSCRIPTION_CREATE_TOPIC, function ($res) {
+        $this->session->subscribe(self::SUBSCRIPTION_CREATE_TOPIC, function($res) {
             return $this->createHandler($res);
         });
-        $this->session->subscribe(self::SUBSCRIPTION_DELETE_TOPIC, function ($res) {
+        $this->session->subscribe(self::SUBSCRIPTION_DELETE_TOPIC, function($res) {
             return $this->deleteHandler($res);
         });
-        $this->session->subscribe(self::SUBSCRIPTION_SUB_TOPIC, function ($res) {
+        $this->session->subscribe(self::SUBSCRIPTION_SUB_TOPIC, function($res) {
             return $this->subHandler($res);
         });
     }
@@ -113,10 +113,10 @@ 
         $sessionId = $res[0];
         $subId = $res[1];
         $this->getSubscriptionDetail($subId)->then(
-            function ($res) use ($sessionId,$subId) {
+            function($res) use ($sessionId, $subId) {
                 $this->emit('sub', [$sessionId, $subId, $res[0]]);
             },
-            function ($error) {
+            function($error) {
                 $this->emit('sub', [$sessionId, $subId, [
                     'id'        => $subId,
                     'created'   => null,
@@ -136,9 +136,9 @@ 
     public function getSubscriptionDetail($subId)
     {
         return $this->session->call(self::SUBSCRIPTION_GET_TOPIC, [$subId])->then(
-            function ($res) {
+            function($res) {
             },
-            function ($error) {
+            function($error) {
             }
         );
     }
@@ -146,14 +146,14 @@ 
     protected function retrieveSubscriptionIds($callback = null)
     {
         return $this->session->call(self::SUBSCRIPTION_LIST_TOPIC, [])->then(
-            function ($res) use ($callback) {
+            function($res) use ($callback) {
                 $this->subscriptionIds = $res[0];
                 $this->emit('list', [$this->subscriptionIds]);
                 if ($callback) {
                     $callback($this->subscriptionIds);
                 }
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );

src/Tidal/WampWatch/SessionMonitor.php

Spacing +8 added lines, -8 removed lines

@@ -36,7 +36,7 @@ 
 
     public function start()
     {
-        $this->once('list', function () {
+        $this->once('list', function() {
             $this->doStart();
         });
         $this->startSubscriptions();
@@ -54,11 +54,11 @@ 
     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]);
             }
         );
@@ -68,14 +68,14 @@ 
     {
         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) {
@@ -83,7 +83,7 @@ 
                 $this->emit('join', [$sessionInfo]);
             }
         });
-        $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();
@@ -104,14 +104,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) {
                     $callback($this->sessionIds);
                 }
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );

examples/thruway_internal_session_monitor/InternalSessionMonitor.php

Spacing +4 added lines, -4 removed lines

@@ -38,22 +38,22 @@
         $sessionMonitor = new SessionMonitor(new Adapter($session));
 
 
-        $sessionMonitor->on('list', function ($l) {
+        $sessionMonitor->on('list', function($l) {
             echo "\nLIST: \n";
             print_r($l);
         });
 
-        $sessionMonitor->on('join', function ($l) {
+        $sessionMonitor->on('join', function($l) {
             echo "\nJOIN: \n";
             print_r($l);
         });
 
-        $sessionMonitor->on('leave', function ($l) {
+        $sessionMonitor->on('leave', function($l) {
             echo "\nLEAVE: \n";
             print_r($l);
         });
 
-        $sessionMonitor->on('error', function ($l) {
+        $sessionMonitor->on('error', function($l) {
             echo "\nERROR: \n";
             print_r($l);
         });

examples/thruway_internal_session_monitor/client.php

Spacing +7 added lines, -7 removed lines

@@ -18,37 +18,37 @@
 $client = new Client('realm1');
 $client->addTransportProvider(new PawlTransportProvider('ws://127.0.0.1:9999/'));
 
-$client->on('open', function (ClientSession $session) {
+$client->on('open', function(ClientSession $session) {
 
     // 1) subscribe to a topic
-    $onevent = function ($args) {
+    $onevent = function($args) {
         echo "Event {$args[0]}\n";
     };
     $session->subscribe('com.myapp.hello', $onevent);
 
     // 2) publish an event
     $session->publish('com.myapp.hello', ['Hello, world from PHP!!!'], [], ['acknowledge' => true])->then(
-        function () {
+        function() {
             echo "Publish Acknowledged!\n";
         },
-        function ($error) {
+        function($error) {
             // publish failed
             echo "Publish Error {$error}\n";
         }
     );
 
     // 3) register a procedure for remoting
-    $add2 = function ($args) {
+    $add2 = function($args) {
         return $args[0] + $args[1];
     };
     $session->register('com.myapp.add2', $add2);
 
     // 4) call a remote procedure
     $session->call('com.myapp.add2', [2, 3])->then(
-        function ($res) {
+        function($res) {
             echo "Result: {$res}\n";
         },
-        function ($error) {
+        function($error) {
             echo "Call Error: {$error}\n";
         }
     );

examples/bootstrap.php

Spacing +1 added lines, -1 removed lines

@@ -3,6 +3,6 @@
 ini_set('xdebug.max_nesting_level', '200');
 if (file_exists($file = realpath(__DIR__.'/..').'/vendor/autoload.php')) {
     $loader = require_once $file;
-} else {
+}else {
     throw new RuntimeException('autoload file not found in vendor path.');
 }

examples/crossbar_session/monitor.php

Spacing +8 added lines, -8 removed lines

@@ -27,30 +27,30 @@ 
     ]
 );
 
-$connection->on('open', function (ClientSession $session) use ($connection, &$timer) {
+$connection->on('open', function(ClientSession $session) use ($connection, &$timer) {
     $sessionMonitor = new SessionMonitor(new Adapter($session));
 
 
-    $sessionMonitor->on('start', function ($l) {
+    $sessionMonitor->on('start', function($l) {
         echo "\n******** SESSION MONITOR STARTED ********\n";
         echo "\nSTART: \n";
         print_r($l);
     });
 
-    $sessionMonitor->on('list', function ($l) {
+    $sessionMonitor->on('list', function($l) {
         echo "\nLIST: \n";
         print_r($l);
     });
 
-    $sessionMonitor->on('join', function ($sessionData) {
+    $sessionMonitor->on('join', function($sessionData) {
         echo "\nJOIN: {$sessionData->session}\n";
     });
 
-    $sessionMonitor->on('leave', function ($sessionId) {
+    $sessionMonitor->on('leave', function($sessionId) {
         echo "\nLEAVE: $sessionId\n";
     });
 
-    $sessionMonitor->on('error', function ($l) {
+    $sessionMonitor->on('error', function($l) {
         echo "\nERROR: \n";
         print_r($l);
     });
@@ -59,11 +59,11 @@ 
 }
 );
 
-$connection->on('close', function ($reason) use (&$timer) {
+$connection->on('close', function($reason) use (&$timer) {
     echo "The connected has closed with reason: {$reason}\n";
 });
 
-$connection->on('error', function ($reason) {
+$connection->on('error', function($reason) {
     echo "The connected has closed with error: {$reason}\n";
 });
 

examples/crossbar_session/client.php

Spacing +3 added lines, -3 removed lines

@@ -23,19 +23,19 @@
     $loop
 );
 
-$connection->on('open', function (ClientSession $session) use ($connection, $loop, &$timer) {
+$connection->on('open', function(ClientSession $session) use ($connection, $loop, &$timer) {
     echo "\nSession established: {$session->getSessionId()}\n";
 }
 );
 
-$connection->on('close', function ($reason) use ($loop, &$timer) {
+$connection->on('close', function($reason) use ($loop, &$timer) {
     if ($timer) {
         $loop->cancelTimer($timer);
     }
     echo "The connected has closed with reason: {$reason}\n";
 });
 
-$connection->on('error', function ($reason) {
+$connection->on('error', function($reason) {
     echo "The connected has closed with error: {$reason}\n";
 });