tidal / WampWatch

src/Tidal/WampWatch/Model/Behavior/Property/HasCollectionsTrait.php

Doc Comments +3 added lines

@@ -44,6 +44,9 @@
         return $this->{$name};
     }
 
+    /**
+     * @param string $name
+     */
     private function hasCollection($name)
     {
         return property_exists($this, $name) && is_a($this->{$name}, CollectionInterface::class);

src/Tidal/WampWatch/Model/Router.php

Spacing +1 added lines, -1 removed lines

@@ -66,6 +66,6 @@
     }
 }
 
-Router::setConnectionFactory(function (Contract\RouterInterface $router, Contract\RealmInterface $realm) {
+Router::setConnectionFactory(function(Contract\RouterInterface $router, Contract\RealmInterface $realm) {
     return new Connection($router, $realm);
 });

src/Tidal/WampWatch/Adapter/React/PromiseAdapter.php

Spacing +9 added lines, -9 removed lines

@@ -56,15 +56,15 @@ 
      */
     public function then(callable $onFulfilled = null, callable $onRejected = null, callable $onProgress = null)
     {
-        $this->adaptee->then(function () use ($onFulfilled) {
+        $this->adaptee->then(function() use ($onFulfilled) {
             if ($onFulfilled !== null) {
                 return call_user_func_array($onFulfilled, func_get_args());
             }
-        }, function () use ($onRejected) {
+        }, function() use ($onRejected) {
             if ($onRejected !== null) {
                 return call_user_func_array($onRejected, func_get_args());
             }
-        }, function () use ($onProgress) {
+        }, function() use ($onProgress) {
             if ($onProgress !== null) {
                 return call_user_func_array($onProgress, func_get_args());
             }
@@ -82,15 +82,15 @@ 
      */
     public function done(callable $onFulfilled = null, callable $onRejected = null, callable $onProgress = null)
     {
-        $this->adaptee->done(function () use ($onFulfilled) {
+        $this->adaptee->done(function() use ($onFulfilled) {
             if ($onFulfilled !== null) {
                 return call_user_func_array($onFulfilled, func_get_args());
             }
-        }, function () use ($onRejected) {
+        }, function() use ($onRejected) {
             if ($onRejected !== null) {
                 return call_user_func_array($onRejected, func_get_args());
             }
-        }, function () use ($onProgress) {
+        }, function() use ($onProgress) {
             if ($onProgress !== null) {
                 return call_user_func_array($onProgress, func_get_args());
             }
@@ -106,7 +106,7 @@ 
      */
     public function otherwise(callable $onRejected)
     {
-        $this->adaptee->otherwise(function () use ($onRejected) {
+        $this->adaptee->otherwise(function() use ($onRejected) {
             return call_user_func_array($onRejected, func_get_args());
         });
 
@@ -120,7 +120,7 @@ 
      */
     public function always(callable $onAlways)
     {
-        $this->adaptee->always(function () use ($onAlways) {
+        $this->adaptee->always(function() use ($onAlways) {
             return call_user_func_array($onAlways, func_get_args());
         });
 
@@ -134,7 +134,7 @@ 
      */
     public function progress(callable $onProgress)
     {
-        $this->adaptee->progress(function () use ($onProgress) {
+        $this->adaptee->progress(function() use ($onProgress) {
             return call_user_func_array($onProgress, func_get_args());
         });
 

src/Tidal/WampWatch/Model/Factory/ConnectionFactory.php

Indentation +2 added lines, -2 removed lines

@@ -26,8 +26,8 @@
     private $session;
 
     private function __construct(RouterInterface $router,
-                                 RealmInterface $realm = null,
-                                 SessionInterface $session = null
+                                    RealmInterface $realm = null,
+                                    SessionInterface $session = null
     ) {
         $this->router = $router;
         $this->realm = $realm;

src/Tidal/WampWatch/Subscription/Collection.php

Spacing +3 added lines, -3 removed lines

@@ -98,7 +98,7 @@ 
 
     protected function doSubscribe()
     {
-        \React\Promise\all($this->getSubscriptionPromises())->done(function () {
+        \React\Promise\all($this->getSubscriptionPromises())->done(function() {
             $this->isSubscribed = true;
             $this->isSubscribing = false;
             $this->subscriptionPromise->resolve($this->subscriptions);
@@ -114,7 +114,7 @@ 
 
         foreach (array_keys($this->subscriptions) as $topic) {
             $promises[] = $this->session->subscribe($topic, $this->subscriptionCallbacks[$topic])
-                ->then(function (SubscribedMessage $msg) use ($topic) {
+                ->then(function(SubscribedMessage $msg) use ($topic) {
                     $this->subscriptions[$topic] = $msg->getSubscriptionId();
                     $this->subscriptionPromise->notify($topic);
 
@@ -130,7 +130,7 @@ 
      */
     public function unsubscribe()
     {
-        $resolver = function (callable $resolve) {
+        $resolver = function(callable $resolve) {
             $resolve();
         };
         $promise = new  Promise($resolver);

src/Tidal/WampWatch/SessionMonitor.php

Spacing +6 added lines, -6 removed lines

@@ -69,12 +69,12 @@ 
     public function getSessionInfo($sessionId)
     {
         return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(
-            function ($res) {
+            function($res) {
                 $this->emit('info', [$res]);
 
                 return $res;
             },
-            function (ErrorMessage $error) use ($sessionId) {
+            function(ErrorMessage $error) use ($sessionId) {
                 $this->emit('error', [$error, $sessionId]);
             }
         );
@@ -94,7 +94,7 @@ 
         }
 
         return $this->createPromiseAdapter(
-            function (callable $resolve) {
+            function(callable $resolve) {
                 $resolve($this->getList());
             }
         );
@@ -171,7 +171,7 @@ 
         // @var \Tidal\WampWatch\Subscription\Collection
         $collection = $this->getMetaSubscriptionCollection();
 
-        $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;
@@ -179,7 +179,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();
@@ -209,7 +209,7 @@ 
      */
     protected function getSessionIdRetrievalCallback()
     {
-        return function ($res) {
+        return function($res) {
             $this->setList($res[0]);
             $sessionIds = $this->getList();
             $this->emit('list', [$sessionIds]);

src/Tidal/WampWatch/MonitorTrait.php

Doc Comments +11 added lines, -1 removed lines

@@ -153,6 +153,9 @@ 
             : $this->metaSubscriptionCollection = new SubscriptionCollection($this->session);
     }
 
+    /**
+     * @param string $procedure
+     */
     protected function setInitialCall($procedure, callable $callback)
     {
         $this->initialCallProcedure = (string) $procedure;
@@ -192,6 +195,9 @@ 
         };
     }
 
+    /**
+     * @param string $procedure
+     */
     private function retrieveCallData($procedure, callable $filter = null, $arguments = [])
     {
         $deferred = new DeferredAdapter(
@@ -204,6 +210,10 @@ 
 
         $this->session->call($procedure, $arguments)
             ->then(
+
+                /**
+                 * @param string $res
+                 */
                 function ($res) use ($deferred, $filter) {
                     $deferred->resolve($filter($res));
                 },
@@ -228,7 +238,7 @@ 
     }
 
     /**
-     * @param $event
+     * @param string $event
      * @return \Closure
      */
     private function getSubscriptionHandler($event)

Spacing +8 added lines, -8 removed lines

@@ -82,7 +82,7 @@ 
             $this->callInitialProcedure(),
         ];
 
-        \React\Promise\all($promises)->done(function () {
+        \React\Promise\all($promises)->done(function() {
             $this->isRunning = true;
             $this->emit('start', [$this->getList()]);
         });
@@ -167,12 +167,12 @@ 
         if (!isset($this->initialCallProcedure) || !isset($this->initialCallCallback)) {
             $this->initialCallDone = true;
 
-            return new  Promise(function (callable $resolve) {
+            return new  Promise(function(callable $resolve) {
                 $resolve();
             });
         }
 
-        return $this->session->call($this->initialCallProcedure, [])->then(function ($res) {
+        return $this->session->call($this->initialCallProcedure, [])->then(function($res) {
             $this->initialCallDone = true;
             $cb = $this->initialCallCallback;
             $cb($res);
@@ -185,7 +185,7 @@ 
 
     private function getErrorCallback()
     {
-        return function ($error) {
+        return function($error) {
             $this->emit('error', [$error]);
 
             return $error;
@@ -198,13 +198,13 @@ 
             new Deferred()
         );
 
-        $filter = $filter ?: function ($res) {
+        $filter = $filter ?: function($res) {
             return $res;
         };
 
         $this->session->call($procedure, $arguments)
             ->then(
-                function ($res) use ($deferred, $filter) {
+                function($res) use ($deferred, $filter) {
                     $deferred->resolve($filter($res));
                 },
                 $this->getErrorCallback()
@@ -233,14 +233,14 @@ 
      */
     private function getSubscriptionHandler($event)
     {
-        return function ($res) use ($event) {
+        return function($res) use ($event) {
             $this->emit($event, $res);
         };
     }
 
     protected function getSubscriptionIdRetrievalCallback()
     {
-        return function (\Thruway\CallResult $res) {
+        return function(\Thruway\CallResult $res) {
             /** @var \Thruway\Message\ResultMessage $message */
             $message = $res->getResultMessage();
             $list = $message->getArguments()[0];

src/Tidal/WampWatch/SubscriptionMonitor.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
     public function getSubscriptionInfo($topic)
     {
         return $this->session->call(self::SUBSCRIPTION_GET_TOPIC, [$topic])->then(
-            function ($res) {
+            function($res) {
                 $this->emit('info', [$res]);
 
                 return $res;
@@ -73,7 +73,7 @@ 
             return $this->retrieveSubscriptionIds();
         }
 
-        return $this->createPromiseAdapter(function (callable $resolve) {
+        return $this->createPromiseAdapter(function(callable $resolve) {
             $resolve($this->subscriptionIds);
         });
     }