hhxsv5 / laravel-s

src/Components/Apollo/Process.php

Spacing +3 added lines, -3 removed lines

@@ -21,7 +21,7 @@ 
                 'class'    => self::class,
                 'redirect' => false,
                 'pipe'     => 0,
-                'enable'   => (bool)getenv('ENABLE_APOLLO'),
+                'enable'   => (bool) getenv('ENABLE_APOLLO'),
             ],
         ];
     }
@@ -30,11 +30,11 @@ 
     {
         $filename = base_path('.env');
         if (isset($_ENV['_ENV'])) {
-            $filename .= '.' . $_ENV['_ENV'];
+            $filename .= '.'.$_ENV['_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);
             Portal::runLaravelSCommand(base_path(), 'reload');

src/Swoole/Process/CustomProcessTrait.php

Spacing +7 added lines, -7 removed lines

@@ -11,7 +11,7 @@ 
 
     public function addCustomProcesses(Server $swoole, $processPrefix, array $processes, array $laravelConfig)
     {
-        $pidfile = dirname($swoole->setting['pid_file']) . '/' . $this->customProcessPidFile;
+        $pidfile = dirname($swoole->setting['pid_file']).'/'.$this->customProcessPidFile;
         if (file_exists($pidfile)) {
             unlink($pidfile);
         }
@@ -26,9 +26,9 @@ 
                 continue;
             }
             $processClass = $item['class'];
-            $restartInterval = isset($item['restart_interval']) ? (int)$item['restart_interval'] : 5;
-            $callback = function (Process $worker) use ($pidfile, $swoole, $processPrefix, $processClass, $restartInterval, $name, $laravelConfig) {
-                file_put_contents($pidfile, $worker->pid . "\n", FILE_APPEND | LOCK_EX);
+            $restartInterval = isset($item['restart_interval']) ? (int) $item['restart_interval'] : 5;
+            $callback = function(Process $worker) use ($pidfile, $swoole, $processPrefix, $processClass, $restartInterval, $name, $laravelConfig) {
+                file_put_contents($pidfile, $worker->pid."\n", FILE_APPEND | LOCK_EX);
                 $this->initLaravel($laravelConfig, $swoole);
                 if (!isset(class_implements($processClass)[CustomProcessInterface::class])) {
                     throw new \InvalidArgumentException(
@@ -42,13 +42,13 @@ 
                 /**@var CustomProcessInterface $processClass */
                 $this->setProcessTitle(sprintf('%s laravels: %s process', $processPrefix, $name));
 
-                Process::signal(SIGUSR1, function ($signo) use ($name, $processClass, $worker, $pidfile, $swoole) {
+                Process::signal(SIGUSR1, function($signo) use ($name, $processClass, $worker, $pidfile, $swoole) {
                     $this->info(sprintf('Reloading %s process[PID=%d].', $name, $worker->pid));
                     $processClass::onReload($swoole, $worker);
                 });
 
                 if (method_exists($processClass, 'onStop')) {
-                    Process::signal(SIGTERM, function ($signo) use ($name, $processClass, $worker, $pidfile, $swoole) {
+                    Process::signal(SIGTERM, function($signo) use ($name, $processClass, $worker, $pidfile, $swoole) {
                         $this->info(sprintf('Stopping %s process[PID=%d].', $name, $worker->pid));
                         $processClass::onStop($swoole, $worker);
                     });
@@ -72,7 +72,7 @@ 
                 for ($i = 0; $i < $item['num']; $i++) {
                     $process = $this->makeProcess($callback, $item);
                     $swoole->addProcess($process);
-                    $processList[$name . $i] = $process;
+                    $processList[$name.$i] = $process;
                 }
             } else {  // For single process
                 $process = $this->makeProcess($callback, $item);