swooletw / laravel-swoole

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

src/Coroutine/PDO.php

Spacing +4 added lines, -4 removed lines

@@ -56,7 +56,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;
 
@@ -101,7 +101,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.");
         }
     }
@@ -126,7 +126,7 @@ 
     public function commit()
     {
         $this->client->commit();
-        $this->inTransaction = false;//TODO I think it's sample to rollback, please confirm it
+        $this->inTransaction = false; //TODO I think it's sample to rollback, please confirm it
     }
 
     public function inTransaction()
@@ -185,7 +185,7 @@ 
             $bindKeyMap = [];
             $statement = preg_replace_callback(
                 '/:([a-zA-Z_]\w*?)\b/',
-                function ($matches) use (&$i, &$bindKeyMap) {
+                function($matches) use (&$i, &$bindKeyMap) {
                     $bindKeyMap[$matches[1]] = $i++;
 
                     return '?';

src/Coroutine/PDOStatement.php

Spacing +7 added lines, -7 removed lines

@@ -48,7 +48,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;
         }
 
@@ -60,12 +60,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;
@@ -86,14 +86,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];
@@ -110,7 +110,7 @@ 
         //if not, the DB::connection('mysql-coroutine')->transaction(func,times) won't be work well,
         //and if one sql occur error, others will be execute success, it doesn't rollback,
         //also please confirm it, Thank you
-        if($result === false){
+        if ($result === false) {
             throw new \PDOException($this->errorInfo(), $this->errorCode());
         }
 
@@ -152,7 +152,7 @@ 
         $fetchArgument = null,
         $ctorArgs = null
     ) {
-        if (! is_array($rawData)) {
+        if (!is_array($rawData)) {
             return false;
         }
         if (empty($rawData)) {

src/Task/SwooleTaskQueue.php

Spacing +2 added lines, -2 removed lines

@@ -50,7 +50,7 @@ 
     public function pushRaw($payload, $queue = null, array $options = [])
     {
         //wiki https://wiki.swoole.com/wiki/page/134.html, task($data,$dst_worker_id), $dst_worker_id should be default -1
-        return $this->swoole->task($payload, (!is_numeric($queue) || $queue < 0) ? -1 : (int)$queue);
+        return $this->swoole->task($payload, (!is_numeric($queue) || $queue < 0) ? -1 : (int) $queue);
     }
 
     /**
@@ -64,7 +64,7 @@ 
      */
     public function later($delay, $job, $data = '', $queue = null)
     {
-        return Timer::after($this->secondsUntil($delay) * 1000, function () use ($job, $data, $queue) {
+        return Timer::after($this->secondsUntil($delay) * 1000, function() use ($job, $data, $queue) {
             return $this->push($job, $data, $queue);
         });
     }