swooletw / laravel-swoole

src/HotReload/FSProcess.php

Spacing +3 added lines, -3 removed lines

@@ -62,8 +62,8 @@ 
      */
     public function make(?callable $callback = null)
     {
-        $mcb = function ($type, $buffer) use ($callback) {
-            if (! $this->locked && AppProcess::OUT === $type && $event = FSEventParser::toEvent($buffer)) {
+        $mcb = function($type, $buffer) use ($callback) {
+            if (!$this->locked && AppProcess::OUT === $type && $event = FSEventParser::toEvent($buffer)) {
                 $this->locked = true;
                 ($callback) ? $callback($event) : null;
                 $this->locked = false;
@@ -71,7 +71,7 @@ 
             }
         };
 
-        return new SwooleProcess(function () use ($mcb) {
+        return new SwooleProcess(function() use ($mcb) {
             (new AppProcess($this->configure()))->setTimeout(0)->run($mcb);
         }, false, false);
     }

src/Concerns/InteractsWithSwooleQueue.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
      */
     protected function isSwooleQueuePacket($packet)
     {
-        if (! is_string($packet)) {
+        if (!is_string($packet)) {
             return false;
         }
 

src/Websocket/Rooms/RedisRoom.php

Spacing +4 added lines, -4 removed lines

@@ -57,7 +57,7 @@ 
      */
     public function setRedis(?RedisClient $redis = null)
     {
-        if (! $redis) {
+        if (!$redis) {
             $server = Arr::get($this->config, 'server', []);
             $options = Arr::get($this->config, 'options', []);
 
@@ -139,7 +139,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->sadd($redisKey, $value);
             }
@@ -162,7 +162,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->srem($redisKey, $value);
             }
@@ -202,7 +202,7 @@ 
      */
     protected function checkTable(string $table)
     {
-        if (! in_array($table, [RoomContract::ROOMS_KEY, RoomContract::DESCRIPTORS_KEY])) {
+        if (!in_array($table, [RoomContract::ROOMS_KEY, RoomContract::DESCRIPTORS_KEY])) {
             throw new \InvalidArgumentException("Invalid table name: `{$table}`.");
         }
     }

src/Websocket/Rooms/TableRoom.php

Spacing +2 added lines, -2 removed lines

@@ -87,7 +87,7 @@ 
         foreach ($rooms as $room) {
             $fds = $this->getClients($room);
 
-            if (! in_array($fd, $fds)) {
+            if (!in_array($fd, $fds)) {
                 continue;
             }
 
@@ -206,7 +206,7 @@ 
      */
     protected function checkTable(string $table)
     {
-        if (! property_exists($this, $table) || ! $this->$table instanceof Table) {
+        if (!property_exists($this, $table) || !$this->$table instanceof Table) {
             throw new \InvalidArgumentException("Invalid table name: `{$table}`.");
         }
     }

copy_versioned_files.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-require __DIR__.'/vendor/autoload.php';
+require __DIR__ . '/vendor/autoload.php';
 
 use SwooleTW\Http\Helpers\FW;
 use SwooleTW\Http\Task\QueueFactory;

src/Helpers/Dumper.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
 
     public static function dump(...$args)
     {
-        if (! static::$cloner instanceOf VarCloner) {
+        if (!static::$cloner instanceOf VarCloner) {
             static::$cloner = new VarCloner;
         }
 
@@ -29,7 +29,7 @@ 
 
     public static function getDumper()
     {
-        $dumper = defined('IN_PHPUNIT') || ! config('swoole_http.ob_output')
+        $dumper = defined('IN_PHPUNIT') || !config('swoole_http.ob_output')
             ? CliDumper::class
             : HtmlDumper::class;
 

src/LumenServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -17,7 +17,7 @@ 
      */
     protected function registerManager()
     {
-        $this->app->singleton(Manager::class, function ($app) {
+        $this->app->singleton(Manager::class, function($app) {
             return new Manager($app, 'lumen');
         });
 
@@ -32,7 +32,7 @@ 
     protected function bootWebsocketRoutes()
     {
         $this->app->router
-            ->group(['namespace' => 'SwooleTW\Http\Controllers'], function ($router) {
+            ->group(['namespace' => 'SwooleTW\Http\Controllers'], function($router) {
                 require __DIR__ . '/../routes/lumen_routes.php';
             });
     }

src/Websocket/Pusher.php

Spacing +4 added lines, -4 removed lines

@@ -209,7 +209,7 @@ 
      */
     public function shouldBroadcast(): bool
     {
-        return $this->broadcast && empty($this->descriptors) && ! $this->assigned;
+        return $this->broadcast && empty($this->descriptors) && !$this->assigned;
     }
 
     /**
@@ -221,7 +221,7 @@ 
      */
     protected function getWebsocketConnections(): array
     {
-        return array_filter(iterator_to_array($this->server->connections), function ($fd) {
+        return array_filter(iterator_to_array($this->server->connections), function($fd) {
             return $this->server->isEstablished($fd);
         });
     }
@@ -233,7 +233,7 @@ 
      */
     public function shouldPushToDescriptor(int $fd): bool
     {
-        if (! $this->server->isEstablished($fd)) {
+        if (!$this->server->isEstablished($fd)) {
             return false;
         }
 
@@ -250,7 +250,7 @@ 
     public function push($payload): void
     {
         // attach sender if not broadcast
-        if (! $this->broadcast && $this->sender && ! $this->hasDescriptor($this->sender)) {
+        if (!$this->broadcast && $this->sender && !$this->hasDescriptor($this->sender)) {
             $this->addDescriptor($this->sender);
         }
 

src/Server/PidManager.php

Spacing +2 added lines, -2 removed lines

@@ -30,8 +30,8 @@
      */
     public function write(int $masterPid, int $managerPid): void
     {
-        if (! is_writable($this->pidFile)
-            && ! is_writable(dirname($this->pidFile))
+        if (!is_writable($this->pidFile)
+            && !is_writable(dirname($this->pidFile))
         ) {
             throw new \RuntimeException(
                 sprintf('Pid file "%s" is not writable', $this->pidFile)