Venta\Routing\RouteDispatcher

Complexity

Total Complexity

4

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

50%

Importance

Changes	2
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	next()	0	14	3

<?php declare(strict_types = 1);

namespace Venta\Routing;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Venta\Contracts\Adr\Payload;
use Venta\Contracts\Container\Invoker;
use Venta\Contracts\Routing\Route as RouteContract;
use Venta\Contracts\Routing\RouteDispatcher as RouteDispatcherContract;

/**
 * Class RouteDispatcher
 *
 * @package Venta\Routing
 */
final class RouteDispatcher implements RouteDispatcherContract
{

    /**
     * @var Invoker
     */
    private $invoker;

    /**
     * @var RouteContract
     */
    private $route;

    /**
     * RouteDispatcher constructor.
     *
     * @param Invoker $invoker
     * @param RouteContract $route
     */
    public function __construct(Invoker $invoker, RouteContract $route)
    {
        $this->invoker = $invoker;
        $this->route = $route;
    }

    /**
     * @inheritDoc
     */
    public function next(ServerRequestInterface $request): ResponseInterface
    {
        // Add current route to the request.
        $request = $request->withAttribute('route', $this->route);

        if ($this->invoker->isCallable($this->route->domain())) {
            if ($this->invoker->isCallable([$this->route->input(), 'process'])) {
                $arguments = $this->invoker->call([$this->route->input(), 'process'], [$request]);
            }
            /** @var Payload $payload */
            $payload = $this->invoker->call($this->route->domain(), $arguments ?? []);
        }
        return $this->invoker->call([$this->route->responder(), 'run'], [$request, $payload ?? null]);
    }

}