swooletw / laravel-swoole

src/Websocket/Middleware/StartSession.php

Spacing +2 added lines, -2 removed lines

@@ -60,7 +60,7 @@ 
      */
     protected function startSession(Request $request)
     {
-        return tap($this->getSession($request), function (Session $session) use ($request) {
+        return tap($this->getSession($request), function(Session $session) use ($request) {
             $session->setRequestOnHandler($request);
 
             $session->start();
@@ -76,7 +76,7 @@ 
      */
     public function getSession(Request $request)
     {
-        return tap($this->manager->driver(), function (Session $session) use ($request) {
+        return tap($this->manager->driver(), function(Session $session) use ($request) {
             $session->setId($request->cookies->get($session->getName()));
         });
     }

src/LumenServiceProvider.php

Spacing +3 added lines, -3 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, 'lumen');
         });
 
@@ -33,11 +33,11 @@ 
         $app = $this->app;
 
         if (property_exists($app, 'router')) {
-            $app->router->group(['namespace' => 'SwooleTW\Http\Controllers'], function ($app) {
+            $app->router->group(['namespace' => 'SwooleTW\Http\Controllers'], function($app) {
                 require __DIR__ . '/../routes/lumen_routes.php';
             });
         } else {
-            $app->group(['namespace' => 'App\Http\Controllers'], function ($app) {
+            $app->group(['namespace' => 'App\Http\Controllers'], function($app) {
                 require __DIR__ . '/../routes/lumen_routes.php';
             });
         }

src/HttpServiceProvider.php

Spacing +6 added lines, -6 removed lines

@@ -145,7 +145,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']);
         }
 
@@ -159,7 +159,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();
@@ -175,8 +175,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 = $this->getMergedDatabaseConfig($config, $name);
 
                 $connection = new MySqlConnection(
@@ -232,8 +232,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/Task/SwooleTaskQueue.php

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
      */
     public function pushRaw($payload, $queue = null, array $options = [])
     {
-        return $this->swoole->task($payload, ! is_numeric($queue) ? -1 : (int)$queue);
+        return $this->swoole->task($payload, !is_numeric($queue) ? -1 : (int) $queue);
     }
 
     /**
@@ -69,7 +69,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);
         });
     }

src/Task/QueueFactory.php

Spacing +2 added lines, -2 removed lines

@@ -41,7 +41,7 @@ 
     public static function make($server, string $version): SwooleTaskQueue
     {
         $isMatch = static::isFileVersionMatch($version);
-        $class = static::copy(static::stub($version), ! $isMatch);
+        $class = static::copy(static::stub($version), !$isMatch);
 
         return new $class($server);
     }
@@ -66,7 +66,7 @@ 
      */
     public static function copy(string $stub, bool $rewrite = false): string
     {
-        if (! file_exists(static::QUEUE_CLASS_PATH) || $rewrite) {
+        if (!file_exists(static::QUEUE_CLASS_PATH) || $rewrite) {
             copy($stub, static::QUEUE_CLASS_PATH);
         }
 

src/Controllers/SocketIOController.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 
     public function upgrade(Request $request)
     {
-        if (! in_array($request->input('transport'), $this->transports)) {
+        if (!in_array($request->input('transport'), $this->transports)) {
             return response()->json(
                 [
                     'code' => 0,

src/Transformers/Request.php

Spacing +2 added lines, -2 removed lines

@@ -158,7 +158,7 @@ 
             $key = str_replace('-', '_', $key);
             $key = strtoupper($key);
 
-            if (! in_array($key, ['REMOTE_ADDR', 'SERVER_PORT', 'HTTPS'])) {
+            if (!in_array($key, ['REMOTE_ADDR', 'SERVER_PORT', 'HTTPS'])) {
                 $key = 'HTTP_' . $key;
             }
 
@@ -187,7 +187,7 @@ 
             return false;
         }
 
-        if (! is_file($fileName) || ! filesize($fileName)) {
+        if (!is_file($fileName) || !filesize($fileName)) {
             return false;
         }
 

src/Websocket/Push.php

Spacing +1 added lines, -1 removed lines

@@ -189,7 +189,7 @@
      */
     public function isBroadcastToAllDescriptors(): bool
     {
-        return $this->isBroadcast() && ! $this->isAssigned() && count($this->descriptors) > 0;
+        return $this->isBroadcast() && !$this->isAssigned() && count($this->descriptors) > 0;
     }
 
     /**

src/Websocket/SocketIO/WebsocketHandler.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
      */
     public function onOpen($fd, Request $request)
     {
-        if (! $request->input('sid')) {
+        if (!$request->input('sid')) {
             $payload = json_encode(
                 [
                     'sid' => base64_encode(uniqid()),