swooletw / laravel-swoole

copy_versioned_files.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-require __DIR__.'/vendor/autoload.php';
+require __DIR__ . '/vendor/autoload.php';
 
 use SwooleTW\Http\Coroutine\Connectors\ConnectorFactory;
 use SwooleTW\Http\Helpers\FW;

src/HttpServiceProvider.php

Spacing +6 added lines, -6 removed lines

@@ -147,7 +147,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,10 +163,10 @@ 
      */
     protected function registerDatabaseDriver()
     {
-        $this->app->resolving('db', function ($db) {
-            $db->extend('mysql-coroutine', function ($config, $name) {
+        $this->app->resolving('db', function($db) {
+            $db->extend('mysql-coroutine', function($config, $name) {
                 $config['name'] = $name;
-                $connection = function () use ($config) {
+                $connection = function() use ($config) {
                     return ConnectorFactory::make(FW::version())->connect($config);
                 };
 
@@ -185,8 +185,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/Task/SwooleTaskQueue.php

Spacing +2 added lines, -2 removed lines

@@ -55,7 +55,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);
     }
 
     /**
@@ -70,7 +70,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/Transformers/Response.php

Spacing +1 added lines, -1 removed lines

@@ -143,7 +143,7 @@
     protected function setIlluminateResponse($illuminateResponse)
     {
         if (!$illuminateResponse instanceof SymfonyResponse) {
-            $content = (string)$illuminateResponse;
+            $content = (string) $illuminateResponse;
             $illuminateResponse = new IlluminateResponse($content);
         }
 

src/Websocket/Middleware/DecryptCookies.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
      */
     public function disableFor($name)
     {
-        $this->except = array_merge($this->except, (array)$name);
+        $this->except = array_merge($this->except, (array) $name);
     }
 
     /**

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/Websocket/Rooms/RedisRoom.php

Spacing +2 added lines, -2 removed lines

@@ -140,7 +140,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->sadd($redisKey, $value);
             }
@@ -163,7 +163,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->srem($redisKey, $value);
             }

src/Websocket/SocketIO/Packet.php

Spacing +1 added lines, -1 removed lines

@@ -119,7 +119,7 @@
             return null;
         }
 
-        return (int)$type;
+        return (int) $type;
     }
 
     /**

src/Websocket/Websocket.php

Spacing +3 added lines, -3 removed lines

@@ -310,7 +310,7 @@ 
      */
     protected function getFds()
     {
-        $fds = array_filter($this->to, function ($value) {
+        $fds = array_filter($this->to, function($value) {
             return is_integer($value);
         });
         $rooms = array_diff($this->to, $fds);
@@ -387,7 +387,7 @@ 
     {
         $pipeline = $this->pipeline;
 
-        $closure = function () use ($container) {
+        $closure = function() use ($container) {
             $this->container = $container;
         };
 
@@ -429,7 +429,7 @@ 
         return $this->pipeline
             ->send($request)
             ->through($this->middleware)
-            ->then(function ($request) {
+            ->then(function($request) {
                 return $request;
             });
     }