Igni\Network\Http\Middleware\MiddlewarePipe

Complexity

Total Complexity

9

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	2
A	__clone()	0	4	1
A	__invoke()	0	4	1
A	handle()	0	11	2
A	process()	0	6	1
A	add()	0	6	2

<?php declare(strict_types=1);

namespace Igni\Network\Http\Middleware;

use Igni\Network\Exception\MiddlewareException;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use SplQueue;

/**
 * Variation of zend stratigility's pipe.
 */
class MiddlewarePipe implements MiddlewareInterface, RequestHandlerInterface
{
    protected $pipeline;

    public function __construct(SplQueue $pipeline = null)
    {
        $this->pipeline = $pipeline ?: new SplQueue();
    }

    public function __clone()
    {
        $this->pipeline = clone $this->pipeline;
    }

    public function __invoke(ServerRequestInterface $request): ResponseInterface
    {
        return $this->handle($request);
    }

    /**
     * De-queues and executes middleware from the top of the cloned pipeline.
     *
     * @param ServerRequestInterface $request
     * @return ResponseInterface
     */
    public function handle(ServerRequestInterface $request): ResponseInterface
    {
        if ($this->pipeline->isEmpty()) {
            throw MiddlewareException::forEmptyMiddlewarePipeline();
        }

        $pipeline = clone $this;
        $middleware = $pipeline->pipeline->dequeue();

        return $middleware->process($request, $pipeline);
    }

    /**
     * PSR-15 Middleware invocation
     *
     * @param ServerRequestInterface $request
     * @param RequestHandlerInterface $handler
     * @return ResponseInterface
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $next = new Next($this->pipeline, $handler);

        return $next($request);
    }

    /**
     * Attach middleware to the pipeline.
     *
     * @param MiddlewareInterface|callable ...$middleware
     */
    public function add(MiddlewareInterface ...$middleware): void
    {
        foreach ($middleware as $item) {
            $this->pipeline->enqueue($item);
        }
    }
}