Portal::configure() - Code Metrics - Inspection of "optimize starting by "-d extension=swoole"" - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 699939...ec5bf1 )

by Biao

created 2021-01-16 05:45 UTC

Portal::configure() A

↳ Parent: Portal

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	1
eloc	8
c	2
b	0
f	0
nc	1
nop	0
dl	0
loc	11
rs	10

<?php


namespace Hhxsv5\LaravelS\Console;

use Hhxsv5\LaravelS\Components\Apollo\Client;
use Hhxsv5\LaravelS\Illuminate\LogTrait;
use Hhxsv5\LaravelS\LaravelS;
use Swoole\Process;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

class Portal extends Command

{
    use LogTrait;


    /**@var string */

    protected $basePath;

    /**@var InputInterface */

    protected $input;

    /**@var OutputInterface */

    protected $output;

    public function __construct($basePath)

    {
        parent::__construct('laravels');
        $this->basePath = $basePath;
    }

    protected function configure()

    {
        $this->setDescription('LaravelS console tool');
        $this->setHelp('LaravelS console tool');

        $this->addArgument('action', InputArgument::OPTIONAL, 'start|stop|restart|reload|info|help', 'help');
        $this->addOption('env', 'e', InputOption::VALUE_OPTIONAL, 'The environment the command should run under, this feature requires Laravel 5.2+');
        $this->addOption('daemonize', 'd', InputOption::VALUE_NONE, 'Run as a daemon');
        $this->addOption('ignore', 'i', InputOption::VALUE_NONE, 'Ignore checking PID file of Master process');
        $this->addOption('x-version', 'x', InputOption::VALUE_OPTIONAL, 'The version(branch) of the current project, stored in $_ENV/$_SERVER');
        Client::attachCommandOptions($this);
    }

    protected function execute(InputInterface $input, OutputInterface $output)

    {
        $this->input = $input;
        $this->output = $output;
        LaravelS::setOutputStyle(new SymfonyStyle($this->input, $this->output));

        try {
            $action = $input->getArgument('action');
            switch ($action) {
                case 'start':

                    return $this->start();
                case 'stop':

                    return $this->stop();
                case 'restart':

                    return $this->restart();
                case 'reload':

                    return $this->reload();
                case 'info':

                    return $this->showInfo();
                default:

                    $help = <<<EOS

Usage: 
  [%s] ./bin/laravels [options] <action>

Arguments:
  action                start|stop|restart|reload|info|help

Options:
  -e, --env             The environment the command should run under, this feature requires Laravel 5.2+
  -d, --daemonize       Run as a daemon
  -i, --ignore          Ignore checking PID file of Master process
  -x, --x-version       The version(branch) of the current project, stored in \$_ENV/\$_SERVER
EOS;

                    $this->info(sprintf($help, PHP_BINARY));
                    return 0;
            }
        } catch (\Exception $e) {
            $error = sprintf(
                'Uncaught exception "%s"([%d]%s) at %s:%s, %s%s',
                get_class($e),
                $e->getCode(),
                $e->getMessage(),
                $e->getFile(),
                $e->getLine(),
                PHP_EOL,
                $e->getTraceAsString()
            );
            $this->error($error);
            return 1;
        }
    }

    public function start()

    {
        if (!extension_loaded('swoole')) {
            $this->error('LaravelS requires swoole extension, try to `pecl install swoole` and `php --ri swoole`.');
            return 1;
        }

        // Generate conf file storage/laravels.conf
        $options = $this->input->getOptions();
        if (isset($options['env']) && $options['env'] !== '') {
            $_SERVER['APP_ENV'] = $_ENV['APP_ENV'] = $options['env'];
        }
        if (isset($options['x-version']) && $options['x-version'] !== '') {
            $_SERVER['X_VERSION'] = $_ENV['X_VERSION'] = $options['x-version'];
        }

        // Load Apollo configurations to .env file
        if (!empty($options['enable-apollo'])) {
            $this->loadApollo($options);
        }

        $passOptionStr = '';
        $passOptions = ['daemonize', 'ignore', 'x-version'];
        foreach ($passOptions as $key) {
            if (!isset($options[$key])) {
                continue;
            }
            $value = $options[$key];
            if ($value === false) {
                continue;
            }
            $passOptionStr .= sprintf('--%s%s ', $key, is_bool($value) ? '' : ('=' . $value));
        }
        $statusCode = self::runArtisanCommand($this->basePath, trim('laravels config ' . $passOptionStr));
        if ($statusCode !== 0) {
            return $statusCode;
        }

        // Here we go...
        $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']);
            if ($pid > 0 && self::kill($pid, 0)) {
                $this->warning(sprintf('Swoole[PID=%d] is already running.', $pid));
                return 1;
            }
        }

        if ($config['server']['swoole']['daemonize']) {
            $this->trace('Swoole is running in daemon mode, see "ps -ef|grep laravels".');
        } else {
            $this->trace('Swoole is running, press Ctrl+C to quit.');
        }

        (new LaravelS($config['server'], $config['laravel']))->run();

        return 0;
    }

    public function stop()

    {
        $config = $this->getConfig();
        $pidFile = $config['server']['swoole']['pid_file'];
        if (!file_exists($pidFile)) {
            $this->warning('It seems that Swoole is not running.');
            return 0;
        }

        $pid = file_get_contents($pidFile);
        if (!self::kill($pid, 0)) {
$a = canBeFalseAndNull();

// Instead of
if ( ! $a) { }

// Better use one of the explicit versions:
if ($a !== null) { }
if ($a !== false) { }
if ($a !== null && $a !== false) { }
            $this->warning("Swoole [PID={$pid}] does not exist, or permission denied.");
            return 0;
        }
        if (!self::kill($pid, SIGTERM)) {
$a = canBeFalseAndNull();

// Instead of
if ( ! $a) { }

// Better use one of the explicit versions:
if ($a !== null) { }
if ($a !== false) { }
if ($a !== null && $a !== false) { }
            $this->error("Swoole [PID={$pid}] is stopped failed.");
            return 1;
        }
        // Make sure that master process quit
        $time = 1;
        $waitTime = isset($config['server']['swoole']['max_wait_time']) ? $config['server']['swoole']['max_wait_time'] : 60;
        $this->info("The max time of waiting to forcibly stop is {$waitTime}s.");
        while (self::kill($pid, 0)) {
            if ($time > $waitTime) {
                $this->warning("Swoole [PID={$pid}] cannot be stopped gracefully in {$waitTime}s, will be stopped forced right now.");
                return 1;
            }
            $this->info("Waiting Swoole[PID={$pid}] to stop. [{$time}]");
            sleep(1);
            $time++;
        }
        $basePath = dirname($pidFile);
        $deleteFiles = [
            $pidFile,
            $basePath . '/laravels-custom-processes.pid',
            $basePath . '/laravels-timer-process.pid',
        ];
        foreach ($deleteFiles as $deleteFile) {
            if (file_exists($deleteFile)) {
                unlink($deleteFile);
            }
        }
        $this->info("Swoole [PID={$pid}] is stopped.");
        return 0;
    }

    public function restart()

    {
        $code = $this->stop();
        if ($code !== 0) {
            return $code;
        }
        return $this->start();
    }

    public function reload()

    {
        $config = $this->getConfig();
        $pidFile = $config['server']['swoole']['pid_file'];
        if (!file_exists($pidFile)) {
            $this->error('It seems that Swoole is not running.');
            return 1;
        }

        // Reload worker processes
        $pid = file_get_contents($pidFile);
        if (!$pid || !self::kill($pid, 0)) {
$a = canBeFalseAndNull();

// Instead of
if ( ! $a) { }

// Better use one of the explicit versions:
if ($a !== null) { }
if ($a !== false) { }
if ($a !== null && $a !== false) { }
            $this->error("Swoole [PID={$pid}] does not exist, or permission denied.");
            return 1;
        }
        if (self::kill($pid, SIGUSR1)) {
            $this->info("Swoole [PID={$pid}] is reloaded.");
        } else {
            $this->error("Swoole [PID={$pid}] is reloaded failed.");
        }

        // Reload custom processes
        $pidFile = dirname($pidFile) . '/laravels-custom-processes.pid';
        if (file_exists($pidFile)) {
            $pids = (array)explode("\n", trim(file_get_contents($pidFile)));
            unlink($pidFile);
            foreach ($pids as $pid) {
                if (!$pid || !self::kill($pid, 0)) {
$a = canBeFalseAndNull();

// Instead of
if ( ! $a) { }

// Better use one of the explicit versions:
if ($a !== null) { }
if ($a !== false) { }
if ($a !== null && $a !== false) { }
                    $this->error("Custom process[PID={$pid}] does not exist, or permission denied.");
                    continue;
                }

                if (self::kill($pid, SIGUSR1)) {
                    $this->info("Custom process[PID={$pid}] is reloaded.");
                } else {
                    $this->error("Custom process[PID={$pid}] is reloaded failed.");
                }
            }
        }

        // Reload timer process
        if (!empty($config['server']['timer']['enable']) && !empty($config['server']['timer']['jobs'])) {
            $pidFile = dirname($pidFile) . '/laravels-timer-process.pid';
            $pid = file_get_contents($pidFile);
            if (!$pid || !self::kill($pid, 0)) {
$a = canBeFalseAndNull();

// Instead of
if ( ! $a) { }

// Better use one of the explicit versions:
if ($a !== null) { }
if ($a !== false) { }
if ($a !== null && $a !== false) { }
                $this->error("Timer process[PID={$pid}] does not exist, or permission denied.");
                return 1;
            }

            if (self::kill($pid, SIGUSR1)) {
                $this->info("Timer process[PID={$pid}] is reloaded.");
            } else {
                $this->error("Timer process[PID={$pid}] is reloaded failed.");
            }
        }
        return 0;
    }

    public function showInfo()

    {
        return self::runArtisanCommand($this->basePath, 'laravels info');
    }

    public function loadApollo(array $options)

    {
        Client::putCommandOptionsToEnv($options);
        $envFile = $this->basePath . '/.env';
        if (isset($options['env'])) {
            $envFile .= '.' . $options['env'];
        }
        Client::createFromCommandOptions($options)->pullAllAndSave($envFile);
    }

    protected static function makeArtisanCmd($basePath, $subCmd)

    {
        $phpCmd = self::makePhpCmd();
        $env = isset($_ENV['APP_ENV']) ? trim($_ENV['APP_ENV']) : '';
        $appEnv = $env === '' ? '' : "APP_ENV={$env}";
        return trim(sprintf('%s %s %s/artisan %s', $appEnv, $phpCmd, $basePath, $subCmd));
    }

    protected static function makeLaravelSCmd($basePath, $subCmd)

    {
        $phpCmd = self::makePhpCmd();
        return trim(sprintf('%s %s/bin/laravels %s', $phpCmd, $basePath, $subCmd));
    }

    protected static function makePhpCmd($subCmd = '')

    {
        $iniFile = php_ini_loaded_file();
        if ($iniFile === false) {
            $phpCmd = PHP_BINARY;
        } else {
            $phpCmd = sprintf('%s -c "%s"', PHP_BINARY, $iniFile);
        }

        $checkSwooleCmd = $phpCmd . ' --ri swoole';
        $checkOutput = (string)shell_exec($checkSwooleCmd);
        if (stripos($checkOutput, 'enabled') === false) {
            $phpCmd .= ' -d "extension=swoole"';
        }
        return trim($phpCmd . ' ' . $subCmd);
    }

    public static function runArtisanCommand($basePath, $cmd)

    {
        $cmd = self::makeArtisanCmd($basePath, $cmd);
        return self::runCommand($cmd);
    }

    public static function runLaravelSCommand($basePath, $cmd)

    {
        $cmd = self::makeLaravelSCmd($basePath, $cmd);
        return self::runCommand($cmd);
    }

    public function getConfig()

    {
        return unserialize((string)file_get_contents($this->getConfPath()));
    }

    protected function getConfPath()

    {
        return $this->basePath . '/storage/laravels.conf';
    }

    public static function runCommand($cmd, $input = null)

    {
        $fp = popen($cmd, 'w');
        if ($fp === false) {
            return false;
        }
        if ($input !== null) {
            $bytes = fwrite($fp, $input);
            if ($bytes === false) {
                return 1;
            }
        }
        return pclose($fp);
    }

    public static function kill($pid, $sig)

    {
        try {
            return Process::kill((int)$pid, $sig);
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
        } catch (\Exception $e) {
            return false;
        }
    }
}


1			<?php
2
			0 ignored issues – show Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report Missing file doc comment Loading history...
3			namespace Hhxsv5\LaravelS\Console;
4
5			use Hhxsv5\LaravelS\Components\Apollo\Client;
6			use Hhxsv5\LaravelS\Illuminate\LogTrait;
7			use Hhxsv5\LaravelS\LaravelS;
8			use Swoole\Process;
9			use Symfony\Component\Console\Command\Command;
10			use Symfony\Component\Console\Input\InputArgument;
11			use Symfony\Component\Console\Input\InputInterface;
12			use Symfony\Component\Console\Input\InputOption;
13			use Symfony\Component\Console\Output\OutputInterface;
14			use Symfony\Component\Console\Style\SymfonyStyle;
15
16			class Portal extends Command
			0 ignored issues – show Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report Missing doc comment for class Portal Loading history...
17			{
18			use LogTrait;
19
20
21			/*@var string /
			0 ignored issues – show Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report The open comment tag must be the only content on the line Loading history... Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report Missing short description in doc comment Loading history... Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report The close comment tag must be the only content on the line Loading history...
22			protected $basePath;
23
24			/*@var InputInterface /
			0 ignored issues – show Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report The open comment tag must be the only content on the line Loading history... Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report Missing short description in doc comment Loading history... Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report The close comment tag must be the only content on the line Loading history...
25			protected $input;
26
27			/*@var OutputInterface /
			0 ignored issues – show Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report The open comment tag must be the only content on the line Loading history... Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report Missing short description in doc comment Loading history... Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report The close comment tag must be the only content on the line Loading history...
28			protected $output;
29
30			public function __construct($basePath)
			0 ignored issues – show Coding Style introduced 2020-06-04 11:11 UTC by Report Bug Copy Issue Report Missing doc comment for function __construct() Loading history...
31			{
32			parent::__construct('laravels');
33			$this->basePath = $basePath;
34			}

hhxsv5 / laravel-s

Push — master ( 699939...ec5bf1 )

Portal::configure() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like