StreamedCommandResponseGenerator::run() - Code Metrics - Inspection of "Merge branch 'next-24090/cherry-pick' into '6.5.0...." - shopware/platform - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — 6.5.0.0 ( 85bd4e...fe6596 )

by Christian

created 2023-03-08 09:49 UTC

StreamedCommandResponseGenerator::run() A

↳ Parent: StreamedCommandResponseGenerator

Complexity

Conditions	2
Paths	1

Size

Total Lines	16
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

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

<?php
declare(strict_types=1);

namespace App\Services;

use Shopware\Core\Framework\Log\Package;
use Symfony\Component\HttpFoundation\StreamedResponse;
use Symfony\Component\Process\Process;

/**
 * @internal
 */
#[Package('core')]
class StreamedCommandResponseGenerator
{
    /**
     * @param array<string> $params
     * @param callable(Process): void $finish
     */
    public function run(array $params, callable $finish): StreamedResponse
    {
        $process = new Process($params);
        $process->setEnv(['COMPOSER_HOME' => sys_get_temp_dir() . '/composer']);
        $process->setTimeout(300);

        $process->start();

        return new StreamedResponse(function () use ($process, $finish): void {
            foreach ($process->getIterator() as $item) {
                \assert(\is_string($item));
                echo $item;
                flush();
            }

            $finish($process);
        });
    }

    /**
     * @param array<string> $params
     */
    public function runJSON(array $params): StreamedResponse
    {
        return $this->run($params, function (Process $process): void {
            echo json_encode([
                'success' => $process->isSuccessful(),
            ]);
        });
    }
}


1			<?php
2			declare(strict_types=1);
3
4			namespace App\Services;
5
6			use Shopware\Core\Framework\Log\Package;
7			use Symfony\Component\HttpFoundation\StreamedResponse;
8			use Symfony\Component\Process\Process;
9
10			/**
11			* @internal
12			*/
13			#[Package('core')]
14			class StreamedCommandResponseGenerator
15			{
16			/**
17			* @param array<string> $params
18			* @param callable(Process): void $finish
19			*/
20			public function run(array $params, callable $finish): StreamedResponse
21			{
22			$process = new Process($params);
23			$process->setEnv(['COMPOSER_HOME' => sys_get_temp_dir() . '/composer']);
24			$process->setTimeout(300);
25
26			$process->start();
27
28			return new StreamedResponse(function () use ($process, $finish): void {
29			foreach ($process->getIterator() as $item) {
30			\assert(\is_string($item));
31			echo $item;
32			flush();
33			}
34
35			$finish($process);
36			});
37			}
38
39			/**
40			* @param array<string> $params
41			*/
42			public function runJSON(array $params): StreamedResponse
43			{
44			return $this->run($params, function (Process $process): void {
45			echo json_encode([
46			'success' => $process->isSuccessful(),
47			]);
48			});
49			}
50			}
51

shopware / platform

Push — 6.5.0.0 ( 85bd4e...fe6596 )

StreamedCommandResponseGenerator::run() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like