swooletw / laravel-swoole

src/HttpServiceProvider.php

Spacing +8 added lines, -8 removed lines

@@ -173,8 +173,8 @@ 
 
         static::$server = new $server($host, $port, $processType, $socketType);
 
-        if(intval($ssl_port) > 0)
-            static::$server->listen($host, $ssl_port, SWOOLE_SOCK_TCP | SWOOLE_SSL );
+        if (intval($ssl_port) > 0)
+            static::$server->listen($host, $ssl_port, SWOOLE_SOCK_TCP | SWOOLE_SSL);
     }
 
     /**
@@ -186,7 +186,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($options['task_worker_num']);
         }
 
@@ -200,7 +200,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();
@@ -216,8 +216,8 @@ 
      */
     protected function registerDatabaseDriver()
     {
-        $this->app->extend(DatabaseManager::class, function (DatabaseManager $db) {
-            $db->extend('mysql-coroutine', function ($config, $name) {
+        $this->app->extend(DatabaseManager::class, function(DatabaseManager $db) {
+            $db->extend('mysql-coroutine', function($config, $name) {
                 $config['name'] = $name;
 
                 $connection = new MySqlConnection(
@@ -260,8 +260,8 @@ 
      */
     protected function registerSwooleQueueDriver()
     {
-        $this->app->afterResolving('queue', function (QueueManager $manager) {
-            $manager->addConnector('swoole', function () {
+        $this->app->afterResolving('queue', function(QueueManager $manager) {
+            $manager->addConnector('swoole', function() {
                 return new SwooleTaskConnector($this->app->make(Server::class));
             });
         });

Braces +3 added lines, -2 removed lines

@@ -173,8 +173,9 @@
 
         static::$server = new $server($host, $port, $processType, $socketType);
 
-        if(intval($ssl_port) > 0)
-            static::$server->listen($host, $ssl_port, SWOOLE_SOCK_TCP | SWOOLE_SSL );
+        if(intval($ssl_port) > 0) {
+                    static::$server->listen($host, $ssl_port, SWOOLE_SOCK_TCP | SWOOLE_SSL );
+        }
     }
 
     /**

src/Commands/HttpServerCommand.php

Spacing +13 added lines, -13 removed lines

@@ -108,7 +108,7 @@ 
 
         $this->info('Starting swoole http server...');
         $this->info("Swoole http server started: <http://{$host}:{$port}>");
-        if(intval($ssl_port) > 0)
+        if (intval($ssl_port) > 0)
             $this->info("Swoole https server started: <https://{$host}:{$ssl_port}>");
 
         if ($this->isDaemon()) {
@@ -137,7 +137,7 @@ 
      */
     protected function stop()
     {
-        if (! $this->isRunning()) {
+        if (!$this->isRunning()) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -177,7 +177,7 @@ 
      */
     protected function reload()
     {
-        if (! $this->isRunning()) {
+        if (!$this->isRunning()) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -185,7 +185,7 @@ 
 
         $this->info('Reloading swoole_http_server...');
 
-        if (! $this->killProcess(SIGUSR1)) {
+        if (!$this->killProcess(SIGUSR1)) {
             $this->error('> failure');
 
             return;
@@ -246,7 +246,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'."
             );
@@ -267,7 +267,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();
         };
@@ -286,7 +286,7 @@ 
     {
         $pids = $this->laravel->make(PidManager::class)->read();
 
-        if (! count($pids)) {
+        if (!count($pids)) {
             return false;
         }
 
@@ -321,7 +321,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning()) {
+                if (!$this->isRunning()) {
                     break;
                 }
 
@@ -351,13 +351,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.3.1', 'ge')) {
+        if (!version_compare(swoole_version(), '4.3.1', 'ge')) {
             $this->error('Your Swoole version must be higher than `4.3.1`.');
 
             exit(1);
@@ -369,15 +369,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));
         });
     }

Braces +3 added lines, -2 removed lines

@@ -108,8 +108,9 @@
 
         $this->info('Starting swoole http server...');
         $this->info("Swoole http server started: <http://{$host}:{$port}>");
-        if(intval($ssl_port) > 0)
-            $this->info("Swoole https server started: <https://{$host}:{$ssl_port}>");
+        if(intval($ssl_port) > 0) {
+                    $this->info("Swoole https server started: <https://{$host}:{$ssl_port}>");
+        }
 
         if ($this->isDaemon()) {
             $this->info(