hhxsv5 / laravel-s

src/Swoole/Timer/TimerTrait.php

Spacing +7 added lines, -7 removed lines

@@ -24,8 +24,8 @@ 
             $config['jobs'][] = CheckGlobalTimerAliveCronJob::class;
         }
 
-        $callback = function (Process $process) use ($swoole, $config, $laravelConfig) {
-            $pidfile = dirname($swoole->setting['pid_file']) . '/' . $this->timerPidFile;
+        $callback = function(Process $process) use ($swoole, $config, $laravelConfig) {
+            $pidfile = dirname($swoole->setting['pid_file']).'/'.$this->timerPidFile;
             file_put_contents($pidfile, $process->pid);
             $this->setProcessTitle(sprintf('%s laravels: timer process', $config['process_prefix']));
             $this->initLaravel($laravelConfig, $swoole);
@@ -39,13 +39,13 @@ 
 
             $timerIds = $this->registerTimers($config['jobs']);
 
-            Process::signal(SIGUSR1, function ($signo) use ($config, $timerIds, $process) {
+            Process::signal(SIGUSR1, function($signo) use ($config, $timerIds, $process) {
                 foreach ($timerIds as $timerId) {
                     if (Timer::exists($timerId)) {
                         Timer::clear($timerId);
                     }
                 }
-                Timer::after($config['max_wait_time'] * 1000, function () use ($process) {
+                Timer::after($config['max_wait_time'] * 1000, function() use ($process) {
                     $process->exit(0);
                 });
             });
@@ -76,9 +76,9 @@ 
             if (empty($job->interval())) {
                 throw new \InvalidArgumentException(sprintf('The interval of %s cannot be empty', get_class($job)));
             }
-            $runJob = function () use ($job) {
-                $runCallback = function () use ($job) {
-                    $this->callWithCatchException(function () use ($job) {
+            $runJob = function() use ($job) {
+                $runCallback = function() use ($job) {
+                    $this->callWithCatchException(function() use ($job) {
                         if (($job instanceof CheckGlobalTimerAliveCronJob) || $job::isEnable()) {
                             $job->run();
                         }

src/Swoole/Timer/RenewGlobalTimerLockCronJob.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 {
     public function interval()
     {
-        return (int)(static::GLOBAL_TIMER_LOCK_SECONDS * 0.9) * 1000;
+        return (int) (static::GLOBAL_TIMER_LOCK_SECONDS * 0.9) * 1000;
     }
 
     public function isImmediate()

src/Swoole/Timer/CronJob.php

Spacing +5 added lines, -5 removed lines

@@ -92,7 +92,7 @@ 
 
     public static function getGlobalTimerCacheKey()
     {
-        return 'laravels:timer:' . strtolower(self::$globalTimerLockKey);
+        return 'laravels:timer:'.strtolower(self::$globalTimerLockKey);
     }
 
     public static function getGlobalTimerLock()
@@ -105,7 +105,7 @@ 
         $expire = self::GLOBAL_TIMER_LOCK_SECONDS;
         $result = $redis->set($key, $value, 'ex', $expire, 'nx');
         // Compatible with Predis and PhpRedis
-        return $result === true || ((string)$result === 'OK');
+        return $result === true || ((string) $result === 'OK');
     }
 
     protected static function getCurrentInstanceId()
@@ -117,7 +117,7 @@ 
     {
         /**@var \Illuminate\Redis\Connections\PhpRedisConnection $redis */
         $redis = app('redis');
-        return (bool)$redis->exists(self::getGlobalTimerCacheKey());
+        return (bool) $redis->exists(self::getGlobalTimerCacheKey());
     }
 
     public static function isCurrentTimerAlive()
@@ -133,7 +133,7 @@ 
     {
         /**@var \Illuminate\Redis\Connections\PhpRedisConnection $redis */
         $redis = app('redis');
-        return (bool)$redis->expire(self::getGlobalTimerCacheKey(), $expire);
+        return (bool) $redis->expire(self::getGlobalTimerCacheKey(), $expire);
     }
 
     public static function setGlobalTimerLockKey($lockKey)
@@ -143,7 +143,7 @@ 
 
     public static function setEnable($enable)
     {
-        self::$enable = (bool)$enable;
+        self::$enable = (bool) $enable;
     }
 
     public static function isEnable()

src/Swoole/Timer/CheckGlobalTimerAliveCronJob.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 {
     public function interval()
     {
-        return (int)(static::GLOBAL_TIMER_LOCK_SECONDS * 0.9) * 1000;
+        return (int) (static::GLOBAL_TIMER_LOCK_SECONDS * 0.9) * 1000;
     }
 
     public function isImmediate()

src/Components/Apollo/Process.php

Spacing +3 added lines, -3 removed lines

@@ -20,7 +20,7 @@ 
                 'class'    => self::class,
                 'redirect' => false,
                 'pipe'     => 0,
-                'enable'   => (bool)getenv('ENABLE_APOLLO'),
+                'enable'   => (bool) getenv('ENABLE_APOLLO'),
             ],
         ];
     }
@@ -29,11 +29,11 @@ 
     {
         $filename = base_path('.env');
         if (isset($_ENV['APP_ENV'])) {
-            $filename .= '.' . $_ENV['APP_ENV'];
+            $filename .= '.'.$_ENV['APP_ENV'];
         }
 
         self::$apollo = Client::createFromEnv();
-        self::$apollo->startWatchNotification(function (array $notifications) use ($process, $filename) {
+        self::$apollo->startWatchNotification(function(array $notifications) use ($process, $filename) {
             $configs = self::$apollo->pullAllAndSave($filename);
             app('log')->info('[ApolloProcess] Pull all configurations', $configs);
             $process->exec(PHP_BINARY, [base_path('bin/laravels'), 'reload']);

src/Swoole/Server.php

Spacing +15 added lines, -15 removed lines

@@ -37,7 +37,7 @@ 
 
         $ip = isset($conf['listen_ip']) ? $conf['listen_ip'] : '127.0.0.1';
         $port = isset($conf['listen_port']) ? $conf['listen_port'] : 5200;
-        $socketType = isset($conf['socket_type']) ? (int)$conf['socket_type'] : SWOOLE_SOCK_TCP;
+        $socketType = isset($conf['socket_type']) ? (int) $conf['socket_type'] : SWOOLE_SOCK_TCP;
 
         if ($socketType === SWOOLE_SOCK_UNIX_STREAM) {
             $socketDir = dirname($ip);
@@ -93,7 +93,7 @@ 
 
     protected function triggerWebSocketEvent($event, array $params)
     {
-        return $this->callWithCatchException(function () use ($event, $params) {
+        return $this->callWithCatchException(function() use ($event, $params) {
             $handler = $this->getWebSocketHandler();
 
             if (method_exists($handler, $event)) {
@@ -108,19 +108,19 @@ 
     protected function bindWebSocketEvents()
     {
         if ($this->enableWebSocket) {
-            $this->swoole->on('HandShake', function () {
+            $this->swoole->on('HandShake', function() {
                 return $this->triggerWebSocketEvent('onHandShake', func_get_args());
             });
 
-            $this->swoole->on('Open', function () {
+            $this->swoole->on('Open', function() {
                 $this->triggerWebSocketEvent('onOpen', func_get_args());
             });
 
-            $this->swoole->on('Message', function () {
+            $this->swoole->on('Message', function() {
                 $this->triggerWebSocketEvent('onMessage', func_get_args());
             });
 
-            $this->swoole->on('Close', function (WebSocketServer $server, $fd, $reactorId) {
+            $this->swoole->on('Close', function(WebSocketServer $server, $fd, $reactorId) {
                 $clientInfo = $server->getClientInfo($fd);
                 if (isset($clientInfo['websocket_status']) && $clientInfo['websocket_status'] === \WEBSOCKET_STATUS_FRAME) {
                     $this->triggerWebSocketEvent('onClose', func_get_args());
@@ -132,7 +132,7 @@ 
 
     protected function triggerPortEvent(Port $port, $handlerClass, $event, array $params)
     {
-        return $this->callWithCatchException(function () use ($port, $handlerClass, $event, $params) {
+        return $this->callWithCatchException(function() use ($port, $handlerClass, $event, $params) {
             $handler = $this->getSocketHandler($port, $handlerClass);
 
             if (method_exists($handler, $event)) {
@@ -177,8 +177,8 @@ 
                 'BufferEmpty',
             ];
             foreach ($events as $event) {
-                $port->on($event, function () use ($port, $handlerClass, $event) {
-                    $this->triggerPortEvent($port, $handlerClass, 'on' . $event, func_get_args());
+                $port->on($event, function() use ($port, $handlerClass, $event) {
+                    $this->triggerPortEvent($port, $handlerClass, 'on'.$event, func_get_args());
                 });
             }
         }
@@ -227,7 +227,7 @@ 
 
     protected function bindSwooleTables()
     {
-        $tables = isset($this->conf['swoole_tables']) ? (array)$this->conf['swoole_tables'] : [];
+        $tables = isset($this->conf['swoole_tables']) ? (array) $this->conf['swoole_tables'] : [];
         foreach ($tables as $name => $table) {
             $t = new Table($table['size']);
             foreach ($table['column'] as $column) {
@@ -324,7 +324,7 @@ 
         $headers = [
             'Upgrade'               => 'websocket',
             'Connection'            => 'Upgrade',
-            'Sec-WebSocket-Accept'  => base64_encode(sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
+            'Sec-WebSocket-Accept'  => base64_encode(sha1($secKey.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
             'Sec-WebSocket-Version' => '13',
         ];
 
@@ -370,7 +370,7 @@ 
             if (!($listener instanceof Listener)) {
                 throw new \InvalidArgumentException(sprintf('%s must extend the abstract class %s', $listenerClass, Listener::class));
             }
-            $this->callWithCatchException(function () use ($listener) {
+            $this->callWithCatchException(function() use ($listener) {
                 $listener->handle();
             }, [], $event->getTries());
         }
@@ -379,7 +379,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -388,7 +388,7 @@ 
     protected function fireEvent($event, $interface, array $arguments)
     {
         if (isset($this->conf['event_handlers'][$event])) {
-            $eventHandlers = (array)$this->conf['event_handlers'][$event];
+            $eventHandlers = (array) $this->conf['event_handlers'][$event];
             foreach ($eventHandlers as $eventHandler) {
                 if (!isset(class_implements($eventHandler)[$interface])) {
                     throw new \InvalidArgumentException(sprintf(
@@ -398,7 +398,7 @@ 
                         )
                     );
                 }
-                $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+                $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                     call_user_func_array([(new $eventHandler), 'handle'], $arguments);
                 });
             }

src/Components/HttpClient/SimpleHttpTrait.php

Spacing +3 added lines, -3 removed lines

@@ -31,10 +31,10 @@ 
             $parts = parse_url($url);
             $path = isset($parts['path']) ? $parts['path'] : '/';
             if (isset($parts['query'])) {
-                $path .= '?' . $parts['query'];
+                $path .= '?'.$parts['query'];
             }
             if (isset($parts['fragment'])) {
-                $path .= '#' . $parts['fragment'];
+                $path .= '#'.$parts['fragment'];
             }
             $client = new CoroutineClient($parts['host'], isset($parts['port']) ? $parts['port'] : 80, isset($parts['scheme']) && $parts['scheme'] === 'https');
             if (isset($options['timeout'])) {
@@ -90,7 +90,7 @@ 
                 continue;
             }
             if (isset($headers[$key])) {
-                $headers[$key] = (array)$headers[$key];
+                $headers[$key] = (array) $headers[$key];
                 $headers[$key][] = isset($middle[1]) ? trim($middle[1]) : '';
             } else {
                 $headers[$key] = isset($middle[1]) ? trim($middle[1]) : '';

src/Swoole/Request.php

Spacing +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
                 $server[$headerServerMapping[$key]] = $value;
             } else {
                 $key = str_replace('-', '_', $key);
-                $server['http_' . $key] = $value;
+                $server['http_'.$key] = $value;
             }
         }
         $server = array_change_key_case($server, CASE_UPPER);
@@ -65,7 +65,7 @@ 
             && isset($_SERVER['QUERY_STRING'])
             && $_SERVER['QUERY_STRING'] !== ''
         ) {
-            $_SERVER['REQUEST_URI'] .= '?' . $_SERVER['QUERY_STRING'];
+            $_SERVER['REQUEST_URI'] .= '?'.$_SERVER['QUERY_STRING'];
         }
 
         // Fix argv & argc

src/Illuminate/Laravel.php

Spacing +11 added lines, -11 removed lines

@@ -82,7 +82,7 @@ 
         self::autoload($this->conf['root_path']);
 
         // Make kernel for Laravel
-        $app = require $this->conf['root_path'] . '/bootstrap/app.php';
+        $app = require $this->conf['root_path'].'/bootstrap/app.php';
         $kernel = $this->conf['is_lumen'] ? null : $app->make(HttpKernel::class);
 
         // Boot
@@ -102,14 +102,14 @@ 
     {
         $cfgPaths = [
             // Framework default configuration
-            $this->conf['root_path'] . '/vendor/laravel/lumen-framework/config/',
+            $this->conf['root_path'].'/vendor/laravel/lumen-framework/config/',
             // App configuration
-            $this->conf['root_path'] . '/config/',
+            $this->conf['root_path'].'/config/',
         ];
 
         $keys = [];
         foreach ($cfgPaths as $cfgPath) {
-            $configs = (array)glob($cfgPath . '*.php');
+            $configs = (array) glob($cfgPath.'*.php');
             foreach ($configs as $config) {
                 $config = substr(basename($config), 0, -4);
                 $keys[$config] = $config;
@@ -123,11 +123,11 @@ 
 
     public static function autoload($rootPath)
     {
-        $autoload = $rootPath . '/bootstrap/autoload.php';
+        $autoload = $rootPath.'/bootstrap/autoload.php';
         if (file_exists($autoload)) {
             require_once $autoload;
         } else {
-            require_once $rootPath . '/vendor/autoload.php';
+            require_once $rootPath.'/vendor/autoload.php';
         }
     }
 
@@ -156,7 +156,7 @@ 
         }
 
         // prefer content in response, secondly ob
-        if (!($response instanceof StreamedResponse) && (string)$content === '' && ob_get_length() > 0) {
+        if (!($response instanceof StreamedResponse) && (string) $content === '' && ob_get_length() > 0) {
             $response->setContent(ob_get_contents());
         }
 
@@ -173,7 +173,7 @@ 
         }
         $uri = urldecode($uri);
 
-        $requestFile = $this->conf['static_path'] . $uri;
+        $requestFile = $this->conf['static_path'].$uri;
         if (is_file($requestFile)) {
             return $this->createStaticResponse($requestFile, $request);
         }
@@ -189,9 +189,9 @@ 
 
     protected function lookupIndex($folder)
     {
-        $folder = rtrim($folder, '/') . '/';
+        $folder = rtrim($folder, '/').'/';
         foreach (self::$staticIndexList as $index) {
-            $tmpFile = $folder . $index;
+            $tmpFile = $folder.$index;
             if (is_file($tmpFile)) {
                 return $tmpFile;
             }
@@ -232,7 +232,7 @@ 
 
     public function bindSwoole($swoole)
     {
-        $this->currentApp->singleton('swoole', function () use ($swoole) {
+        $this->currentApp->singleton('swoole', function() use ($swoole) {
             return $swoole;
         });
     }