ParentRuntime - Code Metrics - Inspection of "Remove heavy uniqueid calculation" - spatie/async - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( c177fb...495f29 )

by Brent

created 2018-01-04 13:56 UTC

ParentRuntime A

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

Metric	Value
dl	0
loc	87
rs	10
c	0
b	0
f	0
wmc	9
lcom	1
cbo	3

5 Methods

Rating	Name	Size	Complexity
A	init()	20	2
A	createChildProcess()	15	2
A	encodeTask()	8	2
A	decodeTask()	4	1
A	getId()	10	2

<?php

namespace Spatie\Async\Runtime;

use Spatie\Async\Task;
use Spatie\Async\ParallelProcess;
use function Opis\Closure\serialize;
use Opis\Closure\SerializableClosure;
use function Opis\Closure\unserialize;
use Symfony\Component\Process\Process;

class ParentRuntime
{
    /** @var bool */
    protected static $isInitialised = false;

    /** @var string */
    protected static $autoloader;

    /** @var string */
    protected static $childProcessScript;

    protected static $currentId = 0;

    protected static $myPid = null;

    public static function init(string $autoloader = null)
    {
        if (! $autoloader) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $existingAutoloaderFiles = array_filter([
                __DIR__.'/../../../../autoload.php',
                __DIR__.'/../../../autoload.php',
                __DIR__.'/../../vendor/autoload.php',
                __DIR__.'/../../../vendor/autoload.php',
            ], function (string $path) {
                return file_exists($path);
            });

            $autoloader = reset($existingAutoloaderFiles);
        }

        self::$autoloader = $autoloader;
        self::$childProcessScript = __DIR__.'/ChildRuntime.php';

        self::$isInitialised = true;
    }

    /**
     * @param \Spatie\Async\Task|callable $task
     *
     * @return \Spatie\Async\ParallelProcess
     */
    public static function createChildProcess($task): ParallelProcess
    {
        if (! self::$isInitialised) {
            self::init();
        }

        $process = new Process(implode(' ', [
            'exec php',
            self::$childProcessScript,
            self::$autoloader,
            self::encodeTask($task),
        ]));

        return ParallelProcess::create($process, self::getId());
    }

    /**
     * @param \Spatie\Async\Task|callable $task
     *
     * @return string
     */
    public static function encodeTask($task): string
    {
        if (! $task instanceof Task) {
            $task = new SerializableClosure($task);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }

        return base64_encode(serialize($task));
    }

    public static function decodeTask(string $task)
    {
        return unserialize(base64_decode($task));
    }

    protected static function getId(): string
    {
        if (self::$myPid === null) {
            self::$myPid = getmypid();
        }

        self::$currentId += 1;

        return (string) self::$currentId . (string) self::$myPid;
    }
}


1			<?php
2
3			namespace Spatie\Async\Runtime;
4
5			use Spatie\Async\Task;
6			use Spatie\Async\ParallelProcess;
7			use function Opis\Closure\serialize;
8			use Opis\Closure\SerializableClosure;
9			use function Opis\Closure\unserialize;
10			use Symfony\Component\Process\Process;
11
12			class ParentRuntime
13			{
14			/** @var bool */
15			protected static $isInitialised = false;
16
17			/** @var string */
18			protected static $autoloader;
19
20			/** @var string */
21			protected static $childProcessScript;
22
23			protected static $currentId = 0;
24
25			protected static $myPid = null;
26
27			public static function init(string $autoloader = null)
28			{
29			if (! $autoloader) {
			0 ignored issues – show Bug Best Practice introduced 2017-12-23 10:08 UTC by Report Bug Copy Issue Report The expression `$autoloader` of type `null\|string` is loosely compared to `false`; this is ambiguous if the string can be empty. You might want to explicitly use `=== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `string` values, the empty string `''` is a special case, in particular the following results might be unexpected: '' == false // true '' == null // true 'ab' == false // false 'ab' == null // false // It is often better to use strict comparison '' === false // false '' === null // false Loading history...
30			$existingAutoloaderFiles = array_filter([
31			__DIR__.'/../../../../autoload.php',
32			__DIR__.'/../../../autoload.php',
33			__DIR__.'/../../vendor/autoload.php',
34			__DIR__.'/../../../vendor/autoload.php',
35			], function (string $path) {
36			return file_exists($path);
37			});
38
39			$autoloader = reset($existingAutoloaderFiles);
40			}
41
42			self::$autoloader = $autoloader;
43			self::$childProcessScript = __DIR__.'/ChildRuntime.php';
44
45			self::$isInitialised = true;
46			}
47
48			/**
49			* @param \Spatie\Async\Task\|callable $task
50			*
51			* @return \Spatie\Async\ParallelProcess
52			*/
53			public static function createChildProcess($task): ParallelProcess
54			{
55			if (! self::$isInitialised) {
56			self::init();
57			}
58
59			$process = new Process(implode(' ', [
60			'exec php',
61			self::$childProcessScript,
62			self::$autoloader,
63			self::encodeTask($task),
64			]));
65
66			return ParallelProcess::create($process, self::getId());
67			}
68
69			/**
70			* @param \Spatie\Async\Task\|callable $task
71			*
72			* @return string
73			*/
74			public static function encodeTask($task): string
75			{
76			if (! $task instanceof Task) {
77			$task = new SerializableClosure($task);
			0 ignored issues – show Documentation introduced 2017-12-25 11:48 UTC by Report Bug Copy Issue Report `$task` is of type `callable`, but the function expects a `object<Closure>`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
78			}
79
80			return base64_encode(serialize($task));
81			}
82
83			public static function decodeTask(string $task)
84			{
85			return unserialize(base64_decode($task));
86			}
87
88			protected static function getId(): string
89			{
90			if (self::$myPid === null) {
91			self::$myPid = getmypid();
92			}
93
94			self::$currentId += 1;
95
96			return (string) self::$currentId . (string) self::$myPid;
97			}
98			}
99

spatie / async

GitHub Access Token became invalid

Push — master ( c177fb...495f29 )

ParentRuntime A

Complexity

Size/Duplication

Coupling/Cohesion

Importance

5 Methods

Duplication Side-by-Side

Filter issues like