Tleckie\Router\MiddlewareDispatcher

Complexity

Total Complexity

4

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	withoutMiddleware()	0	10	1
A	__construct()	0	4	1
A	handle()	0	7	2

<?php

namespace Tleckie\Router;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use function array_filter;
use function array_shift;

/**
 * Class MiddlewareDispatcher
 *
 * @package Tleckie\Router
 * @author  Teodoro Leckie Westberg <teodoroleckie@gmail.com>
 */
class MiddlewareDispatcher implements RequestHandlerInterface
{
    /** @var MiddlewareInterface[] */
    private array $middlewares;

    /** @var ResponseInterface */
    private ResponseInterface $response;

    /**
     * MiddlewareDispatcher constructor.
     *
     * @param ResponseInterface   $response
     * @param MiddlewareInterface ...$middlewares
     */
    public function __construct(ResponseInterface $response, MiddlewareInterface ...$middlewares)
    {
        $this->response = $response;
        $this->middlewares = $middlewares;
    }

    /**
     * @param ServerRequestInterface $request
     * @return ResponseInterface
     */
    public function handle(ServerRequestInterface $request): ResponseInterface
    {
        $middleware = array_shift($this->middlewares);

        return $middleware
            ? $middleware->process($request, $this->withoutMiddleware($middleware))
            : $this->response;
    }

    /**
     * @param MiddlewareInterface $middleware
     * @return RequestHandlerInterface
     */
    private function withoutMiddleware(MiddlewareInterface $middleware): RequestHandlerInterface
    {
        $collection = array_filter(
            $this->middlewares,
            static function ($current) use ($middleware) {
                return $middleware !== $current;
            }
        );

        return new self($this->response, ...$collection);
    }
}