Tebe\Pvc\Middleware\MiddlewarePipe

Complexity

Total Complexity

6

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	2	1
A	process()	0	7	2
A	create()	0	7	2
A	add()	0	5	1

<?php

declare(strict_types=1);

namespace Tebe\Pvc\Middleware;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

class MiddlewarePipe implements MiddlewareInterface
{
    /**
     * @var MiddlewareInterface[]
     */
    private $middlewares = [];

    private function __construct()
    {
    }

    /**
     * @param MiddlewareInterface[] $middlewares FIFO array of middlewares
     * @return self
     */
    public static function create(array $middlewares = []): self
    {
        $pipe = new self();
        foreach ($middlewares as $middleware) {
            $pipe = $pipe->add($middleware);
        }
        return $pipe;
    }

    /**
     * @param ServerRequestInterface $request
     * @param RequestHandlerInterface $requestHandler
     * @return ResponseInterface
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $requestHandler): ResponseInterface
    {
        if (empty($this->middlewares)) {
            return $requestHandler->handle($request);
        }
        $stack = MiddlewareStack::create($requestHandler, array_reverse($this->middlewares));
        return $stack->handle($request);
    }

    /**
     * Creates a new pipe with the given middleware connected.
     *
     * @param MiddlewareInterface $middleware
     * @return self
     */
    public function add(MiddlewareInterface $middleware): self
    {
        $pipe = clone $this;
        array_push($pipe->middlewares, $middleware);
        return $pipe;
    }
}