beyondcode / laravel-websockets

src/Dashboard/Http/Controllers/ShowStatistics.php

Spacing +2 added lines, -2 removed lines

@@ -16,13 +16,13 @@
      */
     public function __invoke(Request $request, $appId)
     {
-        $processQuery = function ($query) use ($appId) {
+        $processQuery = function($query) use ($appId) {
             return $query->whereAppId($appId)
                 ->latest()
                 ->limit(120);
         };
 
-        $processCollection = function ($collection) {
+        $processCollection = function($collection) {
             return $collection->reverse();
         };
 

src/API/Controller.php

Spacing +8 added lines, -8 removed lines

@@ -79,7 +79,7 @@ 
 
         $this->requestBuffer = (string) $request->getBody();
 
-        if (! $this->verifyContentLength()) {
+        if (!$this->verifyContentLength()) {
             return;
         }
 
@@ -97,7 +97,7 @@ 
     {
         $this->requestBuffer .= $msg;
 
-        if (! $this->verifyContentLength()) {
+        if (!$this->verifyContentLength()) {
             return;
         }
 
@@ -124,7 +124,7 @@ 
      */
     public function onError(ConnectionInterface $connection, Exception $exception)
     {
-        if (! $exception instanceof HttpException) {
+        if (!$exception instanceof HttpException) {
             return;
         }
 
@@ -145,7 +145,7 @@ 
      */
     protected function findContentLength(array $headers): int
     {
-        return Collection::make($headers)->first(function ($values, $header) {
+        return Collection::make($headers)->first(function($values, $header) {
             return strtolower($header) === 'content-length';
         })[0] ?? 0;
     }
@@ -180,7 +180,7 @@ 
 
         $this
             ->ensureValidAppId($laravelRequest->appId)
-            ->then(function ($app) use ($laravelRequest, $connection) {
+            ->then(function($app) use ($laravelRequest, $connection) {
                 try {
                     $this->ensureValidSignature($app, $laravelRequest);
                 } catch (HttpException $exception) {
@@ -200,7 +200,7 @@ 
 
                 // Allow for async IO in the controller action
                 if ($response instanceof PromiseInterface) {
-                    $response->then(function ($response) use ($connection) {
+                    $response->then(function($response) use ($connection) {
                         $this->sendAndClose($connection, $response);
                     });
 
@@ -242,8 +242,8 @@ 
         $deferred = new Deferred();
 
         App::findById($appId)
-            ->then(function ($app) use ($appId, $deferred) {
-                if (! $app) {
+            ->then(function($app) use ($appId, $deferred) {
+                if (!$app) {
                     throw new HttpException(401, "Unknown app id `{$appId}` provided.");
                 }
                 $deferred->resolve($app);

src/API/TriggerEvent.php

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
             $deferred = new Deferred();
 
             $this->ensureValidAppId($request->appId)
-                ->then(function ($app) use ($request, $channelName, $deferred) {
+                ->then(function($app) use ($request, $channelName, $deferred) {
                     if ($app->statisticsEnabled) {
                         StatisticsCollector::apiMessage($request->appId);
                     }

src/Statistics/Statistic.php

Spacing +1 added lines, -1 removed lines

@@ -126,7 +126,7 @@
     {
         $deferred = new Deferred();
 
-        App::findById($this->appId)->then(function ($app) use ($deferred) {
+        App::findById($this->appId)->then(function($app) use ($deferred) {
             $deferred->resolve($app->statisticsEnabled);
         });
 

src/Statistics/Collectors/MemoryCollector.php

Spacing +5 added lines, -5 removed lines

@@ -90,10 +90,10 @@ 
      */
     public function save()
     {
-        $this->getStatistics()->then(function ($statistics) {
+        $this->getStatistics()->then(function($statistics) {
             foreach ($statistics as $appId => $statistic) {
-                $statistic->isEnabled()->then(function ($isEnabled) use ($appId, $statistic) {
-                    if (! $isEnabled) {
+                $statistic->isEnabled()->then(function($isEnabled) use ($appId, $statistic) {
+                    if (!$isEnabled) {
                         return;
                     }
 
@@ -107,7 +107,7 @@ 
 
                     $this->channelManager
                         ->getGlobalConnectionsCount($appId)
-                        ->then(function ($connections) use ($statistic) {
+                        ->then(function($connections) use ($statistic) {
                             $statistic->reset(
                                 is_null($connections) ? 0 : $connections
                             );
@@ -170,7 +170,7 @@ 
      */
     protected function findOrMake($appId): Statistic
     {
-        if (! isset($this->statistics[$appId])) {
+        if (!isset($this->statistics[$appId])) {
             $this->statistics[$appId] = Statistic::new($appId);
         }
 

src/Console/Commands/StartServer.php

Spacing +16 added lines, -16 removed lines

@@ -72,7 +72,7 @@ 
      */
     public function handle()
     {
-        $this->laravel->singleton(LoopInterface::class, function () {
+        $this->laravel->singleton(LoopInterface::class, function() {
             return $this->loop;
         });
 
@@ -113,7 +113,7 @@ 
      */
     protected function configureManagers()
     {
-        $this->laravel->singleton(ChannelManager::class, function ($app) {
+        $this->laravel->singleton(ChannelManager::class, function($app) {
             $config = $app['config']['websockets'];
             $mode = $config['replication']['mode'] ?? 'local';
 
@@ -131,10 +131,10 @@ 
      */
     protected function configureStatistics()
     {
-        if (! $this->option('disable-statistics')) {
+        if (!$this->option('disable-statistics')) {
             $intervalInSeconds = $this->option('statistics-interval') ?: config('websockets.statistics.interval_in_seconds', 3600);
 
-            $this->loop->addPeriodicTimer($intervalInSeconds, function () {
+            $this->loop->addPeriodicTimer($intervalInSeconds, function() {
                 $this->line('Saving statistics...', null, OutputInterface::VERBOSITY_VERBOSE);
 
                 StatisticsCollectorFacade::save();
@@ -151,7 +151,7 @@ 
     {
         $this->lastRestart = $this->getLastRestart();
 
-        $this->loop->addPeriodicTimer(10, function () {
+        $this->loop->addPeriodicTimer(10, function() {
             if ($this->getLastRestart() !== $this->lastRestart) {
                 $this->triggerSoftShutdown();
             }
@@ -180,17 +180,17 @@ 
         // to receive new connections, close the current connections,
         // then stopping the loop.
 
-        if (! extension_loaded('pcntl')) {
+        if (!extension_loaded('pcntl')) {
             return;
         }
 
-        $this->loop->addSignal(SIGTERM, function () {
+        $this->loop->addSignal(SIGTERM, function() {
             $this->line('Closing existing connections...');
 
             $this->triggerSoftShutdown();
         });
 
-        $this->loop->addSignal(SIGINT, function () {
+        $this->loop->addSignal(SIGINT, function() {
             $this->line('Closing existing connections...');
 
             $this->triggerSoftShutdown();
@@ -205,7 +205,7 @@ 
      */
     protected function configurePongTracker()
     {
-        $this->loop->addPeriodicTimer(10, function () {
+        $this->loop->addPeriodicTimer(10, function() {
             $this->laravel
                 ->make(ChannelManager::class)
                 ->removeObsoleteConnections();
@@ -219,7 +219,7 @@ 
      */
     protected function configureHttpLogger()
     {
-        $this->laravel->singleton(HttpLogger::class, function ($app) {
+        $this->laravel->singleton(HttpLogger::class, function($app) {
             return (new HttpLogger($this->output))
                 ->enable($this->option('debug') ?: ($app['config']['app']['debug'] ?? false))
                 ->verbose($this->output->isVerbose());
@@ -233,7 +233,7 @@ 
      */
     protected function configureMessageLogger()
     {
-        $this->laravel->singleton(WebSocketsLogger::class, function ($app) {
+        $this->laravel->singleton(WebSocketsLogger::class, function($app) {
             return (new WebSocketsLogger($this->output))
                 ->enable($this->option('debug') ?: ($app['config']['app']['debug'] ?? false))
                 ->verbose($this->output->isVerbose());
@@ -247,7 +247,7 @@ 
      */
     protected function configureConnectionLogger()
     {
-        $this->laravel->bind(ConnectionLogger::class, function ($app) {
+        $this->laravel->bind(ConnectionLogger::class, function($app) {
             return (new ConnectionLogger($this->output))
                 ->enable($app['config']['app']['debug'] ?? false)
                 ->verbose($this->output->isVerbose());
@@ -319,16 +319,16 @@ 
         // Get all local connections and close them. They will
         // be automatically be unsubscribed from all channels.
         $channelManager->getLocalConnections()
-            ->then(function ($connections) {
-                return all(collect($connections)->map(function ($connection) {
+            ->then(function($connections) {
+                return all(collect($connections)->map(function($connection) {
                     return app('websockets.handler')
                         ->onClose($connection)
-                        ->then(function () use ($connection) {
+                        ->then(function() use ($connection) {
                             $connection->close();
                         });
                 })->toArray());
             })
-            ->then(function () {
+            ->then(function() {
                 $this->loop->stop();
             });
     }

src/ChannelManagers/RedisChannelManager.php

Spacing +32 added lines, -32 removed lines

@@ -73,7 +73,7 @@ 
         $this->publishClient = $factory->createLazyClient($connectionUri);
         $this->subscribeClient = $factory->createLazyClient($connectionUri);
 
-        $this->subscribeClient->on('message', function ($channel, $payload) {
+        $this->subscribeClient->on('message', function($channel, $payload) {
             $this->onMessage($channel, $payload);
         });
     }
@@ -101,7 +101,7 @@ 
     public function unsubscribeFromAllChannels(ConnectionInterface $connection): PromiseInterface
     {
         return $this->getGlobalChannels($connection->app->id)
-            ->then(function ($channels) use ($connection) {
+            ->then(function($channels) use ($connection) {
                 $promises = [];
                 foreach ($channels as $channel) {
                     $promises[] = $this->unsubscribeFromChannel($connection, $channel, new stdClass);
@@ -109,7 +109,7 @@ 
 
                 return all($promises);
             })
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 return parent::unsubscribeFromAllChannels($connection);
             });
     }
@@ -125,16 +125,16 @@ 
     public function subscribeToChannel(ConnectionInterface $connection, string $channelName, stdClass $payload): PromiseInterface
     {
         return $this->subscribeToTopic($connection->app->id, $channelName)
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 return $this->addConnectionToSet($connection, Carbon::now());
             })
-            ->then(function () use ($connection, $channelName) {
+            ->then(function() use ($connection, $channelName) {
                 return $this->addChannelToSet($connection->app->id, $channelName);
             })
-            ->then(function () use ($connection, $channelName) {
+            ->then(function() use ($connection, $channelName) {
                 return $this->incrementSubscriptionsCount($connection->app->id, $channelName, 1);
             })
-            ->then(function () use ($connection, $channelName, $payload) {
+            ->then(function() use ($connection, $channelName, $payload) {
                 return parent::subscribeToChannel($connection, $channelName, $payload);
             });
     }
@@ -150,7 +150,7 @@ 
     public function unsubscribeFromChannel(ConnectionInterface $connection, string $channelName, stdClass $payload): PromiseInterface
     {
         return $this->getGlobalConnectionsCount($connection->app->id, $channelName)
-            ->then(function ($count) use ($connection, $channelName) {
+            ->then(function($count) use ($connection, $channelName) {
                 if ($count === 0) {
                     // Make sure to not stay subscribed to the PubSub topic
                     // if there are no connections.
@@ -159,9 +159,9 @@ 
 
                 return Helpers::createFulfilledPromise(null);
             })
-            ->then(function () use ($connection, $channelName) {
+            ->then(function() use ($connection, $channelName) {
                 return $this->decrementSubscriptionsCount($connection->app->id, $channelName)
-                    ->then(function ($count) use ($connection, $channelName) {
+                    ->then(function($count) use ($connection, $channelName) {
                         // If the total connections count gets to 0 after unsubscribe,
                         // try again to check & unsubscribe from the PubSub topic if needed.
                         if ($count < 1) {
@@ -174,10 +174,10 @@ 
                         }
                     });
             })
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 return $this->removeConnectionFromSet($connection);
             })
-            ->then(function () use ($connection, $channelName, $payload) {
+            ->then(function() use ($connection, $channelName, $payload) {
                 return parent::unsubscribeFromChannel($connection, $channelName, $payload);
             });
     }
@@ -192,7 +192,7 @@ 
     public function subscribeToApp($appId): PromiseInterface
     {
         return $this->subscribeToTopic($appId)
-            ->then(function () use ($appId) {
+            ->then(function() use ($appId) {
                 return $this->incrementSubscriptionsCount($appId);
             });
     }
@@ -207,7 +207,7 @@ 
     public function unsubscribeFromApp($appId): PromiseInterface
     {
         return $this->unsubscribeFromTopic($appId)
-            ->then(function () use ($appId) {
+            ->then(function() use ($appId) {
                 return $this->decrementSubscriptionsCount($appId);
             });
     }
@@ -224,7 +224,7 @@ 
     {
         return $this->publishClient
             ->hget($this->getStatsRedisHash($appId, $channelName), 'connections')
-            ->then(function ($count) {
+            ->then(function($count) {
                 return is_null($count) ? 0 : (int) $count;
             });
     }
@@ -247,7 +247,7 @@ 
 
         return $this->publishClient
             ->publish($this->getRedisTopicName($appId, $channel), json_encode($payload))
-            ->then(function () use ($appId, $socketId, $channel, $payload, $serverId) {
+            ->then(function() use ($appId, $socketId, $channel, $payload, $serverId) {
                 return parent::broadcastAcrossServers($appId, $socketId, $channel, $payload, $serverId);
             });
     }
@@ -264,10 +264,10 @@ 
     public function userJoinedPresenceChannel(ConnectionInterface $connection, stdClass $user, string $channel, stdClass $payload): PromiseInterface
     {
         return $this->storeUserData($connection->app->id, $channel, $connection->socketId, json_encode($user))
-            ->then(function () use ($connection, $channel, $user) {
+            ->then(function() use ($connection, $channel, $user) {
                 return $this->addUserSocket($connection->app->id, $channel, $user, $connection->socketId);
             })
-            ->then(function () use ($connection, $user, $channel, $payload) {
+            ->then(function() use ($connection, $user, $channel, $payload) {
                 return parent::userJoinedPresenceChannel($connection, $user, $channel, $payload);
             });
     }
@@ -284,10 +284,10 @@ 
     public function userLeftPresenceChannel(ConnectionInterface $connection, stdClass $user, string $channel): PromiseInterface
     {
         return $this->removeUserData($connection->app->id, $channel, $connection->socketId)
-            ->then(function () use ($connection, $channel, $user) {
+            ->then(function() use ($connection, $channel, $user) {
                 return $this->removeUserSocket($connection->app->id, $channel, $user, $connection->socketId);
             })
-            ->then(function () use ($connection, $user, $channel) {
+            ->then(function() use ($connection, $user, $channel) {
                 return parent::userLeftPresenceChannel($connection, $user, $channel);
             });
     }
@@ -303,8 +303,8 @@ 
     {
         return $this->publishClient
             ->hgetall($this->getUsersRedisHash($appId, $channel))
-            ->then(function ($list) {
-                return collect(Helpers::redisListToArray($list))->map(function ($user) {
+            ->then(function($list) {
+                return collect(Helpers::redisListToArray($list))->map(function($user) {
                     return json_decode($user);
                 })->unique('user_id')->toArray();
             });
@@ -342,7 +342,7 @@ 
         }
 
         return $this->publishClient->exec()
-            ->then(function ($data) use ($channelNames) {
+            ->then(function($data) use ($channelNames) {
                 return array_combine($channelNames, $data);
             });
     }
@@ -372,7 +372,7 @@ 
     {
         // This will update the score with the current timestamp.
         return $this->addConnectionToSet($connection, Carbon::now())
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 $payload = [
                     'socketId' => $connection->socketId,
                     'appId' => $connection->app->id,
@@ -382,7 +382,7 @@ 
                 return $this->publishClient
                     ->publish($this->getPongRedisHash($connection->app->id), json_encode($payload));
             })
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 return parent::connectionPonged($connection);
             });
     }
@@ -394,9 +394,9 @@ 
      */
     public function removeObsoleteConnections(): PromiseInterface
     {
-        return $this->lock()->get(function () {
+        return $this->lock()->get(function() {
             return $this->getConnectionsFromSet(0, now()->subMinutes(2)->format('U'))
-                ->then(function ($connections) {
+                ->then(function($connections) {
                     $promises = [];
                     foreach ($connections as $socketId => $appId) {
                         $connection = $this->fakeConnectionForApp($appId, $socketId);
@@ -406,7 +406,7 @@ 
 
                     return all($promises);
                 });
-        })->then(function () {
+        })->then(function() {
             return parent::removeObsoleteConnections();
         });
     }
@@ -434,7 +434,7 @@ 
 
         $payload->channel = Str::after($redisChannel, "{$payload->appId}:");
 
-        if (! $channel = $this->find($payload->appId, $payload->channel)) {
+        if (!$channel = $this->find($payload->appId, $payload->channel)) {
             return;
         }
 
@@ -459,7 +459,7 @@ 
 
     public function find($appId, string $channel)
     {
-        if (! $channelInstance = parent::find($appId, $channel)) {
+        if (!$channelInstance = parent::find($appId, $channel)) {
             $class = $this->getChannelClassName($channel);
             $this->channels[$appId][$channel] = new $class($channel);
         }
@@ -602,8 +602,8 @@ 
 
         return $this->publishClient
             ->zrangebyscore($this->getSocketsRedisHash(), $start, $stop)
-            ->then(function ($list) {
-                return collect($list)->mapWithKeys(function ($appWithSocket) {
+            ->then(function($list) {
+                return collect($list)->mapWithKeys(function($appWithSocket) {
                     [$appId, $socketId] = explode(':', $appWithSocket);
 
                     return [$socketId => $appId];

src/ChannelManagers/LocalChannelManager.php

Spacing +20 added lines, -20 removed lines

@@ -103,7 +103,7 @@ 
      */
     public function findOrCreate($appId, string $channel)
     {
-        if (! $channelInstance = $this->find($appId, $channel)) {
+        if (!$channelInstance = $this->find($appId, $channel)) {
             $class = $this->getChannelClassName($channel);
 
             $this->channels[$appId][$channel] = new $class($channel);
@@ -121,11 +121,11 @@ 
     public function getLocalConnections(): PromiseInterface
     {
         $connections = collect($this->channels)
-            ->map(function ($channelsWithConnections, $appId) {
+            ->map(function($channelsWithConnections, $appId) {
                 return collect($channelsWithConnections)->values();
             })
             ->values()->collapse()
-            ->map(function ($channel) {
+            ->map(function($channel) {
                 return collect($channel->getConnections());
             })
             ->values()->collapse()
@@ -168,28 +168,28 @@ 
      */
     public function unsubscribeFromAllChannels(ConnectionInterface $connection): PromiseInterface
     {
-        if (! isset($connection->app)) {
+        if (!isset($connection->app)) {
             return Helpers::createFulfilledPromise(false);
         }
 
         $this->getLocalChannels($connection->app->id)
-            ->then(function ($channels) use ($connection) {
+            ->then(function($channels) use ($connection) {
                 collect($channels)
-                    ->each(function (Channel $channel) use ($connection) {
+                    ->each(function(Channel $channel) use ($connection) {
                         $channel->unsubscribe($connection);
                     });
 
                 collect($channels)
-                    ->reject(function ($channel) {
+                    ->reject(function($channel) {
                         return $channel->hasConnections();
                     })
-                    ->each(function (Channel $channel, string $channelName) use ($connection) {
+                    ->each(function(Channel $channel, string $channelName) use ($connection) {
                         unset($this->channels[$connection->app->id][$channelName]);
                     });
             });
 
         $this->getLocalChannels($connection->app->id)
-            ->then(function ($channels) use ($connection) {
+            ->then(function($channels) use ($connection) {
                 if (count($channels) === 0) {
                     unset($this->channels[$connection->app->id]);
                 }
@@ -265,13 +265,13 @@ 
     public function getLocalConnectionsCount($appId, string $channelName = null): PromiseInterface
     {
         return $this->getLocalChannels($appId)
-            ->then(function ($channels) use ($channelName) {
-                return collect($channels)->when(! is_null($channelName), function ($collection) use ($channelName) {
-                    return $collection->filter(function (Channel $channel) use ($channelName) {
+            ->then(function($channels) use ($channelName) {
+                return collect($channels)->when(!is_null($channelName), function($collection) use ($channelName) {
+                    return $collection->filter(function(Channel $channel) use ($channelName) {
                         return $channel->getName() === $channelName;
                     });
                 })
-                    ->flatMap(function (Channel $channel) {
+                    ->flatMap(function(Channel $channel) {
                         return collect($channel->getConnections())->pluck('socketId');
                     })
                     ->unique()->count();
@@ -363,7 +363,7 @@ 
     {
         $members = $this->users["{$appId}:{$channel}"] ?? [];
 
-        $members = collect($members)->map(function ($user) {
+        $members = collect($members)->map(function($user) {
             return json_decode($user);
         })->unique('user_id')->toArray();
 
@@ -394,7 +394,7 @@ 
     public function getChannelsMembersCount($appId, array $channelNames): PromiseInterface
     {
         $results = collect($channelNames)
-            ->reduce(function ($results, $channel) use ($appId) {
+            ->reduce(function($results, $channel) use ($appId) {
                 $results[$channel] = isset($this->users["{$appId}:{$channel}"])
                     ? count($this->users["{$appId}:{$channel}"])
                     : 0;
@@ -438,9 +438,9 @@ 
      */
     public function removeObsoleteConnections(): PromiseInterface
     {
-        return $this->lock()->get(function () {
+        return $this->lock()->get(function() {
             return $this->getLocalConnections()
-                ->then(function ($connections) {
+                ->then(function($connections) {
                     $promises = [];
 
                     foreach ($connections as $connection) {
@@ -452,7 +452,7 @@ 
                     }
 
                     return all($promises);
-                })->then(function () {
+                })->then(function() {
                     $this->lock()->release();
                 });
         });
@@ -467,7 +467,7 @@ 
     public function pongConnectionInChannels(ConnectionInterface $connection): PromiseInterface
     {
         return $this->getLocalChannels($connection->app->id)
-            ->then(function ($channels) use ($connection) {
+            ->then(function($channels) use ($connection) {
                 foreach ($channels as $channel) {
                     if ($conn = $channel->getConnection($connection->socketId)) {
                         $conn->lastPongedAt = Carbon::now();
@@ -488,7 +488,7 @@ 
     public function updateConnectionInChannels($connection): PromiseInterface
     {
         return $this->getLocalChannels($connection->app->id)
-            ->then(function ($channels) use ($connection) {
+            ->then(function($channels) use ($connection) {
                 foreach ($channels as $channel) {
                     if ($channel->hasConnection($connection)) {
                         $channel->saveConnection($connection);

src/Server/WebSocketHandler.php

Spacing +12 added lines, -12 removed lines

@@ -46,12 +46,12 @@ 
      */
     public function onOpen(ConnectionInterface $connection)
     {
-        if (! $this->connectionCanBeMade($connection)) {
+        if (!$this->connectionCanBeMade($connection)) {
             return $connection->close();
         }
 
         $this->verifyAppKey($connection)
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 try {
                     $this->verifyOrigin($connection)
                         ->limitConcurrentConnections($connection)
@@ -80,7 +80,7 @@ 
                 } catch (WebSocketException $exception) {
                     $this->onError($connection, $exception);
                 }
-            }, function ($exception) use ($connection) {
+            }, function($exception) use ($connection) {
                 $this->onError($connection, $exception);
             });
     }
@@ -94,7 +94,7 @@ 
      */
     public function onMessage(ConnectionInterface $connection, MessageInterface $message)
     {
-        if (! isset($connection->app)) {
+        if (!isset($connection->app)) {
             return;
         }
 
@@ -123,7 +123,7 @@ 
     {
         return $this->channelManager
             ->unsubscribeFromAllChannels($connection)
-            ->then(function (bool $unsubscribed) use ($connection) {
+            ->then(function(bool $unsubscribed) use ($connection) {
                 if (isset($connection->app)) {
                     if ($connection->app->statisticsEnabled) {
                         StatisticsCollector::disconnection($connection->app->id);
@@ -134,7 +134,7 @@ 
 
                 return Helpers::createFulfilledPromise(true);
             })
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 if (isset($connection->app)) {
                     DashboardLogger::log($connection->app->id, DashboardLogger::TYPE_DISCONNECTED, [
                         'socketId' => $connection->socketId,
@@ -188,8 +188,8 @@ 
         $appKey = $query->get('appKey');
 
         App::findByKey($appKey)
-            ->then(function ($app) use ($appKey, $connection, $deferred) {
-                if (! $app) {
+            ->then(function($app) use ($appKey, $connection, $deferred) {
+                if (!$app) {
                     $deferred->reject(new Exceptions\UnknownAppKey($appKey));
                 }
 
@@ -209,7 +209,7 @@ 
      */
     protected function verifyOrigin(ConnectionInterface $connection)
     {
-        if (! $connection->app->allowedOrigins) {
+        if (!$connection->app->allowedOrigins) {
             return $this;
         }
 
@@ -217,7 +217,7 @@ 
 
         $origin = parse_url($header, PHP_URL_HOST) ?: $header;
 
-        if (! $header || ! in_array($origin, $connection->app->allowedOrigins)) {
+        if (!$header || !in_array($origin, $connection->app->allowedOrigins)) {
             throw new Exceptions\OriginNotAllowed($connection->app->key);
         }
 
@@ -232,10 +232,10 @@ 
      */
     protected function limitConcurrentConnections(ConnectionInterface $connection)
     {
-        if (! is_null($capacity = $connection->app->capacity)) {
+        if (!is_null($capacity = $connection->app->capacity)) {
             $this->channelManager
                 ->getGlobalConnectionsCount($connection->app->id)
-                ->then(function ($connectionsCount) use ($capacity, $connection) {
+                ->then(function($connectionsCount) use ($capacity, $connection) {
                     if ($connectionsCount >= $capacity) {
                         $exception = new Exceptions\ConnectionsOverCapacity;