Carno\RPC\Client

Complexity

Total Complexity

5

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	4
A	request()	0	21	1

<?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());

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.

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

        return $response;
    }
}