mindplay\middleman\Dispatcher

Complexity

Total Complexity

8

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

96%

Importance

Changes	5
Bugs	0	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	dispatch()	0	6	1
A	__invoke()	0	4	1
B	resolve()	0	26	5

<?php

namespace mindplay\middleman;

use LogicException;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * PSR-7 middleware dispatcher
 */
class Dispatcher implements MiddlewareInterface
{
    /**
     * @var callable middleware resolver
     */
    private $resolver;

    /**
     * @var mixed[] unresolved middleware stack
     */
    private $stack;

    /**
     * @var (callable|MiddlewareInterface)[] resolved middleware stack
     */
    private $resolved = [];

    /**
     * @param (callable|MiddlewareInterface|mixed)[] $stack middleware stack
     * @param callable|null $resolver optional middleware resolver
     */
    public function __construct(array $stack, callable $resolver = null)
    {
        $this->stack = $stack;
        $this->resolver = $resolver;
    }

    /**
     * @param RequestInterface  $request
     * @param ResponseInterface $response
     *
     * @return ResponseInterface
     */
    public function dispatch(RequestInterface $request, ResponseInterface $response)
    {
        $resolved = $this->resolve(0);

        return $resolved($request, $response);
    }

    /**
     * @inheritdoc
     */
    public function __invoke(RequestInterface $request, ResponseInterface $response, callable $next)
    {
        return $next($request, $this->dispatch($request, $response));
    }

    /**
     * @param int $index middleware stack index
     *
     * @return callable function (RequestInterface $request, ResponseInterface $response): ResponseInterface
     */
    private function resolve($index)
    {
        if (isset($this->stack[$index])) {
            return function (RequestInterface $request, ResponseInterface $response) use ($index) {
                if (!isset($this->resolved[$index])) {
                    $this->resolved[$index] = $this->resolver
                        ? call_user_func($this->resolver, $this->stack[$index])
                        : $this->stack[$index]; // as-is
                }

                $middleware = $this->resolved[$index];

                $result = $middleware($request, $response, $this->resolve($index + 1));

                if (!$result instanceof ResponseInterface) {
                    throw new LogicException("unexpected middleware result");
                }

                return $result;
            };
        }

        return function (RequestInterface $request, ResponseInterface $response) {
            return $response;
        };
    }
}