beyondcode / laravel-websockets

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);
             });
         }

src/Server/Loggers/Logger.php

Spacing +1 added lines, -1 removed lines

@@ -96,7 +96,7 @@
      */
     protected function warn(string $message)
     {
-        if (! $this->consoleOutput->getFormatter()->hasStyle('warning')) {
+        if (!$this->consoleOutput->getFormatter()->hasStyle('warning')) {
             $style = new OutputFormatterStyle('yellow');
 
             $this->consoleOutput->getFormatter()->setStyle('warning', $style);

src/Server/WebSocketHandler.php

Spacing +8 added lines, -8 removed lines

@@ -42,7 +42,7 @@ 
      */
     public function onOpen(ConnectionInterface $connection)
     {
-        if (! $this->connectionCanBeMade($connection)) {
+        if (!$this->connectionCanBeMade($connection)) {
             return $connection->close();
         }
 
@@ -82,7 +82,7 @@ 
      */
     public function onMessage(ConnectionInterface $connection, MessageInterface $message)
     {
-        if (! isset($connection->app)) {
+        if (!isset($connection->app)) {
             return;
         }
 
@@ -111,7 +111,7 @@ 
     {
         $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);
@@ -168,7 +168,7 @@ 
 
         $appKey = $query->get('appKey');
 
-        if (! $app = App::findByKey($appKey)) {
+        if (!$app = App::findByKey($appKey)) {
             throw new Exceptions\UnknownAppKey($appKey);
         }
 
@@ -185,7 +185,7 @@ 
      */
     protected function verifyOrigin(ConnectionInterface $connection)
     {
-        if (! $connection->app->allowedOrigins) {
+        if (!$connection->app->allowedOrigins) {
             return $this;
         }
 
@@ -193,7 +193,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);
         }
 
@@ -208,10 +208,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;
 

src/Apps/ConfigAppManager.php

Spacing +2 added lines, -2 removed lines

@@ -31,7 +31,7 @@ 
     public function all(): array
     {
         return $this->apps
-            ->map(function (array $appAttributes) {
+            ->map(function(array $appAttributes) {
                 return $this->convertIntoApp($appAttributes);
             })
             ->toArray();
@@ -84,7 +84,7 @@ 
      */
     protected function convertIntoApp(?array $appAttributes): ?App
     {
-        if (! $appAttributes) {
+        if (!$appAttributes) {
             return null;
         }
 

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/Channels/Channel.php

Spacing +4 added lines, -4 removed lines

@@ -120,7 +120,7 @@ 
      */
     public function unsubscribe(ConnectionInterface $connection): bool
     {
-        if (! $this->hasConnection($connection)) {
+        if (!$this->hasConnection($connection)) {
             return false;
         }
 
@@ -168,7 +168,7 @@ 
     public function broadcast($appId, stdClass $payload, bool $replicate = true): bool
     {
         collect($this->getConnections())
-            ->each(function ($connection) use ($payload) {
+            ->each(function($connection) use ($payload) {
                 $connection->send(json_encode($payload));
                 $this->channelManager->connectionPonged($connection);
             });
@@ -211,7 +211,7 @@ 
             return $this->broadcast($appId, $payload, false);
         }
 
-        collect($this->getConnections())->each(function (ConnectionInterface $connection) use ($socketId, $payload) {
+        collect($this->getConnections())->each(function(ConnectionInterface $connection) use ($socketId, $payload) {
             if ($connection->socketId !== $socketId) {
                 $connection->send(json_encode($payload));
                 $this->channelManager->connectionPonged($connection);
@@ -253,7 +253,7 @@ 
             $signature .= ":{$payload->channel_data}";
         }
 
-        if (! hash_equals(
+        if (!hash_equals(
             hash_hmac('sha256', $signature, $connection->app->secret),
             Str::after($payload->auth, ':'))
         ) {

src/Channels/PresenceChannel.php

Spacing +10 added lines, -10 removed lines

@@ -32,10 +32,10 @@ 
 
         $this->channelManager
             ->userJoinedPresenceChannel($connection, $user, $this->getName(), $payload)
-            ->then(function () use ($connection) {
+            ->then(function() use ($connection) {
                 $this->channelManager
                     ->getChannelMembers($connection->app->id, $this->getName())
-                    ->then(function ($users) use ($connection) {
+                    ->then(function($users) use ($connection) {
                         $hash = [];
 
                         foreach ($users as $socketId => $user) {
@@ -47,7 +47,7 @@ 
                             'channel' => $this->getName(),
                             'data' => json_encode([
                                 'presence' => [
-                                    'ids' => collect($users)->map(function ($user) {
+                                    'ids' => collect($users)->map(function($user) {
                                         return (string) $user->user_id;
                                     })->values(),
                                     'hash' => $hash,
@@ -57,14 +57,14 @@ 
                         ]));
                     });
             })
-            ->then(function () use ($connection, $user, $payload) {
+            ->then(function() use ($connection, $user, $payload) {
                 // The `pusher_internal:member_added` event is triggered when a user joins a channel.
                 // It's quite possible that a user can have multiple connections to the same channel
                 // (for example by having multiple browser tabs open)
                 // and in this case the events will only be triggered when the first tab is opened.
                 $this->channelManager
                     ->getMemberSockets($user->user_id, $connection->app->id, $this->getName())
-                    ->then(function ($sockets) use ($payload, $connection, $user) {
+                    ->then(function($sockets) use ($payload, $connection, $user) {
                         if (count($sockets) === 1) {
                             $memberAddedPayload = [
                                 'event' => 'pusher_internal:member_added',
@@ -108,24 +108,24 @@ 
 
         $this->channelManager
             ->getChannelMember($connection, $this->getName())
-            ->then(function ($user) {
+            ->then(function($user) {
                 return @json_decode($user);
             })
-            ->then(function ($user) use ($connection) {
-                if (! $user) {
+            ->then(function($user) use ($connection) {
+                if (!$user) {
                     return;
                 }
 
                 $this->channelManager
                     ->userLeftPresenceChannel($connection, $user, $this->getName())
-                    ->then(function () use ($connection, $user) {
+                    ->then(function() use ($connection, $user) {
                         // The `pusher_internal:member_removed` is triggered when a user leaves a channel.
                         // It's quite possible that a user can have multiple connections to the same channel
                         // (for example by having multiple browser tabs open)
                         // and in this case the events will only be triggered when the last one is closed.
                         $this->channelManager
                             ->getMemberSockets($user->user_id, $connection->app->id, $this->getName())
-                            ->then(function ($sockets) use ($connection, $user) {
+                            ->then(function($sockets) use ($connection, $user) {
                                 if (count($sockets) === 0) {
                                     $memberRemovedPayload = [
                                         'event' => 'pusher_internal:member_removed',

database/migrations/0000_00_00_000000_rename_statistics_counters.php

Spacing +6 added lines, -6 removed lines

@@ -13,13 +13,13 @@ 
      */
     public function up()
     {
-        Schema::table('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::table('websockets_statistics_entries', function(Blueprint $table) {
             $table->renameColumn('peak_connection_count', 'peak_connections_count');
         });
-        Schema::table('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::table('websockets_statistics_entries', function(Blueprint $table) {
             $table->renameColumn('websocket_message_count', 'websocket_messages_count');
         });
-        Schema::table('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::table('websockets_statistics_entries', function(Blueprint $table) {
             $table->renameColumn('api_message_count', 'api_messages_count');
         });
     }
@@ -31,13 +31,13 @@ 
      */
     public function down()
     {
-        Schema::table('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::table('websockets_statistics_entries', function(Blueprint $table) {
             $table->renameColumn('peak_connections_count', 'peak_connection_count');
         });
-        Schema::table('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::table('websockets_statistics_entries', function(Blueprint $table) {
             $table->renameColumn('websocket_messages_count', 'websocket_message_count');
         });
-        Schema::table('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::table('websockets_statistics_entries', function(Blueprint $table) {
             $table->renameColumn('api_messages_count', 'api_message_count');
         });
     }