beyondcode / laravel-websockets

src/ChannelManagers/LocalChannelManager.php

Spacing +19 added lines, -19 removed lines

@@ -102,7 +102,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);
@@ -120,11 +120,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()
@@ -167,28 +167,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]);
                 }
@@ -266,13 +266,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();
@@ -364,7 +364,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();
 
@@ -395,7 +395,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;
@@ -441,11 +441,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());
 
@@ -470,7 +470,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();
@@ -491,7 +491,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/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);
             });
         }

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, ':'))
         ) {