beyondcode / laravel-websockets

src/Helpers.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
         // and the values are on odd indexes. This way, we know which
         // ones are keys and which ones are values and their get combined
         // later to form the key => value array.
-        [$keys, $values] = collect($list)->partition(function ($value, $key) {
+        [$keys, $values] = collect($list)->partition(function($value, $key) {
             return $key % 2 === 0;
         });
 

src/API/FetchChannels.php

Spacing +8 added lines, -8 removed lines

@@ -23,27 +23,27 @@ 
         if ($request->has('info')) {
             $attributes = explode(',', trim($request->info));
 
-            if (in_array('user_count', $attributes) && ! Str::startsWith($request->filter_by_prefix, 'presence-')) {
+            if (in_array('user_count', $attributes) && !Str::startsWith($request->filter_by_prefix, 'presence-')) {
                 throw new HttpException(400, 'Request must be limited to presence channels in order to fetch user_count');
             }
         }
 
         return $this->channelManager
             ->getGlobalChannels($request->appId)
-            ->then(function ($channels) use ($request, $attributes) {
-                $channels = collect($channels)->keyBy(function ($channel) {
+            ->then(function($channels) use ($request, $attributes) {
+                $channels = collect($channels)->keyBy(function($channel) {
                     return $channel instanceof Channel
                         ? $channel->getName()
                         : $channel;
                 });
 
                 if ($request->has('filter_by_prefix')) {
-                    $channels = $channels->filter(function ($channel, $channelName) use ($request) {
+                    $channels = $channels->filter(function($channel, $channelName) use ($request) {
                         return Str::startsWith($channelName, $request->filter_by_prefix);
                     });
                 }
 
-                $channelNames = $channels->map(function ($channel) {
+                $channelNames = $channels->map(function($channel) {
                     return $channel instanceof Channel
                         ? $channel->getName()
                         : $channel;
@@ -51,8 +51,8 @@ 
 
                 return $this->channelManager
                     ->getChannelsMembersCount($request->appId, $channelNames)
-                    ->then(function ($counts) use ($channels, $attributes) {
-                        $channels = $channels->map(function ($channel) use ($counts, $attributes) {
+                    ->then(function($counts) use ($channels, $attributes) {
+                        $channels = $channels->map(function($channel) use ($counts, $attributes) {
                             $info = new stdClass;
 
                             $channelName = $channel instanceof Channel
@@ -64,7 +64,7 @@ 
                             }
 
                             return $info;
-                        })->sortBy(function ($content, $name) {
+                        })->sortBy(function($content, $name) {
                             return $name;
                         })->all();
 

src/API/FetchUsers.php

Spacing +3 added lines, -3 removed lines

@@ -16,14 +16,14 @@
      */
     public function __invoke(Request $request)
     {
-        if (! Str::startsWith($request->channelName, 'presence-')) {
+        if (!Str::startsWith($request->channelName, 'presence-')) {
             return new HttpException(400, "Invalid presence channel `{$request->channelName}`");
         }
 
         return $this->channelManager
             ->getChannelMembers($request->appId, $request->channelName)
-            ->then(function ($members) {
-                $users = collect($members)->map(function ($user) {
+            ->then(function($members) {
+                $users = collect($members)->map(function($user) {
                     return ['id' => $user->user_id];
                 })->values()->toArray();
 

src/API/Controller.php

Spacing +6 added lines, -6 removed lines

@@ -85,7 +85,7 @@ 
 
         $this->requestBuffer = (string) $request->getBody();
 
-        if (! $this->verifyContentLength()) {
+        if (!$this->verifyContentLength()) {
             return;
         }
 
@@ -103,7 +103,7 @@ 
     {
         $this->requestBuffer .= $msg;
 
-        if (! $this->verifyContentLength()) {
+        if (!$this->verifyContentLength()) {
             return;
         }
 
@@ -130,7 +130,7 @@ 
      */
     public function onError(ConnectionInterface $connection, Exception $exception)
     {
-        if (! $exception instanceof HttpException) {
+        if (!$exception instanceof HttpException) {
             return;
         }
 
@@ -151,7 +151,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;
     }
@@ -192,7 +192,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);
             });
 
@@ -228,7 +228,7 @@ 
      */
     public function ensureValidAppId($appId)
     {
-        if (! $appId || ! $this->app = App::findById($appId)) {
+        if (!$appId || !$this->app = App::findById($appId)) {
             throw new HttpException(401, "Unknown app id `{$appId}` provided.");
         }
 

src/API/FetchChannel.php

Spacing +2 added lines, -2 removed lines

@@ -26,13 +26,13 @@
 
         return $this->channelManager
             ->getGlobalConnectionsCount($request->appId, $request->channelName)
-            ->then(function ($connectionsCount) use ($request) {
+            ->then(function($connectionsCount) use ($request) {
                 // For the presence channels, we need a slightly different response
                 // that need an additional call.
                 if (Str::startsWith($request->channelName, 'presence-')) {
                     return $this->channelManager
                         ->getChannelsMembersCount($request->appId, [$request->channelName])
-                        ->then(function ($channelMembers) use ($connectionsCount, $request) {
+                        ->then(function($channelMembers) use ($connectionsCount, $request) {
                             return [
                                 'occupied' => $connectionsCount > 0,
                                 'subscription_count' => $connectionsCount,

src/Statistics/Collectors/RedisCollector.php

Spacing +13 added lines, -13 removed lines

@@ -85,7 +85,7 @@ 
                 $this->channelManager->getStatsRedisHash($appId, null),
                 'current_connections_count', 1
             )
-            ->then(function ($currentConnectionsCount) use ($appId) {
+            ->then(function($currentConnectionsCount) use ($appId) {
                 // Get the peak connections count from Redis.
                 $this->channelManager
                     ->getPublishClient()
@@ -93,7 +93,7 @@ 
                         $this->channelManager->getStatsRedisHash($appId, null),
                         'peak_connections_count'
                     )
-                    ->then(function ($currentPeakConnectionCount) use ($currentConnectionsCount, $appId) {
+                    ->then(function($currentPeakConnectionCount) use ($currentConnectionsCount, $appId) {
                         // Extract the greatest number between the current peak connection count
                         // and the current connection number.
                         $peakConnectionsCount = is_null($currentPeakConnectionCount)
@@ -122,12 +122,12 @@ 
         // Decrement the current connections count by 1.
         $this->ensureAppIsInSet($appId)
             ->hincrby($this->channelManager->getStatsRedisHash($appId, null), 'current_connections_count', -1)
-            ->then(function ($currentConnectionsCount) use ($appId) {
+            ->then(function($currentConnectionsCount) use ($appId) {
                 // Get the peak connections count from Redis.
                 $this->channelManager
                     ->getPublishClient()
                     ->hget($this->channelManager->getStatsRedisHash($appId, null), 'peak_connections_count')
-                    ->then(function ($currentPeakConnectionCount) use ($currentConnectionsCount, $appId) {
+                    ->then(function($currentPeakConnectionCount) use ($currentConnectionsCount, $appId) {
                         // Extract the greatest number between the current peak connection count
                         // and the current connection number.
                         $peakConnectionsCount = is_null($currentPeakConnectionCount)
@@ -152,17 +152,17 @@ 
      */
     public function save()
     {
-        $this->lock()->get(function () {
+        $this->lock()->get(function() {
             $this->channelManager
                 ->getPublishClient()
                 ->smembers(static::$redisSetName)
-                ->then(function ($members) {
+                ->then(function($members) {
                     foreach ($members as $appId) {
                         $this->channelManager
                             ->getPublishClient()
                             ->hgetall($this->channelManager->getStatsRedisHash($appId, null))
-                            ->then(function ($list) use ($appId) {
-                                if (! $list) {
+                            ->then(function($list) use ($appId) {
+                                if (!$list) {
                                     return;
                                 }
 
@@ -178,7 +178,7 @@ 
 
                                 $this->channelManager
                                     ->getGlobalConnectionsCount($appId)
-                                    ->then(function ($currentConnectionsCount) use ($appId) {
+                                    ->then(function($currentConnectionsCount) use ($appId) {
                                         $currentConnectionsCount === 0 || is_null($currentConnectionsCount)
                                             ? $this->resetAppTraces($appId)
                                             : $this->resetStatistics($appId, $currentConnectionsCount);
@@ -196,7 +196,7 @@ 
      */
     public function flush()
     {
-        $this->getStatistics()->then(function ($statistics) {
+        $this->getStatistics()->then(function($statistics) {
             foreach ($statistics as $appId => $statistic) {
                 $this->resetAppTraces($appId);
             }
@@ -213,14 +213,14 @@ 
         return $this->channelManager
             ->getPublishClient()
             ->smembers(static::$redisSetName)
-            ->then(function ($members) {
+            ->then(function($members) {
                 $appsWithStatistics = [];
 
                 foreach ($members as $appId) {
                     $this->channelManager
                         ->getPublishClient()
                         ->hgetall($this->channelManager->getStatsRedisHash($appId, null))
-                        ->then(function ($list) use ($appId, &$appsWithStatistics) {
+                        ->then(function($list) use ($appId, &$appsWithStatistics) {
                             $appsWithStatistics[$appId] = $this->arrayToStatisticInstance(
                                 $appId, Helpers::redisListToArray($list)
                             );
@@ -242,7 +242,7 @@ 
         return $this->channelManager
             ->getPublishClient()
             ->hgetall($this->channelManager->getStatsRedisHash($appId, null))
-            ->then(function ($list) use ($appId) {
+            ->then(function($list) use ($appId) {
                 return $this->arrayToStatisticInstance(
                     $appId, Helpers::redisListToArray($list)
                 );

src/Statistics/Collectors/MemoryCollector.php

Spacing +4 added lines, -4 removed lines

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

src/Statistics/Stores/DatabaseStore.php

Spacing +5 added lines, -5 removed lines

@@ -40,7 +40,7 @@ 
     public static function delete(Carbon $moment, $appId = null): int
     {
         return static::$model::where('created_at', '<', $moment->toDateTimeString())
-            ->when(! is_null($appId), function ($query) use ($appId) {
+            ->when(!is_null($appId), function($query) use ($appId) {
                 return $query->whereAppId($appId);
             })
             ->delete();
@@ -55,9 +55,9 @@ 
     public function getRawRecords(callable $processQuery = null)
     {
         return static::$model::query()
-            ->when(! is_null($processQuery), function ($query) use ($processQuery) {
+            ->when(!is_null($processQuery), function($query) use ($processQuery) {
                 return call_user_func($processQuery, $query);
-            }, function ($query) {
+            }, function($query) {
                 return $query->latest()->limit(120);
             })->get();
     }
@@ -72,10 +72,10 @@ 
     public function getRecords(callable $processQuery = null, callable $processCollection = null): array
     {
         return $this->getRawRecords($processQuery)
-            ->when(! is_null($processCollection), function ($collection) use ($processCollection) {
+            ->when(!is_null($processCollection), function($collection) use ($processCollection) {
                 return call_user_func($processCollection, $collection);
             })
-            ->map(function (Model $statistic) {
+            ->map(function(Model $statistic) {
                 return $this->statisticToArray($statistic);
             })
             ->toArray();

src/Console/Commands/StartServer.php

Spacing +13 added lines, -13 removed lines

@@ -106,7 +106,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';
 
@@ -124,10 +124,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...');
 
                 StatisticsCollectorFacade::save();
@@ -144,7 +144,7 @@ 
     {
         $this->lastRestart = $this->getLastRestart();
 
-        $this->loop->addPeriodicTimer(10, function () {
+        $this->loop->addPeriodicTimer(10, function() {
             if ($this->getLastRestart() !== $this->lastRestart) {
                 $this->triggerSoftShutdown();
             }
@@ -173,17 +173,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();
@@ -198,7 +198,7 @@ 
      */
     protected function configurePongTracker()
     {
-        $this->loop->addPeriodicTimer(10, function () {
+        $this->loop->addPeriodicTimer(10, function() {
             $this->laravel
                 ->make(ChannelManager::class)
                 ->removeObsoleteConnections();
@@ -212,7 +212,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());
@@ -226,7 +226,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());
@@ -240,7 +240,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());
@@ -310,12 +310,12 @@ 
         // Get all local connections and close them. They will
         // be automatically be unsubscribed from all channels.
         $channelManager->getLocalConnections()
-            ->then(function ($connections) {
+            ->then(function($connections) {
                 foreach ($connections as $connection) {
                     $connection->close();
                 }
             })
-            ->then(function () {
+            ->then(function() {
                 $this->loop->stop();
             });
     }