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/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/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/Server/Messages/PusherClientMessage.php

Spacing +2 added lines, -2 removed lines

@@ -53,11 +53,11 @@
      */
     public function respond()
     {
-        if (! Str::startsWith($this->payload->event, 'client-')) {
+        if (!Str::startsWith($this->payload->event, 'client-')) {
             return;
         }
 
-        if (! $this->connection->app->clientMessagesEnabled) {
+        if (!$this->connection->app->clientMessagesEnabled) {
             return;
         }
 

src/Server/Messages/PusherChannelProtocolMessage.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
     {
         $this->channelManager
             ->connectionPonged($connection)
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 $connection->send(json_encode(['event' => 'pusher:pong']));
 
                 ConnectionPonged::dispatch($connection->app->id, $connection->socketId);

src/Server/Router.php

Spacing +1 added lines, -1 removed lines

@@ -175,7 +175,7 @@
     public function registerCustomRoutes()
     {
         foreach ($this->customRoutes as $method => $actions) {
-            $actions->each(function ($action, $uri) use ($method) {
+            $actions->each(function($action, $uri) use ($method) {
                 $this->{$method}($uri, $action);
             });
         }