Lit\Nimo\MiddlewarePipe

Complexity

Total Complexity

6

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

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

declare(strict_types=1);

namespace Lit\Nimo;

use Interop\Http\Server\MiddlewareInterface;
use Lit\Nimo\Handlers\CallableHandler;
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 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);
    }
}