Factory::parentFromClass() - Code Metrics - Inspection of "Merge pull request #22 from WyriHaximus/close-all-..." - WyriHaximus/reactphp-child-process-messenger - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( fb3f27...562fa1 )

by Cees-Jan

created 2019-01-17 06:54 UTC

Factory::parentFromClass() C

↳ Parent: Factory

Complexity

Conditions	10
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	21
CRAP Score	15.5918

Importance

Changes

Metric	Value
dl	0
loc	65
ccs	21
cts	34
cp	0.6176
rs	6.8969
c	0
b	0
f	0
cc	10
nc	2
nop	3
crap	15.5918

How to fix Long Method Complexity

<?php

namespace WyriHaximus\React\ChildProcess\Messenger;

use React\ChildProcess\Process;
.
|-- OtherDir
|   |-- Bar.php
|   `-- Foo.php
`-- SomeDir
    `-- Foo.php
use React\EventLoop\LoopInterface;
use React\Promise;
use React\Socket\ConnectionInterface;
use React\Socket\Connector;
use React\Socket\Server;
use WyriHaximus\FileDescriptors\Factory as FileDescriptorsFactory;
use WyriHaximus\FileDescriptors\ListerInterface;
use WyriHaximus\React\ChildProcess\Messenger\Messages\Factory as MessengesFactory;
use WyriHaximus\React\ChildProcess\Messenger\Messages\Payload;

final class Factory
{
    const INTERVAL = 0.1;
    const TIMEOUT = 13;
    const TERMINATE_TIMEOUT = 1;
    const PROCESS_REGISTER = 'wyrihaximus.react.child-process.messenger.child.register';

    public static function parent(
        Process $process,
        LoopInterface $loop,
        array $options = []
    ) {
        return new Promise\Promise(function ($resolve, $reject) use ($process, $loop, $options) {
            $server = new Server('127.0.0.1:0', $loop);
            $argvString = \escapeshellarg(ArgvEncoder::encode([
                'address' => $server->getAddress(),
            ]));

            $process = new Process($process->getCommand() . ' ' . $argvString);
$x = 1;
$callable = function() use ($x) {
    $x = 2; // Not visible in outer scope. If you would like this, how
            // about using a different variable name than $x?
};

$callable();
var_dump($x); // integer(1)

            self::startParent($process, $server, $loop, $options)->done($resolve, $reject);
interface User
{
    /** @return string */
    public function getPassword();
}

class MyUser implements User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}
        });
    }

    /**
     * @param  string                              $class
     * @param  LoopInterface                       $loop
     * @param  array                               $options
     * @return Promise\PromiseInterface<Messenger>

     */
    public static function parentFromClass(
        $class,
        LoopInterface $loop,
        array $options = []
    ) {
        if (!\is_subclass_of($class, 'WyriHaximus\React\ChildProcess\Messenger\ChildInterface')) {
            throw new \Exception('Given class doesn\'t implement ChildInterface');
        }

        return new Promise\Promise(function ($resolve, $reject) use ($class, $loop, $options) {
            $server = new Server('127.0.0.1:0', $loop);
            $options['address'] = $server->getAddress();
            $options['random'] = \bin2hex(\random_bytes(512));

            $template = '%s';
            if (isset($options['cmdTemplate'])) {
                $template = $options['cmdTemplate'];
                unset($options['cmdTemplate']);
            }

            $fds = [];
            if (\DIRECTORY_SEPARATOR !== '\\') {
                if (isset($options['fileDescriptorLister']) && $options['fileDescriptorLister'] instanceof ListerInterface) {
                    /** @var ListerInterface $fileDescriptorLister */
                    $fileDescriptorLister = $options['fileDescriptorLister'];
                    unset($options['fileDescriptorLister']);
                }

                if (!isset($fileDescriptorLister)) {
                    /** @var ListerInterface $fileDescriptorLister */
                    $fileDescriptorLister = FileDescriptorsFactory::create();
                }

                foreach (self::listFileDescriptors(($fileDescriptorLister)) as $id) {
                    $fds[(int)$id] = ['file', '/dev/null', 'r'];
                }
            }

            $phpBinary = \escapeshellarg(PHP_BINARY . (PHP_SAPI === 'phpdbg' ? ' -qrr --' : ''));
            $childProcessPath = \escapeshellarg(__DIR__ . DIRECTORY_SEPARATOR . 'child-process.php');
            $argvString = \escapeshellarg(ArgvEncoder::encode($options));
            $command = $phpBinary . ' ' . $childProcessPath;

            $process = new Process(
                \sprintf(
                    $template,
                    $command . ' ' . $argvString
                ),
                null,
                null,
                $fds
            );

            $connectTimeout = isset($options['connect-timeout']) ? $options['connect-timeout'] : 5;
            \WyriHaximus\React\futurePromise($loop)->then(function () use ($process, $server, $loop, $options, $connectTimeout) {
interface User
{
    /** @return string */
    public function getPassword();
}

class MyUser implements User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}
                return Promise\Timer\timeout(self::startParent($process, $server, $loop, $options), $connectTimeout, $loop);
            })->then(function (Messenger $messenger) use ($class) {
                return $messenger->rpc(MessengesFactory::rpc(Factory::PROCESS_REGISTER, [
                    'className' => $class,
                ]))->then(function ($p) use ($messenger) {

                    return Promise\resolve($messenger);
                });
            })->done($resolve, $reject);
        });
    }

    /**
     * @param  LoopInterface                       $loop
     * @param  array                               $options
     * @param  callable                            $termiteCallable
     * @return Promise\PromiseInterface<Messenger>

     */
    public static function child(LoopInterface $loop, array $options = [], callable $termiteCallable = null)
    {
        $connectTimeout = isset($options['connect-timeout']) ? $options['connect-timeout'] : 5;

        return (new Connector($loop, ['timeout' => $connectTimeout]))->connect($options['address'])->then(function (ConnectionInterface $connection) use ($options, $loop, $connectTimeout) {
            return new Promise\Promise(function ($resolve, $reject) use ($connection, $options, $loop, $connectTimeout) {
                Promise\Timer\timeout(Promise\Stream\first($connection), $connectTimeout, $loop)->then(function ($chunk) use ($resolve, $connection, $options) {
                    list($confirmation) = \explode(PHP_EOL, $chunk);
                    if ($confirmation === 'syn') {
                        $connection->write('ack' . PHP_EOL);
                        $resolve(new Messenger($connection, $options));
                    }
                }, $reject);
                $connection->write(\hash_hmac('sha512', $options['address'], $options['random']) . PHP_EOL);
            });
        })->then(function (Messenger $messenger) use ($loop, $termiteCallable) {
            if ($termiteCallable === null) {
                $termiteCallable = function () use ($loop) {
$x = 1;
$callable = function() use ($x) {
    $x = 2; // Not visible in outer scope. If you would like this, how
            // about using a different variable name than $x?
};

$callable();
var_dump($x); // integer(1)
                    $loop->addTimer(
                        self::TERMINATE_TIMEOUT,
                        [
                            $loop,
                            'stop',
                        ]
                    );
                };
            }

            $messenger->registerRpc(
                Messenger::TERMINATE_RPC,
                function (Payload $payload, Messenger $messenger) use ($termiteCallable) {
                    $messenger->emit('terminate', [
                        $messenger,
                    ]);
                    $termiteCallable($payload, $messenger);

                    return Promise\resolve([]);
                }
            );

            return $messenger;
        });
    }

    private static function startParent(
        Process $process,
        Server $server,
        LoopInterface $loop,
        array $options
    ) {
        return (new Promise\Promise(function ($resolve, $reject) use ($process, $server, $loop, $options) {
            $server->on(
                'connection',
                function (ConnectionInterface $connection) use ($server, $resolve, $reject, $options, $loop) {
                    Promise\Stream\first($connection)->then(function ($chunk) use ($options, $connection, $resolve) {
                        list($confirmation) = \explode(PHP_EOL, $chunk);
                        if ($confirmation === \hash_hmac('sha512', $options['address'], $options['random'])) {
                            $connection->write('syn' . PHP_EOL);

                            return Promise\Stream\first($connection);
                        }
                    })->then(function ($chunk) use ($options, $connection) {
                        list($confirmation) = \explode(PHP_EOL, $chunk);
                        if ($confirmation === 'ack') {
                            return Promise\resolve(new Messenger($connection, $options));
                        }

                        return Promise\reject(new \RuntimeException('Handshake failed'));
                    })->always(function () use ($server) {
                        $server->close();
                    })->done($resolve, $reject);
                }
            );
            $server->on('error', function ($et) use ($reject) {
                $reject($et);
            });

            $process->start($loop);
        }, function () use ($server, $process) {
            $server->close();
            $process->terminate();
        }))->then(function (Messenger $messenger) use ($loop, $process) {
            $loop->addPeriodicTimer(self::INTERVAL, function ($timer) use ($messenger, $loop, $process) {
                if (!$process->isRunning()) {
                    $loop->cancelTimer($timer);

                    $exitCode = $process->getExitCode();
                    if ($exitCode === 0) {
                        return;
                    }

                    $messenger->crashed($exitCode);
                }
            });

            return $messenger;
        });
    }

    private static function listFileDescriptors(ListerInterface $fileDescriptorLister)
    {
        if (\method_exists($fileDescriptorLister, 'list')) {
            return $fileDescriptorLister->list();

        }

        return $fileDescriptorLister->listFileDescriptors();
    }
}


GitHub Access Token became invalid

Push — master ( fb3f27...562fa1 )

Factory::parentFromClass() C

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Change not visible in outer-scope

Change visible in outer-scope

Available Fixes

Available Fixes

Change not visible in outer-scope

Change visible in outer-scope

1		<?php
2
3		namespace WyriHaximus\React\ChildProcess\Messenger;
4
5		use React\ChildProcess\Process;
		0 ignored issues – show Bug introduced 2015-12-26 20:25 UTC by Report Bug Copy Issue Report This use statement conflicts with another class in this namespace, `WyriHaximus\React\ChildProcess\Messenger\Process`. Let’s assume that you have a directory layout like this: . \|-- OtherDir \| \|-- Bar.php \| `-- Foo.php `-- SomeDir `-- Foo.php and let’s assume the following content of `Bar.php`: // Bar.php namespace OtherDir; use SomeDir\Foo; // This now conflicts the class OtherDir\Foo If both files `OtherDir/Foo.php` and `SomeDir/Foo.php` are loaded in the same runtime, you will see a PHP error such as the following: PHP Fatal error: Cannot use SomeDir\Foo as Foo because the name is already in use in OtherDir/Foo.php However, as `OtherDir/Foo.php` does not necessarily have to be loaded and the error is only triggered if it is loaded before `OtherDir/Bar.php`, this problem might go unnoticed for a while. In order to prevent this error from surfacing, you must import the namespace with a different alias: // Bar.php namespace OtherDir; use SomeDir\Foo as SomeDirFoo; // There is no conflict anymore. Loading history...
6		use React\EventLoop\LoopInterface;
7		use React\Promise;
8		use React\Socket\ConnectionInterface;
9		use React\Socket\Connector;
10		use React\Socket\Server;
11		use WyriHaximus\FileDescriptors\Factory as FileDescriptorsFactory;
12		use WyriHaximus\FileDescriptors\ListerInterface;
13		use WyriHaximus\React\ChildProcess\Messenger\Messages\Factory as MessengesFactory;
14		use WyriHaximus\React\ChildProcess\Messenger\Messages\Payload;
15
16		final class Factory
17		{
18		const INTERVAL = 0.1;
19		const TIMEOUT = 13;
20		const TERMINATE_TIMEOUT = 1;
21		const PROCESS_REGISTER = 'wyrihaximus.react.child-process.messenger.child.register';
22
23		public static function parent(
24		Process $process,
25		LoopInterface $loop,
26		array $options = []
27		) {
28		return new Promise\Promise(function ($resolve, $reject) use ($process, $loop, $options) {
29		$server = new Server('127.0.0.1:0', $loop);
30		$argvString = \escapeshellarg(ArgvEncoder::encode([
31		'address' => $server->getAddress(),
32		]));
33
34		$process = new Process($process->getCommand() . ' ' . $argvString);
		0 ignored issues – show Bug introduced 2018-01-31 15:13 UTC by Report Bug Copy Issue Report Consider using a different name than the imported variable `$process`, or did you forget to import by reference? It seems like you are assigning to a variable which was imported through a `use` statement which was not imported by reference. For clarity, we suggest to use a different name or import by reference depending on whether you would like to have the change visibile in outer-scope. Change not visible in outer-scope $x = 1; $callable = function() use ($x) { $x = 2; // Not visible in outer scope. If you would like this, how // about using a different variable name than $x? }; $callable(); var_dump($x); // integer(1) Change visible in outer-scope $x = 1; $callable = function() use (&$x) { $x = 2; }; $callable(); var_dump($x); // integer(2) Loading history...
35
36		self::startParent($process, $server, $loop, $options)->done($resolve, $reject);
		0 ignored issues – show Bug introduced 2018-03-23 21:29 UTC by Report Bug Copy Issue Report It seems like you code against a concrete implementation and not the interface `React\Promise\PromiseInterface` as the method `done()` does only exist in the following implementations of said interface: `React\Promise\FulfilledPromise`, `React\Promise\LazyPromise`, `React\Promise\Promise`, `React\Promise\RejectedPromise`. Let’s take a look at an example: interface User { /** @return string / public function getPassword(); } class MyUser implements User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different implementation of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the interface: interface User { /** @return string / public function getPassword(); /* @return string */ public function getDisplayName(); } Loading history...
37		});
38		}
39
40		/**
41		* @param string $class
42		* @param LoopInterface $loop
43		* @param array $options
44		* @return Promise\PromiseInterface<Messenger>
		0 ignored issues – show Documentation introduced 2017-10-17 06:04 UTC by Report Bug Copy Issue Report The doc-type `Promise\PromiseInterface<Messenger>` could not be parsed: Expected "\|" or "end of type", but got "<" at position 24. (view supported doc-types) This check marks PHPDoc comments that could not be parsed by our parser. To see which comment annotations we can parse, please refer to our documentation on supported doc-types. Loading history...
45	2	*/
46		public static function parentFromClass(
47		$class,
48		LoopInterface $loop,
49		array $options = []
50	2	) {
51	1	if (!\is_subclass_of($class, 'WyriHaximus\React\ChildProcess\Messenger\ChildInterface')) {
52		throw new \Exception('Given class doesn\'t implement ChildInterface');
53		}
54
55	1	return new Promise\Promise(function ($resolve, $reject) use ($class, $loop, $options) {
56	1	$server = new Server('127.0.0.1:0', $loop);
57	1	$options['address'] = $server->getAddress();
58		$options['random'] = \bin2hex(\random_bytes(512));
59	1
60	1	$template = '%s';
61		if (isset($options['cmdTemplate'])) {
62		$template = $options['cmdTemplate'];
63		unset($options['cmdTemplate']);
64		}
65	1
66	1	$fds = [];
67	1	if (\DIRECTORY_SEPARATOR !== '\\') {
68	1	if (isset($options['fileDescriptorLister']) && $options['fileDescriptorLister'] instanceof ListerInterface) {
69	1	/** @var ListerInterface $fileDescriptorLister */
70	1	$fileDescriptorLister = $options['fileDescriptorLister'];
71	1	unset($options['fileDescriptorLister']);
72	1	}
73
74		if (!isset($fileDescriptorLister)) {
75		/** @var ListerInterface $fileDescriptorLister */
76		$fileDescriptorLister = FileDescriptorsFactory::create();
77	1	}
78	1
79		foreach (self::listFileDescriptors(($fileDescriptorLister)) as $id) {
80	1	$fds[(int)$id] = ['file', '/dev/null', 'r'];
81	1	}
82	1	}
83	1
84		$phpBinary = \escapeshellarg(PHP_BINARY . (PHP_SAPI === 'phpdbg' ? ' -qrr --' : ''));
85		$childProcessPath = \escapeshellarg(__DIR__ . DIRECTORY_SEPARATOR . 'child-process.php');
86		$argvString = \escapeshellarg(ArgvEncoder::encode($options));
87		$command = $phpBinary . ' ' . $childProcessPath;
88
89		$process = new Process(
90		\sprintf(
91		$template,
92		$command . ' ' . $argvString
93		),
94		null,
95		null,
96		$fds
97		);
98
99		$connectTimeout = isset($options['connect-timeout']) ? $options['connect-timeout'] : 5;
100		\WyriHaximus\React\futurePromise($loop)->then(function () use ($process, $server, $loop, $options, $connectTimeout) {
		0 ignored issues – show Bug introduced 2019-01-16 21:25 UTC by Report Bug Copy Issue Report It seems like you code against a concrete implementation and not the interface `React\Promise\PromiseInterface` as the method `done()` does only exist in the following implementations of said interface: `React\Promise\FulfilledPromise`, `React\Promise\LazyPromise`, `React\Promise\Promise`, `React\Promise\RejectedPromise`. Let’s take a look at an example: interface User { /** @return string / public function getPassword(); } class MyUser implements User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different implementation of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the interface: interface User { /** @return string / public function getPassword(); /* @return string */ public function getDisplayName(); } Loading history...
101		return Promise\Timer\timeout(self::startParent($process, $server, $loop, $options), $connectTimeout, $loop);
102		})->then(function (Messenger $messenger) use ($class) {
103		return $messenger->rpc(MessengesFactory::rpc(Factory::PROCESS_REGISTER, [
104		'className' => $class,
105		]))->then(function ($p) use ($messenger) {
		0 ignored issues – show Unused Code introduced 2018-03-01 21:51 UTC by Report Bug Copy Issue Report The parameter `$p` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
106		return Promise\resolve($messenger);
107		});
108		})->done($resolve, $reject);
109		});
110		}
111
112		/**
113		* @param LoopInterface $loop
114		* @param array $options
115		* @param callable $termiteCallable
116		* @return Promise\PromiseInterface<Messenger>
		0 ignored issues – show Documentation introduced 2018-01-31 15:13 UTC by Report Bug Copy Issue Report The doc-type `Promise\PromiseInterface<Messenger>` could not be parsed: Expected "\|" or "end of type", but got "<" at position 24. (view supported doc-types) This check marks PHPDoc comments that could not be parsed by our parser. To see which comment annotations we can parse, please refer to our documentation on supported doc-types. Loading history...
117		*/
118		public static function child(LoopInterface $loop, array $options = [], callable $termiteCallable = null)
119		{
120		$connectTimeout = isset($options['connect-timeout']) ? $options['connect-timeout'] : 5;
121
122		return (new Connector($loop, ['timeout' => $connectTimeout]))->connect($options['address'])->then(function (ConnectionInterface $connection) use ($options, $loop, $connectTimeout) {
123		return new Promise\Promise(function ($resolve, $reject) use ($connection, $options, $loop, $connectTimeout) {
124		Promise\Timer\timeout(Promise\Stream\first($connection), $connectTimeout, $loop)->then(function ($chunk) use ($resolve, $connection, $options) {
125		list($confirmation) = \explode(PHP_EOL, $chunk);
126		if ($confirmation === 'syn') {
127		$connection->write('ack' . PHP_EOL);
128		$resolve(new Messenger($connection, $options));
129		}
130		}, $reject);
131		$connection->write(\hash_hmac('sha512', $options['address'], $options['random']) . PHP_EOL);
132		});
133		})->then(function (Messenger $messenger) use ($loop, $termiteCallable) {
134		if ($termiteCallable === null) {
135		$termiteCallable = function () use ($loop) {
		0 ignored issues – show Bug introduced 2017-10-17 06:04 UTC by Report Bug Copy Issue Report Consider using a different name than the imported variable `$termiteCallable`, or did you forget to import by reference? It seems like you are assigning to a variable which was imported through a `use` statement which was not imported by reference. For clarity, we suggest to use a different name or import by reference depending on whether you would like to have the change visibile in outer-scope. Change not visible in outer-scope $x = 1; $callable = function() use ($x) { $x = 2; // Not visible in outer scope. If you would like this, how // about using a different variable name than $x? }; $callable(); var_dump($x); // integer(1) Change visible in outer-scope $x = 1; $callable = function() use (&$x) { $x = 2; }; $callable(); var_dump($x); // integer(2) Loading history...
136	1	$loop->addTimer(
137		self::TERMINATE_TIMEOUT,
138		[
139		$loop,
140		'stop',
141		]
142		);
143	1	};
144	1	}
145
146		$messenger->registerRpc(
147	1	Messenger::TERMINATE_RPC,
148	1	function (Payload $payload, Messenger $messenger) use ($termiteCallable) {
149	1	$messenger->emit('terminate', [
150	1	$messenger,
151		]);
152	1	$termiteCallable($payload, $messenger);
153
154		return Promise\resolve([]);
155	1	}
156	1	);
157	1
158		return $messenger;
159	1	});
160	1	}
161
162		private static function startParent(
163		Process $process,
164	1	Server $server,
165		LoopInterface $loop,
166	1	array $options
167		) {
168	1	return (new Promise\Promise(function ($resolve, $reject) use ($process, $server, $loop, $options) {
169	1	$server->on(
170	1	'connection',
171		function (ConnectionInterface $connection) use ($server, $resolve, $reject, $options, $loop) {
172	1	Promise\Stream\first($connection)->then(function ($chunk) use ($options, $connection, $resolve) {
173	1	list($confirmation) = \explode(PHP_EOL, $chunk);
174	1	if ($confirmation === \hash_hmac('sha512', $options['address'], $options['random'])) {
175		$connection->write('syn' . PHP_EOL);
176
177		return Promise\Stream\first($connection);
178		}
179	1	})->then(function ($chunk) use ($options, $connection) {
180		list($confirmation) = \explode(PHP_EOL, $chunk);
181	1	if ($confirmation === 'ack') {
182	1	return Promise\resolve(new Messenger($connection, $options));
183		}
184
185		return Promise\reject(new \RuntimeException('Handshake failed'));
186		})->always(function () use ($server) {
187		$server->close();
188		})->done($resolve, $reject);
189		}
190		);
191		$server->on('error', function ($et) use ($reject) {
192		$reject($et);
193		});
194
195		$process->start($loop);
196		}, function () use ($server, $process) {
197		$server->close();
198		$process->terminate();
199		}))->then(function (Messenger $messenger) use ($loop, $process) {
200		$loop->addPeriodicTimer(self::INTERVAL, function ($timer) use ($messenger, $loop, $process) {
201		if (!$process->isRunning()) {
202		$loop->cancelTimer($timer);
203
204		$exitCode = $process->getExitCode();
205		if ($exitCode === 0) {
206		return;
207		}
208
209		$messenger->crashed($exitCode);
210		}
211		});
212
213		return $messenger;
214		});
215		}
216
217		private static function listFileDescriptors(ListerInterface $fileDescriptorLister)
218		{
219		if (\method_exists($fileDescriptorLister, 'list')) {
220		return $fileDescriptorLister->list();
		0 ignored issues – show Bug introduced 2019-01-16 21:25 UTC by Report Bug Copy Issue Report The method `list()` does not seem to exist on `object<WyriHaximus\FileD...iptors\ListerInterface>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
221		}
222
223		return $fileDescriptorLister->listFileDescriptors();
224		}
225		}
226

WyriHaximus / reactphp-child-process-messenger

GitHub Access Token became invalid

Push — master ( fb3f27...562fa1 )

Factory::parentFromClass() C

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Change not visible in outer-scope

Change visible in outer-scope

Available Fixes

Available Fixes

Change not visible in outer-scope

Change visible in outer-scope

Duplication Side-by-Side

Filter issues like