Client::__construct() - Code Metrics - carno-php/rpc - Measure and Improve Code Quality continuously with Scrutinizer

Client::__construct() A
last analyzed 2019-04-03 06:42 UTC

↳ Parent: Client

Complexity

Conditions	4
Paths	3

Size

Total Lines	11
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	8
dl	0
loc	11
c	0
b	0
f	0
rs	10
cc	4
nc	3
nop	2

<?php
/**
 * RPC client base
 * User: moyo
 * Date: 27/09/2017
 * Time: 6:14 PM
 */

namespace Carno\RPC;

use function Carno\Coroutine\ctx;
use Carno\RPC\Chips\HChains;
use Carno\RPC\Chips\NamedKit;
use Carno\RPC\Contracts\Client\Cluster;
use Carno\RPC\Contracts\Client\Remapping;
use Carno\RPC\Exception\ClientInitializingException;
use Carno\RPC\Protocol\Request;
use Carno\RPC\Protocol\Response;
use Google\Protobuf\Internal\Message;
use Closure;

abstract class Client
{
    use NamedKit, HChains;

    /**
     * @var Closure
     */
    private $invoker = null;

    /**
     * Client constructor.
     * @param Cluster $clustering
     * @param Remapping $remapping
     */
    final public function __construct(Cluster $clustering = null, Remapping $remapping = null)
    {
        $serv = $this->namedServer(static::class);

        if ($remapping && $remapping->configured($serv)) {
            $this->invoker = $remapping->dispatcher()->handler();
        } elseif ($clustering) {
            $clustering->joining($serv);
            $this->invoker = Client::layers()->handler();
        } else {
            throw new ClientInitializingException;
        }
    }

    /**
     * @param string $server
     * @param string $service
     * @param string $method
     * @param Message $request
     * @param Message $response
     * @return Message
     */
    final protected function request(
        string $server,
        string $service,
        string $method,
        Message $request,
        Message $response
    ) {
        $rpc =
            (new Request($server, $service, $method))
                ->setJsonc(false)
                ->setPayload($request->serializeToString())
        ;

        /**
         * @var Response $resp
         */
        $resp = yield ($this->invoker)($rpc, clone yield ctx());


        $response->mergeFromString($resp->getPayload());

        return $response;
    }
}


1			<?php
2			/**
3			* RPC client base
4			* User: moyo
5			* Date: 27/09/2017
6			* Time: 6:14 PM
7			*/
8
9			namespace Carno\RPC;
10
11			use function Carno\Coroutine\ctx;
12			use Carno\RPC\Chips\HChains;
13			use Carno\RPC\Chips\NamedKit;
14			use Carno\RPC\Contracts\Client\Cluster;
15			use Carno\RPC\Contracts\Client\Remapping;
16			use Carno\RPC\Exception\ClientInitializingException;
17			use Carno\RPC\Protocol\Request;
18			use Carno\RPC\Protocol\Response;
19			use Google\Protobuf\Internal\Message;
20			use Closure;
21
22			abstract class Client
23			{
24			use NamedKit, HChains;
25
26			/**
27			* @var Closure
28			*/
29			private $invoker = null;
30
31			/**
32			* Client constructor.
33			* @param Cluster $clustering
34			* @param Remapping $remapping
35			*/
36			final public function __construct(Cluster $clustering = null, Remapping $remapping = null)
37			{
38			$serv = $this->namedServer(static::class);
39
40			if ($remapping && $remapping->configured($serv)) {
41			$this->invoker = $remapping->dispatcher()->handler();
42			} elseif ($clustering) {
43			$clustering->joining($serv);
44			$this->invoker = Client::layers()->handler();
45			} else {
46			throw new ClientInitializingException;
47			}
48			}
49
50			/**
51			* @param string $server
52			* @param string $service
53			* @param string $method
54			* @param Message $request
55			* @param Message $response
56			* @return Message
57			*/
58			final protected function request(
59			string $server,
60			string $service,
61			string $method,
62			Message $request,
63			Message $response
64			) {
65			$rpc =
66			(new Request($server, $service, $method))
67			->setJsonc(false)
68			->setPayload($request->serializeToString())
69			;
70
71			/**
72			* @var Response $resp
73			*/
74			$resp = yield ($this->invoker)($rpc, clone yield ctx());
			0 ignored issues – show Bug Best Practice introduced 2019-01-09 16:15 UTC by Report Bug Copy Issue Report The expression `yield $this->invoker($rpc, clone yield ctx())` returns the type `Generator` which is incompatible with the documented return type `Google\Protobuf\Internal\Message`. Loading history...
75
76			$response->mergeFromString($resp->getPayload());
77
78			return $response;
79			}
80			}
81

carno-php / rpc

Client::__construct() A last analyzed 2019-04-03 06:42 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Client::__construct() A
last analyzed 2019-04-03 06:42 UTC