tidal / WampWatch

src/Tidal/WampWatch/SubscriptionMonitor.php

Spacing +12 added lines, -12 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]);
             }
         );
@@ -80,13 +80,13 @@ 
 
     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);
         });
     }
@@ -115,10 +115,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 () {
+            function() {
                 $this->emit('sub', [$sessionId, $subId, [
                     'id'        => $subId,
                     'created'   => null,
@@ -138,11 +138,11 @@ 
     public function getSubscriptionDetail($subId, callable $callback)
     {
         return $this->session->call(self::SUBSCRIPTION_GET_TOPIC, [$subId])->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]);
             }
         );
@@ -151,14 +151,14 @@ 
     protected function retrieveSubscriptionIds(callback $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/MonitorTrait.php

Doc Comments +3 added lines

@@ -135,6 +135,9 @@
             : $this->subscriptionCollection = new SubscriptionCollection($this->session);
     }
 
+    /**
+     * @param string $pocedure
+     */
     protected function setInitialCall($pocedure, callable $callback)
     {
         $this->initialCallProcedure = (string)$pocedure;

Spacing +2 added lines, -2 removed lines

@@ -147,14 +147,14 @@
     protected function callInitialProcedure()
     {
         if (!isset($this->initialCallProcedure) || !isset($this->initialCallCallback)) {
-            $resolver = function (callable $resolve) {
+            $resolver = function(callable $resolve) {
                 $resolve();
             };
 
             return new  Promise($resolver);
         }
 
-        return $this->session->call($this->initialCallProcedure)->then(function ($res) {
+        return $this->session->call($this->initialCallProcedure)->then(function($res) {
             $this->initialCallDone = true;
 
             return $res;

src/Tidal/WampWatch/SessionMonitor.php

Spacing +7 added lines, -7 removed lines

@@ -69,7 +69,7 @@ 
     public function start()
     {
         $this->initSetupCalls();
-        $this->getSubscriptionCollection()->subscribe()->done(function () {
+        $this->getSubscriptionCollection()->subscribe()->done(function() {
             $this->checkStarted();
         });
         $this->retrieveSessionIds();
@@ -102,13 +102,13 @@ 
     public function getSessionInfo($sessionId, callable $callback = null)
     {
         return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(
-            function ($res) use ($callback) {
+            function($res) use ($callback) {
                 $this->emit('info', [$res[0]]);
                 if ($callback !== null) {
                     $callback($res[0]);
                 }
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );
@@ -205,7 +205,7 @@ 
         // @var \Tidal\WampWatch\Subscription\Collection
         $collection = $this->getSubscriptionCollection();
 
-        $collection->addSubscription(self::SESSION_JOIN_TOPIC, function (array $res) {
+        $collection->addSubscription(self::SESSION_JOIN_TOPIC, function(array $res) {
             $sessionInfo = $res[0];
             if (!$this->validateSessionInfo($sessionInfo) || $this->hasSession($sessionInfo)) {
                 return;
@@ -213,7 +213,7 @@ 
             $this->addSession($sessionInfo);
         });
 
-        $collection->addSubscription(self::SESSION_LEAVE_TOPIC, function (array $res) {
+        $collection->addSubscription(self::SESSION_LEAVE_TOPIC, function(array $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();
@@ -234,7 +234,7 @@ 
         $this->session->call(self::SESSION_LIST_TOPIC, [])
             ->then(
                 $this->getSessionIdRetrievalCallback()
-            )->done(function ($res) use ($callback) {
+            )->done(function($res) use ($callback) {
                 if ($callback !== null) {
                     $callback($res);
                 }
@@ -243,7 +243,7 @@ 
 
     protected function getSessionIdRetrievalCallback()
     {
-        return function ($res) {
+        return function($res) {
             // remove our own sessionID from the tracked sessions
             $sessionIds = $this->removeOwnSessionId($res[0]);
             $this->setList($sessionIds);

src/Tidal/WampWatch/Subscription/Collection.php

Spacing +2 added lines, -2 removed lines

@@ -95,7 +95,7 @@ 
     {
         foreach (array_keys($this->subscriptions) as $topic) {
             $this->session->subscribe($topic, $this->subscriptionCallbacks[$topic])
-                ->done(function (SubscribedMessage $msg) use ($topic) {
+                ->done(function(SubscribedMessage $msg) use ($topic) {
 
                     $this->subscriptions[$topic] = $msg->getSubscriptionId();
                     $this->subscriptionPromise->notify($topic);
@@ -110,7 +110,7 @@ 
      */
     public function unsubscribe()
     {
-        $resolver = function (callable $resolve) {
+        $resolver = function(callable $resolve) {
             $resolve();
         };
         $promise = new  Promise($resolver);