TopLikeCommand::outputTrace() - Code Metrics - Inspection of "Update dependency php to v8.1" - sj-i/php-profiler - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — renovate/php-8.x ( bfb893...222c0a )

unknown
created 2022-02-14 21:18 UTC
TopLikeCommand::outputTrace() A

↳ Parent: TopLikeCommand
Complexity

Conditions	1
Paths	1
Size

Total Lines	5
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	1
Metric	Value
cc	1
eloc	1
c	1
b	0
f	1
nc	1
nop	2
dl	0
loc	5
rs	10
<?php

/**
 * This file is part of the sj-i/ package.
 *
 * (c) sji <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace PhpProfiler\Command\Inspector;

use Amp\Loop;
filter:
    dependency_paths: ["lib/*"]
use Amp\Promise;
filter:
    dependency_paths: ["lib/*"]
use PhpProfiler\Inspector\Daemon\Dispatcher\DispatchTable;
use PhpProfiler\Inspector\Daemon\Dispatcher\WorkerPool;
use PhpProfiler\Inspector\Daemon\Reader\Context\PhpReaderContextCreator;
use PhpProfiler\Inspector\Daemon\Reader\Protocol\Message\TraceMessage;
use PhpProfiler\Inspector\Daemon\Searcher\Context\PhpSearcherContextCreator;
use PhpProfiler\Inspector\Output\TopLike\TopLikeFormatter;
use PhpProfiler\Inspector\Output\TopLike\TopLikeFormatterFactory;
use PhpProfiler\Inspector\Settings\DaemonSettings\DaemonSettingsFromConsoleInput;
use PhpProfiler\Inspector\Settings\GetTraceSettings\GetTraceSettingsFromConsoleInput;
use PhpProfiler\Inspector\Settings\TargetPhpSettings\TargetPhpSettingsFromConsoleInput;
use PhpProfiler\Inspector\Settings\TraceLoopSettings\TraceLoopSettingsFromConsoleInput;
use PhpProfiler\Lib\Console\EchoBackCanceller;
use PhpProfiler\Lib\Log\Log;
use PhpProfiler\Lib\PhpProcessReader\CallTrace;
use Symfony\Component\Console\Command\Command;
filter:
    dependency_paths: ["lib/*"]
use Symfony\Component\Console\Input\InputInterface;
filter:
    dependency_paths: ["lib/*"]
use Symfony\Component\Console\Output\OutputInterface;
filter:
    dependency_paths: ["lib/*"]

use function Amp\call;


final class TopLikeCommand extends Command
{
    public function __construct(
        private PhpSearcherContextCreator $php_searcher_context_creator,
        private PhpReaderContextCreator $php_reader_context_creator,
        private DaemonSettingsFromConsoleInput $daemon_settings_from_console_input,
        private GetTraceSettingsFromConsoleInput $get_trace_settings_from_console_input,
        private TargetPhpSettingsFromConsoleInput $target_php_settings_from_console_input,
        private TraceLoopSettingsFromConsoleInput $trace_loop_settings_from_console_input,
        private TopLikeFormatterFactory $formatter_factory,
    ) {
        parent::__construct();
    }

    public function configure(): void
    {
        $this->setName('inspector:top')
            ->setDescription(
                'show an aggregated view of traces in real time in a form similar to the UNIX top command.'
            )
        ;
        $this->daemon_settings_from_console_input->setOptions($this);
        $this->get_trace_settings_from_console_input->setOptions($this);
        $this->trace_loop_settings_from_console_input->setOptions($this);
        $this->target_php_settings_from_console_input->setOptions($this);
    }

    public function execute(InputInterface $input, OutputInterface $output): int
    {
        $get_trace_settings = $this->get_trace_settings_from_console_input->createSettings($input);
        $daemon_settings = $this->daemon_settings_from_console_input->createSettings($input);
        $target_php_settings = $this->target_php_settings_from_console_input->createSettings($input);
        $loop_settings = $this->trace_loop_settings_from_console_input->createSettings($input);
        $formatter = $this->formatter_factory->create(
            $daemon_settings->target_regex,
            $output
        );

        $searcher_context = $this->php_searcher_context_creator->create();
        Promise\wait($searcher_context->start());
        Promise\wait($searcher_context->start());
        Promise\wait($searcher_context->sendTargetRegex($daemon_settings->target_regex));

        $worker_pool = WorkerPool::create(
            $this->php_reader_context_creator,
            $daemon_settings->threads,
            $target_php_settings,
            $loop_settings,
            $get_trace_settings
        );

        $dispatch_table = new DispatchTable(
            $worker_pool,
        );

        $_echo_back_canceler = new EchoBackCanceller();


        Loop::onReadable(
            STDIN,
            /** @param resource $stream */
            function (string $watcher_id, $stream) {
                $key = fread($stream, 1);
                if ($key === 'q') {
                    Loop::cancel($watcher_id);
                    Loop::stop();
                }
            }
        );
        Loop::run(function () use ($dispatch_table, $searcher_context, $worker_pool, $formatter) {
            $promises = [];
            $promises[] = call(function () use ($searcher_context, $dispatch_table) {
            $promises[] = /** @scrutinizer ignore-call */ call(function () use ($searcher_context, $dispatch_table) {
                while (1) {
                    Log::debug('receiving pid List');
                    $update_target_message = yield $searcher_context->receivePidList();
                    Log::debug('update targets', [
                        'update' => $update_target_message->target_process_list->getArray(),
                        'current' => $dispatch_table->worker_pool->debugDump(),
                    ]);
                    $dispatch_table->updateTargets($update_target_message->target_process_list);
                    Log::debug('target updated', [$dispatch_table->worker_pool->debugDump()]);
                }
            });
            foreach ($worker_pool->getWorkers() as $reader) {
                $promises[] = call(
                    function () use ($reader, $dispatch_table, $formatter) {
                        while (1) {
                            $result = yield $reader->receiveTraceOrDetachWorker();
                            if ($result instanceof TraceMessage) {
                                $this->outputTrace($formatter, $result);
                            } else {
                                Log::debug('releaseOne', [$result]);
                                $dispatch_table->releaseOne($result->pid);
                                $this->outputTrace($formatter, new TraceMessage(
                                    new CallTrace()
                                ));
                            }
                        }
                    }
                );
            }
            yield $promises;
        });

        return 0;
    }

    private function outputTrace(
        TopLikeFormatter $formatter,
        TraceMessage $message
    ): void {
        $formatter->format($message->trace);
    }
}

sj-i / php-profiler

Push — renovate/php-8.x ( bfb893...222c0a )

TopLikeCommand::outputTrace() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
