Nimo\MiddlewarePipe

Complexity

Total Complexity

6

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

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

<?php namespace Nimo;

use Interop\Http\Server\MiddlewareInterface;
use Nimo\Handlers\CallableHandler;
use Nimo\Middlewares\CallableMiddleware;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;

/**
 * User: mcfog
 * Date: 15/9/4
 */
class MiddlewarePipe extends AbstractMiddleware
{
    /**
     * @var CallableHandler
     */
    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 mixed $middleware
     * @return $this
     */
    public function append($middleware): MiddlewarePipe
    {
        $this->stack[] = CallableMiddleware::wrap($middleware);
        return $this;
    }

    /**
     * prepend $middleware
     * return $this
     * note this method would modify $this
     *
     * @param $middleware
     * @return $this
     */
    public function prepend($middleware): MiddlewarePipe
    {
        array_unshift($this->stack, CallableMiddleware::wrap($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);
    }
}