beyondcode / laravel-websockets

src/Apps/MysqlAppManager.php

Spacing +11 added lines, -11 removed lines

@@ -42,9 +42,9 @@ 
         $deferred = new Deferred();
 
         $this->database->query('SELECT * FROM `'.$this->getTableName().'`')
-            ->then(function (QueryResult $result) use ($deferred) {
+            ->then(function(QueryResult $result) use ($deferred) {
                 $deferred->resolve($result->resultRows);
-            }, function ($error) use ($deferred) {
+            }, function($error) use ($deferred) {
                 $deferred->reject($error);
             });
 
@@ -62,9 +62,9 @@ 
         $deferred = new Deferred();
 
         $this->database->query('SELECT * from `'.$this->getTableName().'` WHERE `id` = ?', [$appId])
-            ->then(function (QueryResult $result) use ($deferred) {
+            ->then(function(QueryResult $result) use ($deferred) {
                 $deferred->resolve($this->convertIntoApp($result->resultRows[0]));
-            }, function ($error) use ($deferred) {
+            }, function($error) use ($deferred) {
                 $deferred->reject($error);
             });
 
@@ -82,9 +82,9 @@ 
         $deferred = new Deferred();
 
         $this->database->query('SELECT * from `'.$this->getTableName().'` WHERE `key` = ?', [$appKey])
-            ->then(function (QueryResult $result) use ($deferred) {
+            ->then(function(QueryResult $result) use ($deferred) {
                 $deferred->resolve($this->convertIntoApp($result->resultRows[0]));
-            }, function ($error) use ($deferred) {
+            }, function($error) use ($deferred) {
                 $deferred->reject($error);
             });
 
@@ -102,9 +102,9 @@ 
         $deferred = new Deferred();
 
         $this->database->query('SELECT * from `'.$this->getTableName().'` WHERE `secret` = ?', [$appSecret])
-            ->then(function (QueryResult $result) use ($deferred) {
+            ->then(function(QueryResult $result) use ($deferred) {
                 $deferred->resolve($this->convertIntoApp($result->resultRows[0]));
-            }, function ($error) use ($deferred) {
+            }, function($error) use ($deferred) {
                 $deferred->reject($error);
             });
 
@@ -119,7 +119,7 @@ 
      */
     protected function convertIntoApp(?array $appAttributes): ?App
     {
-        if (! $appAttributes) {
+        if (!$appAttributes) {
             return null;
         }
 
@@ -160,9 +160,9 @@ 
         $this->database->query(
             'INSERT INTO `'.$this->getTableName().'` (`id`, `key`, `secret`, `name`, `enable_client_messages`, `enable_statistics`, `allowed_origins`, `capacity`) VALUES (?, ?, ?, ?, ?, ?, ?, ?)',
             [$appData['id'], $appData['key'], $appData['secret'], $appData['name'], $appData['enable_client_messages'], $appData['enable_statistics'], $appData['allowed_origins'] ?? '', $appData['capacity'] ?? null])
-            ->then(function () use ($deferred) {
+            ->then(function() use ($deferred) {
                 $deferred->resolve();
-            }, function ($error) use ($deferred) {
+            }, function($error) use ($deferred) {
                 $deferred->reject($error);
             });
 

src/Apps/ConfigAppManager.php

Spacing +2 added lines, -2 removed lines

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

src/Channels/Channel.php

Spacing +4 added lines, -4 removed lines

@@ -122,7 +122,7 @@ 
      */
     public function unsubscribe(ConnectionInterface $connection): PromiseInterface
     {
-        if (! $this->hasConnection($connection)) {
+        if (!$this->hasConnection($connection)) {
             return Helpers::createFulfilledPromise(false);
         }
 
@@ -170,7 +170,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);
             });
@@ -213,7 +213,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);
@@ -255,7 +255,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 +11 added lines, -11 removed lines

@@ -34,10 +34,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) {
@@ -49,7 +49,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,
@@ -59,14 +59,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',
@@ -110,24 +110,24 @@ 
 
         return $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 Helpers::createFulfilledPromise(true);
                 }
 
                 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.
                         return $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',
@@ -152,7 +152,7 @@ 
                             });
                     });
             })
-            ->then(function () use ($truth) {
+            ->then(function() use ($truth) {
                 return $truth;
             });
     }

src/Cache/RedisLock.php

Spacing +3 added lines, -3 removed lines

@@ -30,13 +30,13 @@ 
         if ($this->seconds > 0) {
             $this->redis
                 ->set($this->name, $this->owner, 'EX', $this->seconds, 'NX')
-                ->then(function ($result) use ($promise) {
+                ->then(function($result) use ($promise) {
                     $promise->resolve($result === true);
                 });
         } else {
             $this->redis
                 ->setnx($this->name, $this->owner)
-                ->then(function ($result) use ($promise) {
+                ->then(function($result) use ($promise) {
                     $promise->resolve($result === 1);
                 });
         }
@@ -49,7 +49,7 @@ 
         $promise = new Deferred();
 
         $this->acquire()
-            ->then(function ($result) use ($callback, $promise) {
+            ->then(function($result) use ($callback, $promise) {
                 if ($result) {
                     try {
                         $callback();

src/WebSocketsServiceProvider.php

Spacing +11 added lines, -11 removed lines

@@ -81,7 +81,7 @@ 
 
     protected function registerEventLoop()
     {
-        $this->app->singleton(LoopInterface::class, function () {
+        $this->app->singleton(LoopInterface::class, function() {
             return Factory::create();
         });
     }
@@ -93,14 +93,14 @@ 
      */
     protected function registerAsyncRedisQueueDriver()
     {
-        Queue::extend('async-redis', function () {
+        Queue::extend('async-redis', function() {
             return new AsyncRedisConnector($this->app['redis']);
         });
     }
 
     protected function registerSQLiteDatabase()
     {
-        $this->app->singleton(DatabaseInterface::class, function () {
+        $this->app->singleton(DatabaseInterface::class, function() {
             $factory = new SQLiteFactory($this->app->make(LoopInterface::class));
 
             $database = $factory->openLazy(
@@ -124,7 +124,7 @@ 
 
     protected function registerMySqlDatabase()
     {
-        $this->app->singleton(ConnectionInterface::class, function () {
+        $this->app->singleton(ConnectionInterface::class, function() {
             $factory = new MySQLFactory($this->app->make(LoopInterface::class));
 
             $connectionKey = 'database.connections.'.config('websockets.managers.mysql.connection');
@@ -146,14 +146,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';
 
@@ -198,7 +198,7 @@ 
      */
     protected function registerRouter()
     {
-        $this->app->singleton('websockets.router', function () {
+        $this->app->singleton('websockets.router', function() {
             return new Router;
         });
     }
@@ -210,7 +210,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']);
@@ -229,7 +229,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('/apps', ShowApps::class)->name('apps');
             Route::post('/apps', StoreApp::class)->name('apps.store');
@@ -246,14 +246,14 @@ 
      */
     protected function registerDashboardGate()
     {
-        Gate::define('viewWebSocketsDashboard', function ($user = null) {
+        Gate::define('viewWebSocketsDashboard', function($user = null) {
             return $this->app->environment('local');
         });
     }
 
     protected function registerWebSocketHandler()
     {
-        $this->app->singleton('websockets.handler', function () {
+        $this->app->singleton('websockets.handler', function() {
             return app(config('websockets.handlers.websocket'));
         });
     }

database/migrations/0000_00_00_000000_create_websockets_statistics_entries_table.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function up()
     {
-        Schema::create('websockets_statistics_entries', function (Blueprint $table) {
+        Schema::create('websockets_statistics_entries', function(Blueprint $table) {
             $table->increments('id');
             $table->string('app_id');
             $table->integer('peak_connections_count');

database/migrations/0000_00_00_000000_create_websockets_apps_table.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
      */
     public function up()
     {
-        Schema::create('websockets_apps', function (Blueprint $table) {
+        Schema::create('websockets_apps', function(Blueprint $table) {
             $table->string('id')->index();
             $table->string('key');
             $table->string('secret');