hhxsv5 / laravel-s

src/Components/Prometheus/ServiceProvider.php

Spacing +8 added lines, -8 removed lines

@@ -15,31 +15,31 @@
     public function boot()
     {
         $this->publishes([
-            __DIR__ . '/../../../config/prometheus.php' => base_path('config/prometheus.php'),
+            __DIR__.'/../../../config/prometheus.php' => base_path('config/prometheus.php'),
         ]);
     }
 
     public function register()
     {
         $this->mergeConfigFrom(
-            __DIR__ . '/../../../config/prometheus.php', 'prometheus'
+            __DIR__.'/../../../config/prometheus.php', 'prometheus'
         );
-        $this->app->singleton(RequestMiddleware::class, function ($app) {
+        $this->app->singleton(RequestMiddleware::class, function($app) {
             return new RequestMiddleware($app->make(HttpRequestCollector::class));
         });
-        $this->app->singleton(HttpRequestCollector::class, function ($app) {
+        $this->app->singleton(HttpRequestCollector::class, function($app) {
             return new HttpRequestCollector($app['config']->get('prometheus'));
         });
-        $this->app->singleton(SwooleProcessCollector::class, function ($app) {
+        $this->app->singleton(SwooleProcessCollector::class, function($app) {
             return new SwooleProcessCollector($app['config']->get('prometheus'));
         });
-        $this->app->singleton(SwooleStatsCollector::class, function ($app) {
+        $this->app->singleton(SwooleStatsCollector::class, function($app) {
             return new SwooleStatsCollector($app['config']->get('prometheus'));
         });
-        $this->app->singleton(SystemCollector::class, function ($app) {
+        $this->app->singleton(SystemCollector::class, function($app) {
             return new SystemCollector($app['config']->get('prometheus'));
         });
-        $this->app->singleton(Exporter::class, function ($app) {
+        $this->app->singleton(Exporter::class, function($app) {
             return new Exporter($app['config']->get('prometheus'));
         });
     }

src/Components/Prometheus/Collectors/HttpRequestCollector.php

Spacing +9 added lines, -9 removed lines

@@ -20,26 +20,26 @@ 
         if ($routes instanceof \Illuminate\Routing\RouteCollection) { // Laravel
             foreach ($routes->getRoutes() as $route) {
                 $method = $route->methods()[0];
-                $uri = '/' . ltrim($route->uri(), '/');
-                $this->routes[$method . $uri] = $uri;
+                $uri = '/'.ltrim($route->uri(), '/');
+                $this->routes[$method.$uri] = $uri;
 
                 $action = $route->getAction();
                 if (is_string($action['uses'])) { // Uses
-                    $this->routesByUses[$method . $action['uses']] = $uri;
+                    $this->routesByUses[$method.$action['uses']] = $uri;
                 } elseif ($action['uses'] instanceof Closure) {  // Closure
                     $objectId = spl_object_hash($action['uses']);
-                    $this->routesByClosure[$method . $objectId] = $uri;
+                    $this->routesByClosure[$method.$objectId] = $uri;
                 }
             }
         } elseif (is_array($routes)) { // Lumen
             $this->routes = $routes;
             foreach ($routes as $route) {
                 if (isset($route['action']['uses'])) { // Uses
-                    $this->routesByUses[$route['method'] . $route['action']['uses']] = $route['uri'];
+                    $this->routesByUses[$route['method'].$route['action']['uses']] = $route['uri'];
                 }
                 if (isset($route['action'][0]) && $route['action'][0] instanceof Closure) { // Closure
                     $objectId = spl_object_hash($route['action'][0]);
-                    $this->routesByClosure[$route['method'] . $objectId] = $route['uri'];
+                    $this->routesByClosure[$route['method'].$objectId] = $route['uri'];
                 }
             }
         }
@@ -82,7 +82,7 @@ 
     {
         $method = $request->getMethod();
         $uri = $request->getPathInfo();
-        $key = $method . $uri;
+        $key = $method.$uri;
         if (isset($this->routes[$key])) {
             return $uri;
         }
@@ -92,12 +92,12 @@ 
             $uri = $route->uri();
         } elseif (is_array($route)) { // Lumen
             if (isset($route[1]['uses'])) {
-                $key = $method . $route[1]['uses'];
+                $key = $method.$route[1]['uses'];
                 if (isset($this->routesByUses[$key])) {
                     $uri = $this->routesByUses[$key];
                 }
             } elseif (isset($route[1][0]) && $route[1][0] instanceof Closure) {
-                $key = $method . spl_object_hash($route[1][0]);
+                $key = $method.spl_object_hash($route[1][0]);
                 if (isset($this->routesByClosure[$key])) {
                     $uri = $this->routesByClosure[$key];
                 }

src/Swoole/Task/BaseTask.php

Spacing +3 added lines, -3 removed lines

@@ -28,7 +28,7 @@ 
         if ($delay < 0) {
             throw new \InvalidArgumentException('The delay must be greater than or equal to 0');
         }
-        $this->delay = (int)$delay;
+        $this->delay = (int) $delay;
         return $this;
     }
 
@@ -51,7 +51,7 @@ 
         if ($tries < 1) {
             throw new \InvalidArgumentException('The number of attempts must be greater than or equal to 1');
         }
-        $this->tries = (int)$tries;
+        $this->tries = (int) $tries;
         return $this;
     }
 
@@ -73,7 +73,7 @@ 
     {
         static $dispatch;
         if (!$dispatch) {
-            $dispatch = static function ($task) {
+            $dispatch = static function($task) {
                 /**@var \Swoole\Http\Server $swoole */
                 $swoole = app('swoole');
                 // The worker_id of timer process is -1

src/Console/Portal.php

Spacing +17 added lines, -17 removed lines

@@ -131,9 +131,9 @@ 
             if ($value === false) {
                 continue;
             }
-            $passOptionStr .= sprintf('--%s%s ', $key, is_bool($value) ? '' : ('=' . $value));
+            $passOptionStr .= sprintf('--%s%s ', $key, is_bool($value) ? '' : ('='.$value));
         }
-        $statusCode = self::runArtisanCommand($this->basePath, trim('laravels config ' . $passOptionStr));
+        $statusCode = self::runArtisanCommand($this->basePath, trim('laravels config '.$passOptionStr));
         if ($statusCode !== 0) {
             return $statusCode;
         }
@@ -142,7 +142,7 @@ 
         $config = $this->getConfig();
 
         if (!$config['server']['ignore_check_pid'] && file_exists($config['server']['swoole']['pid_file'])) {
-            $pid = (int)file_get_contents($config['server']['swoole']['pid_file']);
+            $pid = (int) file_get_contents($config['server']['swoole']['pid_file']);
             if ($pid > 0 && self::kill($pid, 0)) {
                 $this->warning(sprintf('Swoole[PID=%d] is already running.', $pid));
                 return 1;
@@ -194,8 +194,8 @@ 
         $basePath = dirname($pidFile);
         $deleteFiles = [
             $pidFile,
-            $basePath . '/laravels-custom-processes.pid',
-            $basePath . '/laravels-timer-process.pid',
+            $basePath.'/laravels-custom-processes.pid',
+            $basePath.'/laravels-timer-process.pid',
         ];
         foreach ($deleteFiles as $deleteFile) {
             if (file_exists($deleteFile)) {
@@ -237,9 +237,9 @@ 
         }
 
         // Reload custom processes
-        $pidFile = dirname($pidFile) . '/laravels-custom-processes.pid';
+        $pidFile = dirname($pidFile).'/laravels-custom-processes.pid';
         if (file_exists($pidFile)) {
-            $pids = (array)explode("\n", trim(file_get_contents($pidFile)));
+            $pids = (array) explode("\n", trim(file_get_contents($pidFile)));
             unlink($pidFile);
             foreach ($pids as $pid) {
                 if (!$pid || !self::kill($pid, 0)) {
@@ -257,7 +257,7 @@ 
 
         // Reload timer process
         if (!empty($config['server']['timer']['enable']) && !empty($config['server']['timer']['jobs'])) {
-            $pidFile = dirname($pidFile) . '/laravels-timer-process.pid';
+            $pidFile = dirname($pidFile).'/laravels-timer-process.pid';
             $pid = file_get_contents($pidFile);
             if (!$pid || !self::kill($pid, 0)) {
                 $this->error("Timer process[PID={$pid}] does not exist, or permission denied.");
@@ -281,9 +281,9 @@ 
     public function loadApollo(array $options)
     {
         Client::putCommandOptionsToEnv($options);
-        $envFile = $this->basePath . '/.env';
+        $envFile = $this->basePath.'/.env';
         if (isset($options['env'])) {
-            $envFile .= '.' . $options['env'];
+            $envFile .= '.'.$options['env'];
         }
         Client::createFromCommandOptions($options)->pullAllAndSave($envFile);
     }
@@ -314,12 +314,12 @@ 
         $checkSwooleCmd = $phpCmd.' --ri swoole';
         $checkOpenSwooleCmd = $phpCmd.' --ri openswoole';
         // Short-circuit, if Swoole is found Loaded already. If not, check for Open-Swoole as well.
-        if (stripos((string)shell_exec($checkSwooleCmd), 'enabled') === false
-          && stripos((string)shell_exec($checkOpenSwooleCmd), 'enabled') === false) {
+        if (stripos((string) shell_exec($checkSwooleCmd), 'enabled') === false
+          && stripos((string) shell_exec($checkOpenSwooleCmd), 'enabled') === false) {
             $phpCmd .= ' -d "extension=swoole"';
         }
         
-        return trim($phpCmd . ' ' . $subCmd);
+        return trim($phpCmd.' '.$subCmd);
     }
 
     public static function runArtisanCommand($basePath, $cmd)
@@ -336,16 +336,16 @@ 
 
     public function getConfig()
     {
-        return unserialize((string)file_get_contents($this->getConfigPath()));
+        return unserialize((string) file_get_contents($this->getConfigPath()));
     }
 
     protected function getConfigPath()
     {
         $storagePath = getenv('APP_STORAGE_PATH');
         if ($storagePath === false) {
-            $storagePath = $this->basePath . '/storage';
+            $storagePath = $this->basePath.'/storage';
         }
-        return $storagePath . '/laravels.conf';
+        return $storagePath.'/laravels.conf';
     }
 
     public static function runCommand($cmd, $input = null)
@@ -366,7 +366,7 @@ 
     public static function kill($pid, $sig)
     {
         try {
-            return Process::kill((int)$pid, $sig);
+            return Process::kill((int) $pid, $sig);
         } catch (\Exception $e) {
             return false;
         }

src/Swoole/Server.php

Spacing +15 added lines, -15 removed lines

@@ -38,7 +38,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);
@@ -100,7 +100,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)) {
@@ -115,19 +115,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());
@@ -139,7 +139,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)) {
@@ -184,8 +184,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());
                 });
             }
         }
@@ -224,7 +224,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) {
@@ -323,7 +323,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 @@ 
                 throw new \InvalidArgumentException(sprintf('%s must extend the abstract class %s', $listenerClass, Listener::class));
             }
 
-            $result = $this->callWithCatchException(function () use ($listener, $event) {
+            $result = $this->callWithCatchException(function() use ($listener, $event) {
                 return $listener->handle($event);
             }, [], $event->getTries());
 
@@ -382,7 +382,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -391,7 +391,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(
@@ -401,7 +401,7 @@ 
                         )
                     );
                 }
-                $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+                $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                     call_user_func_array([(new $eventHandler), 'handle'], $arguments);
                 });
             }

src/Illuminate/LaravelSCommand.php

Spacing +19 added lines, -19 removed lines

@@ -24,7 +24,7 @@ 
 
     public function handle()
     {
-        $action = (string)$this->argument('action');
+        $action = (string) $this->argument('action');
         switch ($action) {
             case 'publish':
                 $this->publish();
@@ -56,7 +56,7 @@ 
     {
         // Load configuration laravel.php manually for Lumen
         $basePath = config('laravels.laravel_base_path') ?: base_path();
-        if ($this->isLumen() && file_exists($basePath . '/config/laravels.php')) {
+        if ($this->isLumen() && file_exists($basePath.'/config/laravels.php')) {
             $this->getLaravel()->configure('laravels');
         }
     }
@@ -113,7 +113,7 @@ 
                 $laravelSVersion,
             ],
             [
-                $this->getApplication()->getName() . ' [<info>' . env('APP_ENV', config('app.env')) . '</info>]',
+                $this->getApplication()->getName().' [<info>'.env('APP_ENV', config('app.env')).'</info>]',
                 $this->getApplication()->getVersion(),
             ],
         ]);
@@ -123,7 +123,7 @@ 
     {
         $this->comment('>>> Protocols');
 
-        $config = unserialize((string)file_get_contents($this->getConfigPath()));
+        $config = unserialize((string) file_get_contents($this->getConfigPath()));
         $ssl = isset($config['server']['swoole']['ssl_key_file'], $config['server']['swoole']['ssl_cert_file']);
         $socketType = isset($config['server']['socket_type']) ? $config['server']['socket_type'] : SWOOLE_SOCK_TCP;
         if (in_array($socketType, [SWOOLE_SOCK_UNIX_DGRAM, SWOOLE_SOCK_UNIX_STREAM])) {
@@ -163,7 +163,7 @@ 
                 continue;
             }
 
-            $name = 'Port#' . $key . ' ';
+            $name = 'Port#'.$key.' ';
             $name .= isset($socketTypeNames[$socket['type']]) ? $socketTypeNames[$socket['type']] : 'Unknown socket';
             $tableRows [] = [
                 $name,
@@ -196,8 +196,8 @@ 
         $laravelConf = [
             'root_path'           => $svrConf['laravel_base_path'],
             'static_path'         => $svrConf['swoole']['document_root'],
-            'cleaners'            => array_unique((array)Arr::get($svrConf, 'cleaners', [])),
-            'register_providers'  => array_unique((array)Arr::get($svrConf, 'register_providers', [])),
+            'cleaners'            => array_unique((array) Arr::get($svrConf, 'cleaners', [])),
+            'register_providers'  => array_unique((array) Arr::get($svrConf, 'register_providers', [])),
             'destroy_controllers' => Arr::get($svrConf, 'destroy_controllers', []),
             'is_lumen'            => $this->isLumen(),
             '_SERVER'             => $_SERVER,
@@ -222,7 +222,7 @@ 
             $svrConf['laravel_base_path'] = base_path();
         }
         if (empty($svrConf['process_prefix'])) {
-            $svrConf['process_prefix'] = trim(config('app.name', '') . ' ' . $svrConf['laravel_base_path']);
+            $svrConf['process_prefix'] = trim(config('app.name', '').' '.$svrConf['laravel_base_path']);
         }
         if ($this->option('ignore')) {
             $svrConf['ignore_check_pid'] = true;
@@ -230,7 +230,7 @@ 
             $svrConf['ignore_check_pid'] = false;
         }
         if (empty($svrConf['swoole']['document_root'])) {
-            $svrConf['swoole']['document_root'] = $svrConf['laravel_base_path'] . '/public';
+            $svrConf['swoole']['document_root'] = $svrConf['laravel_base_path'].'/public';
         }
         if ($this->option('daemonize')) {
             $svrConf['swoole']['daemonize'] = true;
@@ -255,7 +255,7 @@ 
         }
 
         // Set X-Version
-        $xVersion = (string)$this->option('x-version');
+        $xVersion = (string) $this->option('x-version');
         if ($xVersion !== '') {
             $_SERVER['X_VERSION'] = $_ENV['X_VERSION'] = $xVersion;
         }
@@ -282,34 +282,34 @@ 
     public function publish()
     {
         $basePath = config('laravels.laravel_base_path') ?: base_path();
-        $configPath = $basePath . '/config/laravels.php';
+        $configPath = $basePath.'/config/laravels.php';
         $todoList = [
             [
-                'from' => realpath(__DIR__ . '/../../config/laravels.php'),
+                'from' => realpath(__DIR__.'/../../config/laravels.php'),
                 'to'   => $configPath,
                 'mode' => 0644,
             ],
             [
-                'from' => realpath(__DIR__ . '/../../bin/laravels'),
-                'to'   => $basePath . '/bin/laravels',
+                'from' => realpath(__DIR__.'/../../bin/laravels'),
+                'to'   => $basePath.'/bin/laravels',
                 'mode' => 0755,
                 'link' => true,
             ],
             [
-                'from' => realpath(__DIR__ . '/../../bin/fswatch'),
-                'to'   => $basePath . '/bin/fswatch',
+                'from' => realpath(__DIR__.'/../../bin/fswatch'),
+                'to'   => $basePath.'/bin/fswatch',
                 'mode' => 0755,
                 'link' => true,
             ],
             [
-                'from' => realpath(__DIR__ . '/../../bin/inotify'),
-                'to'   => $basePath . '/bin/inotify',
+                'from' => realpath(__DIR__.'/../../bin/inotify'),
+                'to'   => $basePath.'/bin/inotify',
                 'mode' => 0755,
                 'link' => true,
             ],
         ];
         if (file_exists($configPath)) {
-            $choice = $this->anticipate($configPath . ' already exists, do you want to override it ? Y/N',
+            $choice = $this->anticipate($configPath.' already exists, do you want to override it ? Y/N',
                 ['Y', 'N'],
                 'N'
             );