WorkerChild::create() - Code Metrics - WyriHaximus/cakephp-async-orm - Measure and Improve Code Quality continuously with Scrutinizer

WorkerChild::create() A
last analyzed 2019-04-23 00:19 UTC

↳ Parent: WorkerChild

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	11
c	0
b	0
f	0
rs	9.9
cc	1
nc	1
nop	2

<?php declare(strict_types=1);

namespace WyriHaximus\React\Cake\Orm;

use Cake\Cache\Cache;
use Cake\Core\Configure;
use Cake\Datasource\ConnectionManager;
use Cake\Datasource\Exception\PageOutOfBoundsException;
use Cake\Datasource\Paginator;
use Cake\ORM\Query;
use Cake\ORM\TableRegistry;
use React\EventLoop\LoopInterface;
use React\Promise\Deferred;
use function React\Promise\resolve;
use WyriHaximus\React\ChildProcess\Messenger\ChildInterface;
use WyriHaximus\React\ChildProcess\Messenger\Messages\Payload;
use WyriHaximus\React\ChildProcess\Messenger\Messenger;
use function WyriHaximus\React\futurePromise;

final class WorkerChild implements ChildInterface
{
    private $messenger;
    private $loop;

    /**
     * WorkerChild constructor.
     */
    public function __construct(Messenger $messenger, LoopInterface $loop)
    {
        $this->messenger = $messenger;
        $this->loop = $loop;

        $this->messenger->registerRpc('table.call', function (Payload $payload) {
            $deferred = new Deferred();
            $this->loop->futureTick(function () use ($payload, $deferred) {
                $this->handleTableCall($payload, $deferred);
            });

            return $deferred->promise();
        });

        $this->messenger->registerRpc('paginate', function (Payload $payload) {
            return futurePromise($this->loop, $payload)->then(function ($payload) {
                return $this->handlePaginateCall($payload);
            });
        });
    }

    /**
     * @inheritDoc
     */
    public static function create(Messenger $messenger, LoopInterface $loop)
    {
        require dirname(dirname(dirname(dirname(__DIR__)))) . '/config/paths.php';
        require CORE_PATH . 'config' . DS . 'bootstrap.php';
        Configure::config('default', new Configure\Engine\PhpConfig());
        Configure::load('app', 'default', false);
        Cache::setConfig(Configure::consume('Cache'));

        ConnectionManager::setConfig(Configure::consume('Datasources'));


        return new self($messenger, $loop);
    }

    /**
     * @param Payload  $payload
     * @param Deferred $deferred
     */
    protected function handleTableCall(Payload $payload, Deferred $deferred)
    {
        $result = call_user_func_array([
            TableRegistry::get(

                $payload['table']/*,

                [
                    'className' => $payload['className'],
                    'table' => $payload['table'],
                ]*/
            ),
            $payload['function'],
        ], unserialize($payload['arguments']));

        if (!($result instanceof Query)) {
            $deferred->resolve([
                'result' => serialize($result),
            ]);

            return;
        }

        foreach ($result->all() as $row) {
            $deferred->notify([

                'row' => $row,
            ]);
        }

        $deferred->resolve();
    }

    /**
     * @param Payload  $payload
     * @param Deferred $deferred
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     */
    protected function handlePaginateCall(Payload $payload)
    {
        $object = TableRegistry::get(

            $payload['table']/*,

                [
                    'className' => $payload['className'],
                    'table' => $payload['table'],
                ]*/
        );
        $paginator = new Paginator();

        try {
            $items = $paginator->paginate($object, $payload['params'], $payload['settings'])->toArray();
            $eos = false;
        } catch (PageOutOfBoundsException $pageOutOfBoundsException) {
            $items = [];
            $eos = true;
        }

        return resolve([
            'items' => $items,
            'eos' => $eos,
            'pagingParams' => $paginator->getPagingParams(),
        ]);
    }
}


1			<?php declare(strict_types=1);
2
3			namespace WyriHaximus\React\Cake\Orm;
4
5			use Cake\Cache\Cache;
6			use Cake\Core\Configure;
7			use Cake\Datasource\ConnectionManager;
8			use Cake\Datasource\Exception\PageOutOfBoundsException;
9			use Cake\Datasource\Paginator;
10			use Cake\ORM\Query;
11			use Cake\ORM\TableRegistry;
12			use React\EventLoop\LoopInterface;
13			use React\Promise\Deferred;
14			use function React\Promise\resolve;
15			use WyriHaximus\React\ChildProcess\Messenger\ChildInterface;
16			use WyriHaximus\React\ChildProcess\Messenger\Messages\Payload;
17			use WyriHaximus\React\ChildProcess\Messenger\Messenger;
18			use function WyriHaximus\React\futurePromise;
19
20			final class WorkerChild implements ChildInterface
21			{
22			private $messenger;
23			private $loop;
24
25			/**
26			* WorkerChild constructor.
27			*/
28			public function __construct(Messenger $messenger, LoopInterface $loop)
29			{
30			$this->messenger = $messenger;
31			$this->loop = $loop;
32
33			$this->messenger->registerRpc('table.call', function (Payload $payload) {
34			$deferred = new Deferred();
35			$this->loop->futureTick(function () use ($payload, $deferred) {
36			$this->handleTableCall($payload, $deferred);
37			});
38
39			return $deferred->promise();
40			});
41
42			$this->messenger->registerRpc('paginate', function (Payload $payload) {
43			return futurePromise($this->loop, $payload)->then(function ($payload) {
44			return $this->handlePaginateCall($payload);
45			});
46			});
47			}
48
49			/**
50			* @inheritDoc
51			*/
52			public static function create(Messenger $messenger, LoopInterface $loop)
53			{
54			require dirname(dirname(dirname(dirname(__DIR__)))) . '/config/paths.php';
55			require CORE_PATH . 'config' . DS . 'bootstrap.php';
56			Configure::config('default', new Configure\Engine\PhpConfig());
57			Configure::load('app', 'default', false);
58			Cache::setConfig(Configure::consume('Cache'));
			0 ignored issues – show Bug introduced 2018-10-21 13:59 UTC by Report Bug Copy Issue Report It seems like `\Cake\Core\Configure::consume('Cache')` targeting `Cake\Core\Configure::consume()` can also be of type `null`; however, `Cake\Core\StaticConfigTrait::setConfig()` does only seem to accept `string\|array`, maybe add an additional type check? This check looks at variables that are passed out again to other methods. If the outgoing method call has stricter type requirements than the method itself, an issue is raised. An additional type check may prevent trouble. Loading history...
59			ConnectionManager::setConfig(Configure::consume('Datasources'));
			0 ignored issues – show Bug introduced 2018-10-21 13:59 UTC by Report Bug Copy Issue Report It seems like `\Cake\Core\Configure::consume('Datasources')` targeting `Cake\Core\Configure::consume()` can also be of type `null`; however, `Cake\Datasource\ConnectionManager::setConfig()` does only seem to accept `string\|array`, maybe add an additional type check? This check looks at variables that are passed out again to other methods. If the outgoing method call has stricter type requirements than the method itself, an issue is raised. An additional type check may prevent trouble. Loading history...
60
61			return new self($messenger, $loop);
62			}
63
64			/**
65			* @param Payload $payload
66			* @param Deferred $deferred
67			*/
68			protected function handleTableCall(Payload $payload, Deferred $deferred)
69			{
70			$result = call_user_func_array([
71			TableRegistry::get(
			0 ignored issues – show Deprecated Code introduced 2018-10-21 13:59 UTC by Report Bug Copy Issue Report The method `Cake\ORM\TableRegistry::get()` has been deprecated with message: 3.6.0 Use \Cake\ORM\Locator\TableLocator::get() instead. This method has been deprecated. The supplier of the class has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the method will be removed from the class and what other method or class to use instead. Loading history...
72			$payload['table']/*,
			0 ignored issues – show Unused Code Comprehensibility introduced 2018-10-21 13:59 UTC by Report Bug Copy Issue Report `68%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
73			[
74			'className' => $payload['className'],
75			'table' => $payload['table'],
76			]*/
77			),
78			$payload['function'],
79			], unserialize($payload['arguments']));
80
81			if (!($result instanceof Query)) {
82			$deferred->resolve([
83			'result' => serialize($result),
84			]);
85
86			return;
87			}
88
89			foreach ($result->all() as $row) {
90			$deferred->notify([
			0 ignored issues – show Deprecated Code introduced 2018-10-21 13:59 UTC by Report Bug Copy Issue Report The method `React\Promise\Deferred::notify()` has been deprecated with message: 2.6.0 Progress support is deprecated and should not be used anymore. This method has been deprecated. The supplier of the class has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the method will be removed from the class and what other method or class to use instead. Loading history...
91			'row' => $row,
92			]);
93			}
94
95			$deferred->resolve();
96			}
97
98			/**
99			* @param Payload $payload
100			* @param Deferred $deferred
			0 ignored issues – show Bug introduced 2018-12-22 13:58 UTC by Report Bug Copy Issue Report There is no parameter named `$deferred`. Was it maybe removed? This check looks for PHPDoc comments describing methods or function parameters that do not exist on the corresponding method or function. Consider the following example. The parameter `$italy` is not defined by the method `finale(...)`. /** * @param array $germany * @param array $island * @param array $italy */ function finale($germany, $island) { return "2:1"; } The most likely cause is that the parameter was removed, but the annotation was not. Loading history...
101			*/
102			protected function handlePaginateCall(Payload $payload)
103			{
104			$object = TableRegistry::get(
			0 ignored issues – show Deprecated Code introduced 2018-12-19 18:18 UTC by Report Bug Copy Issue Report The method `Cake\ORM\TableRegistry::get()` has been deprecated with message: 3.6.0 Use \Cake\ORM\Locator\TableLocator::get() instead. This method has been deprecated. The supplier of the class has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the method will be removed from the class and what other method or class to use instead. Loading history...
105			$payload['table']/*,
			0 ignored issues – show Unused Code Comprehensibility introduced 2018-12-19 18:18 UTC by Report Bug Copy Issue Report `68%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
106			[
107			'className' => $payload['className'],
108			'table' => $payload['table'],
109			]*/
110			);
111			$paginator = new Paginator();
112
113			try {
114			$items = $paginator->paginate($object, $payload['params'], $payload['settings'])->toArray();
115			$eos = false;
116			} catch (PageOutOfBoundsException $pageOutOfBoundsException) {
117			$items = [];
118			$eos = true;
119			}
120
121			return resolve([
122			'items' => $items,
123			'eos' => $eos,
124			'pagingParams' => $paginator->getPagingParams(),
125			]);
126			}
127			}
128

WyriHaximus / cakephp-async-orm

WorkerChild::create() A last analyzed 2019-04-23 00:19 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

WorkerChild::create() A
last analyzed 2019-04-23 00:19 UTC