Serve::isAddressTaken() - Code Metrics - Inspection of "Kill other processes is port is taken" - yiisoft/yii-console - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — master (#211)

by Dmitriy

created 2024-06-24 05:20 UTC

Serve::isAddressTaken() A

↳ Parent: Serve

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	6
c	1
b	0
f	0
dl	0
loc	11
ccs	0
cts	0
cp	0
rs	10
cc	2
nc	2
nop	1
crap	6

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Console\Command;

use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Completion\CompletionInput;
use Symfony\Component\Console\Completion\CompletionSuggestions;
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;
use Yiisoft\Yii\Console\ExitCode;

use function explode;
use function fclose;
use function file_exists;
use function fsockopen;
use function is_dir;
use function passthru;

#[AsCommand('serve', 'Runs PHP built-in web server')]
final class Serve extends Command
{
    public const EXIT_CODE_NO_DOCUMENT_ROOT = 2;
    public const EXIT_CODE_NO_ROUTING_FILE = 3;
    public const EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS = 5;

    private string $defaultAddress;
    private string $defaultPort;
    private string $defaultDocroot;
    private string $defaultRouter;
    private int $defaultWorkers;

    /**
     * @psalm-param array{
     *     address?:non-empty-string,
     *     port?:non-empty-string,
     *     docroot?:string,
     *     router?:string,
     *     workers?:int|string
     * } $options
     */
    public function __construct(private ?string $appRootPath = null, ?array $options = [])
    {
        $this->defaultAddress = $options['address'] ?? '127.0.0.1';
        $this->defaultPort = $options['port'] ?? '8080';
        $this->defaultDocroot = $options['docroot'] ?? 'public';
        $this->defaultRouter = $options['router'] ?? 'public/index.php';
        $this->defaultWorkers = (int) ($options['workers'] ?? 2);

        parent::__construct();
    }

    public function configure(): void
    {
        $this
            ->setHelp(
                'In order to access server from remote machines use 0.0.0.0:8000. That is especially useful when running server in a virtual machine.'
            )
            ->addArgument('address', InputArgument::OPTIONAL, 'Host to serve at', $this->defaultAddress)
            ->addOption('port', 'p', InputOption::VALUE_OPTIONAL, 'Port to serve at', $this->defaultPort)
            ->addOption(
                'docroot',
                't',
                InputOption::VALUE_OPTIONAL,
                'Document root to serve from',
                $this->defaultDocroot
            )
            ->addOption('router', 'r', InputOption::VALUE_OPTIONAL, 'Path to router script', $this->defaultRouter)
            ->addOption(
                'workers',
                'w',
                InputOption::VALUE_OPTIONAL,
                'Workers number the server will start with',
                $this->defaultWorkers
            )
            ->addOption('env', 'e', InputOption::VALUE_OPTIONAL, 'It is only used for testing.')
            ->addOption('open', 'o', InputOption::VALUE_OPTIONAL, 'Opens the serving server in the default browser.')
            ->addOption('xdebug', 'x', InputOption::VALUE_OPTIONAL, 'Enables XDEBUG session.', false);
    }

    public function complete(CompletionInput $input, CompletionSuggestions $suggestions): void
    {
        if ($input->mustSuggestArgumentValuesFor('address')) {
            $suggestions->suggestValues(['localhost', '127.0.0.1', '0.0.0.0']);
            return;
        }
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $io = new SymfonyStyle($input, $output);
        $io->title('Yii3 Development Server');
        $io->writeln('https://yiiframework.com' . "\n");

        /** @var string $address */
        $address = $input->getArgument('address');

        /** @var string $router */
        $router = $input->getOption('router');
        $workers = (int) $input->getOption('workers');

        /** @var string $port */
        $port = $input->getOption('port');

        /** @var string $docroot */
        $docroot = $input->getOption('docroot');

        if ($router === $this->defaultRouter && !file_exists($this->defaultRouter)) {
            $io->warning(
                'Default router "' . $this->defaultRouter . '" does not exist. Serving without router. URLs with dots may fail.'
            );
            $router = null;
        }

        /** @var string $env */
        $env = $input->getOption('env');

        $documentRoot = $this->getRootPath() . DIRECTORY_SEPARATOR . $docroot;

        if (!str_contains($address, ':')) {
            $address .= ':' . $port;
        }

        if (!is_dir($documentRoot)) {
            $io->error("Document root \"$documentRoot\" does not exist.");
            return self::EXIT_CODE_NO_DOCUMENT_ROOT;
        }

        if ($this->isAddressTaken($address)) {
            if ($this->isWindows()) {
                $io->error("Port {$port} is taken by another process");
                return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
            }

            $runningCommandPIDs = trim((string) shell_exec('lsof -ti :8080 -s TCP:LISTEN'));
            if (empty($runningCommandPIDs)) {
                $io->error("Port {$port} is taken by another process");
                return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
            }

            $runningCommandPIDs = array_filter(explode("\n", $runningCommandPIDs));
            sort($runningCommandPIDs);

            $io->block(
                [
                    "Port {$port} is taken by the processes:",
                    ...array_map(
                        fn ($pid) => sprintf(
                            '#%s: %s',
                            $pid,
                            shell_exec("ps -o command= -p {$pid}"),
                        ),
                        $runningCommandPIDs,
                    ),
                ],
                'ERROR',
                'error',
            );
            if (!$io->confirm('Kill the process', true)) {
                return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
            }
            $io->info([
                'Stopping the processes...',
            ]);
            $out = array_filter(
                array_map(
                    fn ($pid) => shell_exec("kill -9 {$pid}"),
                    $runningCommandPIDs,
                )
            );
            if (!empty($out)) {
                $io->error($out);
                return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
            }
        }

        if ($router !== null && !file_exists($router)) {
            $io->error("Routing file \"$router\" does not exist.");
            return self::EXIT_CODE_NO_ROUTING_FILE;
        }

        $command = [];

        $isLinux = DIRECTORY_SEPARATOR !== '\\';

        if ($isLinux) {
            $command[] = 'PHP_CLI_SERVER_WORKERS=' . $workers;
        }

        $xDebugInstalled = extension_loaded('xdebug');
        $xDebugEnabled = $isLinux && $xDebugInstalled && $input->hasOption('xdebug') && $input->getOption(
            'xdebug'
        ) === null;

        if ($xDebugEnabled) {
            $command[] = 'XDEBUG_MODE=debug XDEBUG_TRIGGER=yes';
        }
        $outputTable = [];
        $outputTable[] = ['PHP', PHP_VERSION];
        $outputTable[] = [
            'xDebug',
            $xDebugInstalled ? sprintf(
                '%s, %s',
                phpversion('xdebug'),
                $xDebugEnabled ? '<info> Enabled </>' : '<error> Disabled </>',
            ) : '<error>Not installed</>',
            '--xdebug',
        ];
        $outputTable[] = ['Workers', $isLinux ? $workers : 'Not supported', '--workers, -w'];
        $outputTable[] = ['Address', $address];
        $outputTable[] = ['Document root', $documentRoot, '--docroot, -t'];
        $outputTable[] = ($router ? ['Routing file', $router, '--router, -r'] : []);

        $io->table(['Configuration', null, 'Options'], $outputTable);

        $command[] = '"' . PHP_BINARY . '"' . " -S $address -t \"$documentRoot\" $router";
        $command = implode(' ', $command);

        $output->writeln([
            'Executing: ',
            sprintf('<info>%s</>', $command),
        ], OutputInterface::VERBOSITY_VERBOSE);

        $io->success('Quit the server with CTRL-C or COMMAND-C.');

        if ($env === 'test') {
            return ExitCode::OK;
        }

        $openInBrowser = $input->hasOption('open') && $input->getOption('open') === null;


        //if ($openInBrowser) {
        //    passthru('open http://' . $address);
        //}
        passthru($command, $result);
        //$descriptorspec = array(
        //    0 => array("pipe", "r"),  // stdin - канал, из которого дочерний процесс будет читать
        //    1 => array("pipe", "w"),  // stdout - канал, в который дочерний процесс будет записывать
        //    2 => array("file", "/tmp/error-output.txt", "a") // stderr - файл для записи
        //);

        //$cwd = dirname($documentRoot);
        //$process = proc_open($command, $descriptorspec, $cwd);
        //
        //var_dump($process);

        return 0;
    }

    /**
     * @param string $address The server address.
     *
     * @return bool If address is already in use.
     */
    private function isAddressTaken(string $address): bool
    {
        [$hostname, $port] = explode(':', $address);
        $fp = @fsockopen($hostname, (int) $port, $errno, $errstr, 3);

        if ($fp === false) {
            return false;
        }

        fclose($fp);
        return true;
    }

    private function getRootPath(): string
    {
        if ($this->appRootPath !== null) {
            return rtrim($this->appRootPath, DIRECTORY_SEPARATOR);
        }

        return getcwd();
    }

    private function isWindows(): bool
    {
        return stripos(PHP_OS, 'Win') === 0;
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Yiisoft\Yii\Console\Command;
6
7		use Symfony\Component\Console\Attribute\AsCommand;
8		use Symfony\Component\Console\Command\Command;
9		use Symfony\Component\Console\Completion\CompletionInput;
10		use Symfony\Component\Console\Completion\CompletionSuggestions;
11		use Symfony\Component\Console\Input\InputArgument;
12		use Symfony\Component\Console\Input\InputInterface;
13		use Symfony\Component\Console\Input\InputOption;
14		use Symfony\Component\Console\Output\OutputInterface;
15		use Symfony\Component\Console\Style\SymfonyStyle;
16		use Yiisoft\Yii\Console\ExitCode;
17
18		use function explode;
19		use function fclose;
20		use function file_exists;
21		use function fsockopen;
22		use function is_dir;
23		use function passthru;
24
25		#[AsCommand('serve', 'Runs PHP built-in web server')]
26		final class Serve extends Command
27		{
28		public const EXIT_CODE_NO_DOCUMENT_ROOT = 2;
29		public const EXIT_CODE_NO_ROUTING_FILE = 3;
30		public const EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS = 5;
31
32		private string $defaultAddress;
33		private string $defaultPort;
34		private string $defaultDocroot;
35		private string $defaultRouter;
36		private int $defaultWorkers;
37
38		/**
39		* @psalm-param array{
40		* address?:non-empty-string,
41		* port?:non-empty-string,
42		* docroot?:string,
43		* router?:string,
44		* workers?:int\|string
45		* } $options
46		*/
47	49	public function __construct(private ?string $appRootPath = null, ?array $options = [])
48		{
49	49	$this->defaultAddress = $options['address'] ?? '127.0.0.1';
50	49	$this->defaultPort = $options['port'] ?? '8080';
51	49	$this->defaultDocroot = $options['docroot'] ?? 'public';
52	49	$this->defaultRouter = $options['router'] ?? 'public/index.php';
53	49	$this->defaultWorkers = (int) ($options['workers'] ?? 2);
54
55	49	parent::__construct();
56		}
57
58	49	public function configure(): void
59		{
60	49	$this
61	49	->setHelp(
62	49	'In order to access server from remote machines use 0.0.0.0:8000. That is especially useful when running server in a virtual machine.'
63	49	)
64	49	->addArgument('address', InputArgument::OPTIONAL, 'Host to serve at', $this->defaultAddress)
65	49	->addOption('port', 'p', InputOption::VALUE_OPTIONAL, 'Port to serve at', $this->defaultPort)
66	49	->addOption(
67	49	'docroot',
68	49	't',
69	49	InputOption::VALUE_OPTIONAL,
70	49	'Document root to serve from',
71	49	$this->defaultDocroot
72	49	)
73	49	->addOption('router', 'r', InputOption::VALUE_OPTIONAL, 'Path to router script', $this->defaultRouter)
74	49	->addOption(
75	49	'workers',
76	49	'w',
77	49	InputOption::VALUE_OPTIONAL,
78	49	'Workers number the server will start with',
79	49	$this->defaultWorkers
80	49	)
81	49	->addOption('env', 'e', InputOption::VALUE_OPTIONAL, 'It is only used for testing.')
82	49	->addOption('open', 'o', InputOption::VALUE_OPTIONAL, 'Opens the serving server in the default browser.')
83		->addOption('xdebug', 'x', InputOption::VALUE_OPTIONAL, 'Enables XDEBUG session.', false);
84		}
85	1
86		public function complete(CompletionInput $input, CompletionSuggestions $suggestions): void
87	1	{
88	1	if ($input->mustSuggestArgumentValuesFor('address')) {
89	1	$suggestions->suggestValues(['localhost', '127.0.0.1', '0.0.0.0']);
90		return;
91		}
92		}
93	6
94		protected function execute(InputInterface $input, OutputInterface $output): int
95	6	{
96	6	$io = new SymfonyStyle($input, $output);
97	6	$io->title('Yii3 Development Server');
98		$io->writeln('https://yiiframework.com' . "\n");
99
100	6	/** @var string $address */
101		$address = $input->getArgument('address');
102
103	6	/** @var string $router */
104	6	$router = $input->getOption('router');
105		$workers = (int) $input->getOption('workers');
106
107	6	/** @var string $port */
108		$port = $input->getOption('port');
109
110	6	/** @var string $docroot */
111		$docroot = $input->getOption('docroot');
112	6
113	4	if ($router === $this->defaultRouter && !file_exists($this->defaultRouter)) {
114	4	$io->warning(
115	4	'Default router "' . $this->defaultRouter . '" does not exist. Serving without router. URLs with dots may fail.'
116	4	);
117		$router = null;
118		}
119
120	6	/** @var string $env */
121		$env = $input->getOption('env');
122	6
123		$documentRoot = $this->getRootPath() . DIRECTORY_SEPARATOR . $docroot;
124	6
125	5	if (!str_contains($address, ':')) {
126		$address .= ':' . $port;
127		}
128	6
129	1	if (!is_dir($documentRoot)) {
130	1	$io->error("Document root \"$documentRoot\" does not exist.");
131		return self::EXIT_CODE_NO_DOCUMENT_ROOT;
132		}
133	5
134	1	if ($this->isAddressTaken($address)) {
135	1	if ($this->isWindows()) {
136		$io->error("Port {$port} is taken by another process");
137		return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
138	4	}
139	1
140	1	$runningCommandPIDs = trim((string) shell_exec('lsof -ti :8080 -s TCP:LISTEN'));
141		if (empty($runningCommandPIDs)) {
142		$io->error("Port {$port} is taken by another process");
143	3	return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
144		}
145	3
146		$runningCommandPIDs = array_filter(explode("\n", $runningCommandPIDs));
147	3	sort($runningCommandPIDs);
148	3
149		$io->block(
150		[
151	3	"Port {$port} is taken by the processes:",
152	3	...array_map(
153		fn ($pid) => sprintf(
154	3	'#%s: %s',
155		$pid,
156		shell_exec("ps -o command= -p {$pid}"),
157	3	),
158	3	$runningCommandPIDs,
159	3	),
160	3	],
161	3	'ERROR',
162	3	'error',
163	3	);
164	3	if (!$io->confirm('Kill the process', true)) {
165	3	return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
166	3	}
167	3	$io->info([
168	3	'Stopping the processes...',
169	3	]);
170	3	$out = array_filter(
171		array_map(
172	3	fn ($pid) => shell_exec("kill -9 {$pid}"),
173		$runningCommandPIDs,
174	3	)
175	3	);
176		if (!empty($out)) {
177	3	$io->error($out);
178	3	return self::EXIT_CODE_ADDRESS_TAKEN_BY_ANOTHER_PROCESS;
179	3	}
180	3	}
181
182	3	if ($router !== null && !file_exists($router)) {
183		$io->error("Routing file \"$router\" does not exist.");
184	3	return self::EXIT_CODE_NO_ROUTING_FILE;
185	3	}
186
187		$command = [];
188
189		$isLinux = DIRECTORY_SEPARATOR !== '\\';
190
191		if ($isLinux) {
192		$command[] = 'PHP_CLI_SERVER_WORKERS=' . $workers;
193		}
194
195		$xDebugInstalled = extension_loaded('xdebug');
196		$xDebugEnabled = $isLinux && $xDebugInstalled && $input->hasOption('xdebug') && $input->getOption(
197		'xdebug'
198	5	) === null;
199
200	5	if ($xDebugEnabled) {
201	5	$command[] = 'XDEBUG_MODE=debug XDEBUG_TRIGGER=yes';
202		}
203	5	$outputTable = [];
204	4	$outputTable[] = ['PHP', PHP_VERSION];
205		$outputTable[] = [
206		'xDebug',
207	1	$xDebugInstalled ? sprintf(
208	1	'%s, %s',
209		phpversion('xdebug'),
210		$xDebugEnabled ? '<info> Enabled </>' : '<error> Disabled </>',
211	6	) : '<error>Not installed</>',
212		'--xdebug',
213	6	];
214		$outputTable[] = ['Workers', $isLinux ? $workers : 'Not supported', '--workers, -w'];
215		$outputTable[] = ['Address', $address];
216		$outputTable[] = ['Document root', $documentRoot, '--docroot, -t'];
217	6	$outputTable[] = ($router ? ['Routing file', $router, '--router, -r'] : []);
218
219		$io->table(['Configuration', null, 'Options'], $outputTable);
220
221		$command[] = '"' . PHP_BINARY . '"' . " -S $address -t \"$documentRoot\" $router";
222		$command = implode(' ', $command);
223
224		$output->writeln([
225		'Executing: ',
226		sprintf('<info>%s</>', $command),
227		], OutputInterface::VERBOSITY_VERBOSE);
228
229		$io->success('Quit the server with CTRL-C or COMMAND-C.');
230
231		if ($env === 'test') {
232		return ExitCode::OK;
233		}
234
235		$openInBrowser = $input->hasOption('open') && $input->getOption('open') === null;
		0 ignored issues – show Unused Code introduced 2024-06-23 15:58 UTC by Report Bug Copy Issue Report The assignment to `$openInBrowser` is dead and can be removed. Loading history...
236
237		//if ($openInBrowser) {
238		// passthru('open http://' . $address);
239		//}
240		passthru($command, $result);
241		//$descriptorspec = array(
242		// 0 => array("pipe", "r"), // stdin - канал, из которого дочерний процесс будет читать
243		// 1 => array("pipe", "w"), // stdout - канал, в который дочерний процесс будет записывать
244		// 2 => array("file", "/tmp/error-output.txt", "a") // stderr - файл для записи
245		//);
246
247		//$cwd = dirname($documentRoot);
248		//$process = proc_open($command, $descriptorspec, $cwd);
249		//
250		//var_dump($process);
251
252		return 0;
253		}
254
255		/**
256		* @param string $address The server address.
257		*
258		* @return bool If address is already in use.
259		*/
260		private function isAddressTaken(string $address): bool
261		{
262		[$hostname, $port] = explode(':', $address);
263		$fp = @fsockopen($hostname, (int) $port, $errno, $errstr, 3);
264
265		if ($fp === false) {
266		return false;
267		}
268
269		fclose($fp);
270		return true;
271		}
272
273		private function getRootPath(): string
274		{
275		if ($this->appRootPath !== null) {
276		return rtrim($this->appRootPath, DIRECTORY_SEPARATOR);
277		}
278
279		return getcwd();
280		}
281
282		private function isWindows(): bool
283		{
284		return stripos(PHP_OS, 'Win') === 0;
285		}
286		}
287

yiisoft / yii-console

Pull Request — master (#211)

Serve::isAddressTaken() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like