tidal / WampWatch

src/Tidal/WampWatch/SessionMonitor.php

Spacing +10 added lines, -10 removed lines

@@ -53,7 +53,7 @@ 
      */
     public function start()
     {
-        $this->once('list', function () {
+        $this->once('list', function() {
             $this->doStart();
         });
         $this->startSubscriptions();
@@ -87,11 +87,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]);
             }
         );
@@ -109,7 +109,7 @@ 
     {
         if (!count($this->sessionIds)) {
             $this->retrieveSessionIds($callback);
-        } else {
+        }else {
             $callback($this->sessionIds);
         }
     }
@@ -119,7 +119,7 @@ 
      */
     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) {
@@ -127,7 +127,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();
@@ -156,16 +156,16 @@ 
     protected function retrieveSessionIds(callable $callback = null)
     {
         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(
-            function ($res) use ($callback) {
+            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){
+                if ($callback !== null) {
                     $callback($this->sessionIds);
                 }
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );
@@ -190,7 +190,7 @@ 
     protected function removeOwnSessionId(array $sessionsIds)
     {
         $key = array_search($this->session->getSessionId(), $sessionsIds);
-        if($key >= 0){
+        if ($key >= 0) {
             unset($sessionsIds[$key]);
         }
 

examples/thruway_internal_session_monitor/client.php

Spacing +8 added lines, -8 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-require_once realpath(__DIR__ . "/..") . "/bootstrap.php";
+require_once realpath(__DIR__."/..")."/bootstrap.php";
 
 /*
  * This file is part of the Tidal/WampWatch package.
@@ -20,37 +20,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/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/router.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-require_once realpath(__DIR__ . "/..") . "/bootstrap.php";
+require_once realpath(__DIR__."/..")."/bootstrap.php";
 require_once 'InternalSessionMonitor.php';
 
 /*

examples/crossbar_session/client.php

Spacing +4 added lines, -4 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-require_once realpath(__DIR__ . "/..") . "/bootstrap.php";
+require_once realpath(__DIR__."/..")."/bootstrap.php";
 
 /*
  * This file is part of the Tidal/WampWatch package.
@@ -26,14 +26,14 @@ 
     $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);
     }
@@ -41,7 +41,7 @@ 
 
 });
 
-$connection->on('error', function ($reason) {
+$connection->on('error', function($reason) {
     echo "The connected has closed with error: {$reason}\n";
 });
 

examples/crossbar_session/monitor.php

Spacing +9 added lines, -9 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-require_once realpath(__DIR__ . "/..") . "/bootstrap.php";
+require_once realpath(__DIR__."/..")."/bootstrap.php";
 
 /*
  * This file is part of the Tidal/WampWatch package.
@@ -31,32 +31,32 @@ 
     ]
 );
 
-$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);
     });
@@ -67,13 +67,13 @@ 
 }
 );
 
-$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/bootstrap.php

Spacing +2 added lines, -2 removed lines

@@ -1,8 +1,8 @@
 <?php
 
 ini_set('xdebug.max_nesting_level', '200');
-if (file_exists($file = realpath(__DIR__ . "/..") . '/vendor/autoload.php')) {
+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.");
 }