swooletw / laravel-swoole

src/Concerns/InteractsWithWebsocket.php

Spacing +8 added lines, -8 removed lines

@@ -66,7 +66,7 @@ 
             // enable sandbox
             $sandbox->enable();
             // check if socket.io connection established
-            if (! $this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
+            if (!$this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
                 return;
             }
             // trigger 'connect' websocket event
@@ -130,7 +130,7 @@ 
      */
     public function onClose($server, $fd, $reactorId)
     {
-        if (! $this->isServerWebsocket($fd) || ! $server instanceof WebsocketServer) {
+        if (!$this->isServerWebsocket($fd) || !$server instanceof WebsocketServer) {
             return;
         }
 
@@ -158,7 +158,7 @@ 
      */
     protected function isWebsocketPushPacket($packet)
     {
-        if (! is_array($packet)) {
+        if (!is_array($packet)) {
             return false;
         }
 
@@ -243,7 +243,7 @@ 
     {
         $handlerClass = $this->container->make('config')->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new WebsocketNotSetInConfigException;
         }
 
@@ -290,7 +290,7 @@ 
      */
     protected function bindRoom(): void
     {
-        $this->app->singleton(RoomContract::class, function (Container $container) {
+        $this->app->singleton(RoomContract::class, function(Container $container) {
             $config = $container->make('config');
             $driver = $config->get('swoole_websocket.default');
             $settings = $config->get("swoole_websocket.settings.{$driver}");
@@ -311,7 +311,7 @@ 
      */
     protected function bindWebsocket()
     {
-        $this->app->singleton(Websocket::class, function (Container $app) {
+        $this->app->singleton(Websocket::class, function(Container $app) {
             return new Websocket($app->make(RoomContract::class), new Pipeline($app));
         });
 
@@ -326,7 +326,7 @@ 
         $routePath = $this->container->make('config')
             ->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 
@@ -342,7 +342,7 @@ 
      */
     public function isWebsocketPushPayload($payload): bool
     {
-        if (! is_array($payload)) {
+        if (!is_array($payload)) {
             return false;
         }
 

src/HttpServiceProvider.php

Spacing +6 added lines, -6 removed lines

@@ -149,7 +149,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']);
         }
 
@@ -163,7 +163,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();
@@ -179,8 +179,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(
@@ -223,8 +223,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));
             });
         });

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/Commands/HttpServerCommand.php

Spacing +12 added lines, -12 removed lines

@@ -134,7 +134,7 @@ 
     {
         $pid = $this->getCurrentPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -178,7 +178,7 @@ 
     {
         $pid = $this->getCurrentPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -188,7 +188,7 @@ 
 
         $isRunning = $this->killProcess($pid, SIGUSR1);
 
-        if (! $isRunning) {
+        if (!$isRunning) {
             $this->error('> failure');
 
             return;
@@ -245,7 +245,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'."
             );
@@ -266,7 +266,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();
         };
@@ -283,7 +283,7 @@ 
      */
     protected function isRunning($pid)
     {
-        if (! $pid) {
+        if (!$pid) {
             return false;
         }
 
@@ -311,7 +311,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning($pid)) {
+                if (!$this->isRunning($pid)) {
                     break;
                 }
 
@@ -379,13 +379,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);
@@ -397,15 +397,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/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);
         }