Carno\RPC\Handlers\ServiceInvoker

Complexity

Total Complexity

4

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	outbound()	0	3	1
A	inbound()	0	5	1
A	__construct()	0	4	1
A	exception()	0	3	1

<?php
/**
 * Service invoker
 * User: moyo
 * Date: 25/09/2017
 * Time: 4:57 PM
 */

namespace Carno\RPC\Handlers;

use Carno\Chain\Layered;
use function Carno\Coroutine\async;
use Carno\Coroutine\Context;
use function Carno\Coroutine\race;
use function Carno\Coroutine\timeout;
use Carno\Promise\Promised;
use Carno\RPC\Options;
use Carno\RPC\Service\Dispatcher;
use Carno\RPC\Protocol\Request;
use Carno\RPC\Protocol\Response;
use Throwable;

class ServiceInvoker implements Layered
{
    /**
     * @var Dispatcher
     */
    private $dispatcher = null;

    /**
     * @var Options
     */
    private $options = null;

    /**
     * ServiceInvoker constructor.
     * @param Dispatcher $dispatcher
     * @param Options $options
     */
    public function __construct(Dispatcher $dispatcher, Options $options = null)
    {
        $this->dispatcher = $dispatcher;
        $this->options = $options ?? new Options;
    }

    /**
     * @param Request $request
     * @param Context $ctx
     * @return Promised
     */
    public function inbound($request, Context $ctx) : Promised
    {
        return race(async(function ($request) {
            return $this->dispatcher->invoke($request);
        }, $ctx, $request), timeout($this->options->ttExec));
    }

    /**
     * @param Response $response
     * @param Context $ctx
     * @return Response
     */
    public function outbound($response, Context $ctx) : Response
    {
        return $response;
    }

    /**
     * @param Throwable $e
     * @param Context $ctx
     * @return void
     * @throws Throwable
     */
    public function exception(Throwable $e, Context $ctx) : void
    {
        throw $e;
    }
}