swooletw / laravel-swoole

src/Server/Resetters/RebindViewContainer.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
     {
         $view = $app->make('view');
 
-        $closure = function () use ($app) {
+        $closure = function() use ($app) {
             $this->container = $app;
             $this->shared['app'] = $app;
         };

src/Server/helpers.php

Spacing +2 added lines, -2 removed lines

@@ -3,7 +3,7 @@ 
 /**
  * This is only for `function not exists` in config/swoole_http.php.
  */
-if (! function_exists('swoole_cpu_num')) {
+if (!function_exists('swoole_cpu_num')) {
     function swoole_cpu_num()
     {
         return;
@@ -13,6 +13,6 @@ 
 /**
  * This is only for `function not exists` in config/swoole_http.php.
  */
-if (! defined('SWOOLE_SOCK_TCP')) {
+if (!defined('SWOOLE_SOCK_TCP')) {
     define('SWOOLE_SOCK_TCP', 1);
 }

src/Server/Sandbox.php

Spacing +6 added lines, -6 removed lines

@@ -34,7 +34,7 @@ 
      */
     public function __construct($app = null, $framework = null)
     {
-        if (! $app instanceof Container) {
+        if (!$app instanceof Container) {
             return;
         }
 
@@ -102,7 +102,7 @@ 
      */
     public function initialize()
     {
-        if (! $this->app instanceof Container) {
+        if (!$this->app instanceof Container) {
             throw new SandboxException('A base app has not been set.');
         }
 
@@ -149,7 +149,7 @@ 
      */
     public function run(Request $request)
     {
-        if (! $this->getSnapshot() instanceof Container) {
+        if (!$this->getSnapshot() instanceof Container) {
             throw new SandboxException('Sandbox is not enabled.');
         }
 
@@ -199,7 +199,7 @@ 
             $response->sendContent();
         } elseif ($response instanceof SymfonyResponse) {
             $content = $response->getContent();
-        } elseif (! $isFile = $response instanceof BinaryFileResponse) {
+        } elseif (!$isFile = $response instanceof BinaryFileResponse) {
             $content = (string) $response;
         }
 
@@ -207,7 +207,7 @@ 
         $this->terminate($request, $response);
 
         // append ob content to response
-        if (! $isFile && ob_get_length() > 0) {
+        if (!$isFile && ob_get_length() > 0) {
             if ($isStream) {
                 $response->output = ob_get_contents();
             } else {
@@ -280,7 +280,7 @@ 
      */
     public function enable()
     {
-        if (! $this->config instanceof ConfigContract) {
+        if (!$this->config instanceof ConfigContract) {
             throw new SandboxException('Please initialize after setting base app.');
         }
 

src/Commands/HttpServerCommand.php

Spacing +9 added lines, -9 removed lines

@@ -106,7 +106,7 @@ 
     {
         $pid = $this->getPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
             exit(1);
         }
@@ -148,7 +148,7 @@ 
     {
         $pid = $this->getPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
             exit(1);
         }
@@ -157,7 +157,7 @@ 
 
         $isRunning = $this->killProcess($pid, SIGUSR1);
 
-        if (! $isRunning) {
+        if (!$isRunning) {
             $this->error('> failure');
             exit(1);
         }
@@ -215,7 +215,7 @@ 
     {
         $this->action = $this->argument('action');
 
-        if (! in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'])) {
+        if (!in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'])) {
             $this->error("Invalid argument '{$this->action}'. Expected 'start', 'stop', 'restart', 'reload' or 'infos'.");
             exit(1);
         }
@@ -229,7 +229,7 @@ 
      */
     protected function isRunning($pid)
     {
-        if (! $pid) {
+        if (!$pid) {
             return false;
         }
 
@@ -256,7 +256,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning($pid)) {
+                if (!$this->isRunning($pid)) {
                     break;
                 }
 
@@ -284,7 +284,7 @@ 
         if (file_exists($path)) {
             $pid = (int) file_get_contents($path);
 
-            if (! $pid) {
+            if (!$pid) {
                 $this->removePidFile();
             } else {
                 $this->pid = $pid;
@@ -330,10 +330,10 @@ 
         if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
             $this->error("Swoole extension doesn't support Windows OS yet.");
             exit;
-        } elseif (! extension_loaded('swoole')) {
+        } elseif (!extension_loaded('swoole')) {
             $this->error("Can't detect Swoole extension installed.");
             exit;
-        } elseif (! version_compare(swoole_version(), '4.0.0', 'ge')) {
+        } elseif (!version_compare(swoole_version(), '4.0.0', 'ge')) {
             $this->error("Your Swoole version must be higher than 4.0 to use coroutine.");
             exit;
         }

src/Websocket/Rooms/TableRoom.php

Spacing +2 added lines, -2 removed lines

@@ -55,7 +55,7 @@ 
         foreach ($rooms as $room) {
             $fds = $this->getClients($room);
 
-            if (! in_array($fd, $fds)) {
+            if (!in_array($fd, $fds)) {
                 continue;
             }
 
@@ -122,7 +122,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.');
         }
     }

src/Websocket/Rooms/RedisRoom.php

Spacing +3 added lines, -3 removed lines

@@ -91,7 +91,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function ($pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function($pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->sadd($redisKey, $value);
             }
@@ -105,7 +105,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function ($pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function($pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->srem($redisKey, $value);
             }
@@ -126,7 +126,7 @@ 
 
     protected function checkTable(string $table)
     {
-        if (! in_array($table, ['rooms', 'fds'])) {
+        if (!in_array($table, ['rooms', 'fds'])) {
             throw new \InvalidArgumentException('Invalid table name.');
         }
     }

src/Concerns/ResetApplication.php

Spacing +2 added lines, -2 removed lines

@@ -48,7 +48,7 @@ 
         $providers = $this->config->get('swoole_http.providers', []);
 
         foreach ($providers as $provider) {
-            if (class_exists($provider) && ! in_array($provider, $this->providers)) {
+            if (class_exists($provider) && !in_array($provider, $this->providers)) {
                 $providerClass = new $provider($app);
                 $this->providers[$provider] = $providerClass;
             }
@@ -73,7 +73,7 @@ 
 
         foreach ($resetters as $resetter) {
             $resetterClass = $app->make($resetter);
-            if (! $resetterClass instanceof ResetterContract) {
+            if (!$resetterClass instanceof ResetterContract) {
                 throw new SandboxException("{$resetter} must implement " . ResetterContract::class);
             }
             $this->resetters[$resetter] = $resetterClass;

src/Server/Manager.php

Spacing +4 added lines, -4 removed lines

@@ -103,7 +103,7 @@ 
             if (method_exists($this, $listener)) {
                 $this->container['swoole.server']->on($event, [$this, $listener]);
             } else {
-                $this->container['swoole.server']->on($event, function () use ($event) {
+                $this->container['swoole.server']->on($event, function() use ($event) {
                     $event = sprintf('swoole.%s', $event);
 
                     $this->container['events']->fire($event, func_get_args());
@@ -145,7 +145,7 @@ 
 
         // don't init laravel app in task workers
         if ($server->taskworker) {
-            $this->setProcessName('task process');//mark task process
+            $this->setProcessName('task process'); //mark task process
             return;
         }
         $this->setProcessName('worker process');
@@ -245,7 +245,7 @@ 
                     (new SwooleTaskJob($this->container, $server, $data, $taskId, $srcWorkerId))->fire();
                 }
             }
-            $server->finish("$taskId finished");//if not ,don't call onFinish
+            $server->finish("$taskId finished"); //if not ,don't call onFinish
         } catch (Throwable $e) {
             $this->logServerError($e);
         }
@@ -288,7 +288,7 @@ 
      */
     protected function bindSandbox()
     {
-        $this->app->singleton(Sandbox::class, function ($app) {
+        $this->app->singleton(Sandbox::class, function($app) {
             return new Sandbox($app, $this->framework);
         });
         $this->app->alias(Sandbox::class, 'swoole.sandbox');

src/HttpServiceProvider.php

Spacing +8 added lines, -8 removed lines

@@ -130,7 +130,7 @@ 
         $options = $config->get('swoole_http.server.options');
 
         // only enable task worker in websocket mode and for queue driver
-        if ($config->get('queue.default') !== 'swoole' && ! $this->isWebsocket) {
+        if ($config->get('queue.default') !== 'swoole' && !$this->isWebsocket) {
             unset($config['task_worker_num']);
         }
 
@@ -144,7 +144,7 @@ 
      */
     protected function registerServer()
     {
-        $this->app->singleton(Server::class, function () {
+        $this->app->singleton(Server::class, function() {
             if (is_null(static::$server)) {
                 $this->createSwooleServer();
                 $this->configureSwooleServer();
@@ -163,15 +163,15 @@ 
      */
     protected function registerDatabaseDriver()
     {
-        $this->app->extend('db', function ($db) {
-            $db->extend('mysql-coroutine', function ($config, $name) {
+        $this->app->extend('db', function($db) {
+            $db->extend('mysql-coroutine', function($config, $name) {
                 $config['name'] = $name;
 
                 if (isset($config['read'])) {
                     $config = array_merge($config, $config['read']);
                 }
 
-                $connectionRead = function () use ($config) {
+                $connectionRead = function() use ($config) {
                     return (new MySqlConnector())->connect($config);
                 };
 
@@ -179,7 +179,7 @@ 
                     $config = array_merge($config, $config['write']);
                 }
 
-                $connection = function () use ($config) {
+                $connection = function() use ($config) {
                     return (new MySqlConnector())->connect($config);
                 };
 
@@ -200,8 +200,8 @@ 
      */
     protected function registerSwooleQueueDriver()
     {
-        $this->app->afterResolving('queue', function ($manager) {
-            $manager->addConnector('swoole', function () {
+        $this->app->afterResolving('queue', function($manager) {
+            $manager->addConnector('swoole', function() {
                 return new SwooleTaskConnector($this->app->make(Server::class));
             });
         });