Lit\Nimo\Middlewares\MiddlewarePipe

Complexity

Total Complexity

6

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	append()	0	4	1
A	__construct()	0	4	1
A	prepend()	0	4	1
A	loop()	0	7	2
A	main()	0	5	1

<?php

declare(strict_types=1);

namespace Lit\Nimo\Middlewares;

use Lit\Nimo\Handlers\CallableHandler;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

class MiddlewarePipe extends AbstractMiddleware
{
    /**
     * @var RequestHandlerInterface
     */
    protected $nextHandler;
    /**
     * @var MiddlewareInterface[]
     */
    protected $stack = [];
    protected $index;

    public function __construct()
    {
        $this->nextHandler = CallableHandler::wrap(function (ServerRequestInterface $request) {
            return $this->loop($request);
        });
    }


    /**
     * append $middleware
     * return $this
     * note this method would modify $this
     *
     * @param MiddlewareInterface $middleware
     * @return $this
     */
    public function append(MiddlewareInterface $middleware): MiddlewarePipe
    {
        $this->stack[] = $middleware;
        return $this;
    }

    /**
     * prepend $middleware
     * return $this
     * note this method would modify $this
     *
     * @param MiddlewareInterface $middleware
     * @return $this
     */
    public function prepend(MiddlewareInterface $middleware): MiddlewarePipe
    {
        array_unshift($this->stack, $middleware);
        return $this;
    }

    protected function main(): ResponseInterface
    {
        $this->index = 0;

        return $this->loop($this->request);
    }

    /**
     * @param ServerRequestInterface $request
     * @return ResponseInterface
     */
    protected function loop(ServerRequestInterface $request): ResponseInterface
    {
        if (!isset($this->stack[$this->index])) {
            return $this->delegate($request);
        }

        return $this->stack[$this->index++]->process($request, $this->nextHandler);
    }
}