beyondcode / laravel-websockets

src/API/FetchChannels.php

Spacing +13 added lines, -13 removed lines

@@ -23,12 +23,12 @@ 
         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');
             }
 
-            if (in_array('socket_count', $attributes) &&  $request->has('starts_with')) {
-                if (! Str::startsWith($request->starts_with, ['presence-', 'private-'])) {
+            if (in_array('socket_count', $attributes) && $request->has('starts_with')) {
+                if (!Str::startsWith($request->starts_with, ['presence-', 'private-'])) {
                     throw new HttpException(400, 'Requests must be limited to presence and private channels in order to fetch channel data');
                 }
             }
@@ -37,11 +37,11 @@ 
         if (in_array('socket_count', $attributes)) {
             return $this->channelManager
                 ->getChannelSockets($request->appId)
-                ->then(function ($channels) use ($request) {
+                ->then(function($channels) use ($request) {
                     if (count($channels)) {
 
                         if ($request->has('starts_with')) {
-                            $channels = $channels->filter(function ($channel, $channelName) use ($request) {
+                            $channels = $channels->filter(function($channel, $channelName) use ($request) {
                                 return Str::startsWith($channelName, $request->starts_with);
                             });
                         }
@@ -50,7 +50,7 @@ 
 
                         return $this->channelManager
                             ->getChannelsSocketsCount($request->appId, $channelNames)
-                            ->then(function ($counts) use ($channels) {
+                            ->then(function($counts) use ($channels) {
                                 return [
                                     'channels' => $counts ?: new stdClass,
                                 ];
@@ -62,20 +62,20 @@ 
 
         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;
@@ -83,8 +83,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
@@ -96,7 +96,7 @@ 
                             }
 
                             return $info;
-                        })->sortBy(function ($content, $name) {
+                        })->sortBy(function($content, $name) {
                             return $name;
                         })->all();
 

src/ChannelManagers/LocalChannelManager.php

Spacing +20 added lines, -20 removed lines

@@ -109,7 +109,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);
@@ -127,11 +127,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()
@@ -188,28 +188,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]);
                 }
@@ -287,13 +287,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();
@@ -415,7 +415,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();
 
@@ -446,7 +446,7 @@ 
     public function getChannelsSocketsCount($appId, array $channelNames): PromiseInterface
     {
         $results = collect($channelNames)
-            ->reduce(function ($results, $channel) use ($appId) {
+            ->reduce(function($results, $channel) use ($appId) {
                 $results[$channel] = isset($this->channelSockets[$appId][$channel])
                     ? count($this->channelSockets[$appId][$channel])
                     : 0;
@@ -467,7 +467,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;
@@ -513,11 +513,11 @@ 
     {
         $lock = $this->lock();
         try {
-            if (! $lock->acquire()) {
+            if (!$lock->acquire()) {
                 return Helpers::createFulfilledPromise(false);
             }
 
-            $this->getLocalConnections()->then(function ($connections) {
+            $this->getLocalConnections()->then(function($connections) {
                 foreach ($connections as $connection) {
                     $differenceInSeconds = $connection->lastPongedAt->diffInSeconds(Carbon::now());
 
@@ -542,7 +542,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();
@@ -563,7 +563,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/WebSocketsServiceProvider.php

Spacing +7 added lines, -7 removed lines

@@ -69,7 +69,7 @@ 
      */
     protected function registerAsyncRedisQueueDriver()
     {
-        Queue::extend('async-redis', function () {
+        Queue::extend('async-redis', function() {
             return new AsyncRedisConnector($this->app['redis']);
         });
     }
@@ -81,14 +81,14 @@ 
      */
     protected function registerStatistics()
     {
-        $this->app->singleton(StatisticsStore::class, function ($app) {
+        $this->app->singleton(StatisticsStore::class, function($app) {
             $config = $app['config']['websockets'];
             $class = $config['statistics']['store'];
 
             return new $class;
         });
 
-        $this->app->singleton(StatisticsCollector::class, function ($app) {
+        $this->app->singleton(StatisticsCollector::class, function($app) {
             $config = $app['config']['websockets'];
             $replicationMode = $config['replication']['mode'] ?? 'local';
 
@@ -133,7 +133,7 @@ 
      */
     protected function registerRouter()
     {
-        $this->app->singleton('websockets.router', function () {
+        $this->app->singleton('websockets.router', function() {
             return new Router;
         });
     }
@@ -145,7 +145,7 @@ 
      */
     protected function registerManagers()
     {
-        $this->app->singleton(Contracts\AppManager::class, function ($app) {
+        $this->app->singleton(Contracts\AppManager::class, function($app) {
             $config = $app['config']['websockets'];
 
             return $this->app->make($config['managers']['app']);
@@ -164,7 +164,7 @@ 
             'prefix' => config('websockets.dashboard.path'),
             'as' => 'laravel-websockets.',
             'middleware' => config('websockets.dashboard.middleware', [AuthorizeDashboard::class]),
-        ], function () {
+        ], function() {
             Route::get('/', ShowDashboard::class)->name('dashboard');
             Route::get('/api/{appId}/channels', ShowChannels::class)->name('channels');
             Route::get('/api/{appId}/statistics', ShowStatistics::class)->name('statistics');
@@ -180,7 +180,7 @@ 
      */
     protected function registerDashboardGate()
     {
-        Gate::define('viewWebSocketsDashboard', function ($user = null) {
+        Gate::define('viewWebSocketsDashboard', function($user = null) {
             return $this->app->environment('local');
         });
     }