swooletw / laravel-swoole

src/Concerns/InteractsWithSwooleTable.php

Spacing +2 added lines, -2 removed lines

@@ -56,8 +56,8 @@
      */
     protected function bindSwooleTable()
     {
-        if (! $this->app instanceof ConsoleApp) {
-            $this->app->singleton(SwooleTable::class, function () {
+        if (!$this->app instanceof ConsoleApp) {
+            $this->app->singleton(SwooleTable::class, function() {
                 return $this->currentTable;
             });
 

src/Commands/HttpServerCommand.php

Spacing +12 added lines, -12 removed lines

@@ -133,7 +133,7 @@ 
     {
         $pid = $this->getCurrentPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -177,7 +177,7 @@ 
     {
         $pid = $this->getCurrentPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -187,7 +187,7 @@ 
 
         $isRunning = $this->killProcess($pid, SIGUSR1);
 
-        if (! $isRunning) {
+        if (!$isRunning) {
             $this->error('> failure');
 
             return;
@@ -244,7 +244,7 @@ 
     {
         $this->action = $this->argument('action');
 
-        if (! in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'], true)) {
+        if (!in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'], true)) {
             $this->error(
                 "Invalid argument '{$this->action}'. Expected 'start', 'stop', 'restart', 'reload' or 'infos'."
             );
@@ -265,7 +265,7 @@ 
         $filter = Arr::get($this->config, 'hot_reload.filter');
         $log = Arr::get($this->config, 'hot_reload.log');
 
-        $cb = function (FSEvent $event) use ($server, $log) {
+        $cb = function(FSEvent $event) use ($server, $log) {
             $log ? $this->info(FSOutput::format($event)) : null;
             $server->reload();
         };
@@ -282,7 +282,7 @@ 
      */
     protected function isRunning($pid)
     {
-        if (! $pid) {
+        if (!$pid) {
             return false;
         }
 
@@ -310,7 +310,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning($pid)) {
+                if (!$this->isRunning($pid)) {
                     break;
                 }
 
@@ -378,13 +378,13 @@ 
             exit(1);
         }
 
-        if (! extension_loaded('swoole')) {
+        if (!extension_loaded('swoole')) {
             $this->error("Can't detect Swoole extension installed.");
 
             exit(1);
         }
 
-        if (! version_compare(swoole_version(), '4.0.0', 'ge')) {
+        if (!version_compare(swoole_version(), '4.0.0', 'ge')) {
             $this->error("Your Swoole version must be higher than 4.0 to use coroutine.");
 
             exit(1);
@@ -396,15 +396,15 @@ 
      */
     protected function registerAccessLog()
     {
-        $this->laravel->singleton(OutputStyle::class, function () {
+        $this->laravel->singleton(OutputStyle::class, function() {
             return new OutputStyle($this->input, $this->output);
         });
 
-        $this->laravel->singleton(AccessOutput::class, function () {
+        $this->laravel->singleton(AccessOutput::class, function() {
             return new AccessOutput(new ConsoleOutput);
         });
 
-        $this->laravel->singleton(AccessLog::class, function (Container $container) {
+        $this->laravel->singleton(AccessLog::class, function(Container $container) {
             return new AccessLog($container->make(AccessOutput::class));
         });
     }

src/Coroutine/Connectors/ConnectorFactory.php

Spacing +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
     public static function make(string $version): MySqlConnector
     {
         $isMatch = static::isFileVersionMatch($version);
-        $class = static::copy(static::stub($version), ! $isMatch);
+        $class = static::copy(static::stub($version), !$isMatch);
 
         return new $class;
     }
@@ -64,7 +64,7 @@ 
      */
     public static function copy(string $stub, bool $rewrite = false): string
     {
-        if (! file_exists(static::CONNECTOR_CLASS_PATH) || $rewrite) {
+        if (!file_exists(static::CONNECTOR_CLASS_PATH) || $rewrite) {
             copy($stub, static::CONNECTOR_CLASS_PATH);
         }
 

src/Coroutine/PDOStatement.php

Spacing +6 added lines, -6 removed lines

@@ -54,7 +54,7 @@ 
 
     public function bindParam($parameter, &$variable, $type = null, $maxlen = null, $driverdata = null)
     {
-        if (! is_string($parameter) && ! is_int($parameter)) {
+        if (!is_string($parameter) && !is_int($parameter)) {
             return false;
         }
 
@@ -66,12 +66,12 @@ 
 
     public function bindValue($parameter, $variable, $type = null)
     {
-        if (! is_string($parameter) && ! is_int($parameter)) {
+        if (!is_string($parameter) && !is_int($parameter)) {
             return false;
         }
 
         if (is_object($variable)) {
-            if (! method_exists($variable, '__toString')) {
+            if (!method_exists($variable, '__toString')) {
                 return false;
             } else {
                 $variable = (string) $variable;
@@ -92,14 +92,14 @@ 
 
     public function execute($inputParameters = null)
     {
-        if (! empty($inputParameters)) {
+        if (!empty($inputParameters)) {
             foreach ($inputParameters as $key => $value) {
                 $this->bindParam($key, $value);
             }
         }
 
         $inputParameters = [];
-        if (! empty($this->statement->bindKeyMap)) {
+        if (!empty($this->statement->bindKeyMap)) {
             foreach ($this->statement->bindKeyMap as $nameKey => $numKey) {
                 if (isset($this->bindMap[$nameKey])) {
                     $inputParameters[$numKey] = $this->bindMap[$nameKey];
@@ -156,7 +156,7 @@ 
         $ctorArgs = null
     )
     {
-        if (! is_array($rawData)) {
+        if (!is_array($rawData)) {
             return false;
         }
         if (empty($rawData)) {

src/Coroutine/PDO.php

Spacing +3 added lines, -3 removed lines

@@ -74,7 +74,7 @@ 
     {
         $this->client->connect($options);
 
-        if (! $this->client->connected) {
+        if (!$this->client->connected) {
             $message = $this->client->connect_error ?: $this->client->error;
             $errorCode = $this->client->connect_errno ?: $this->client->errno;
 
@@ -130,7 +130,7 @@ 
      */
     public static function checkDriver(string $driver)
     {
-        if (! in_array($driver, static::getAvailableDrivers())) {
+        if (!in_array($driver, static::getAvailableDrivers())) {
             throw new \InvalidArgumentException("{$driver} driver is not supported yet.");
         }
     }
@@ -252,7 +252,7 @@ 
         if (strpos($statement, ':') !== false) {
             $i = 0;
             $bindKeyMap = [];
-            $statement = preg_replace_callback('/:([a-zA-Z_]\w*?)\b/', function ($matches) use (&$i, &$bindKeyMap) {
+            $statement = preg_replace_callback('/:([a-zA-Z_]\w*?)\b/', function($matches) use (&$i, &$bindKeyMap) {
                 $bindKeyMap[$matches[1]] = $i++;
 
                 return '?';

src/LaravelServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
      */
     protected function registerManager()
     {
-        $this->app->singleton(Manager::class, function ($app) {
+        $this->app->singleton(Manager::class, function($app) {
             return new Manager($app, 'laravel');
         });
 

src/Server/helpers.php

Spacing +3 added lines, -3 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(): int
     {
         return 1;
@@ -13,10 +13,10 @@ 
 /**
  * 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);
 }
 
-if (! defined('SWOOLE_PROCESS')) {
+if (!defined('SWOOLE_PROCESS')) {
     define('SWOOLE_PROCESS', 3);
 }

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