chillerlan\HTTP\Psr15\RecursiveDispatcher

Complexity

Total Complexity

7

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	hp$0 ➔ __construct()	0	3	1
	handle()	0	2	?
A	hp$0 ➔ addStack()	0	12	3
A	hp$0 ➔ handle()	0	2	1
A	__construct()	0	2	1
	addStack()	0	12	?
A	hp$0 ➔ add()	0	19	1
	add()	0	19	?

<?php
/**
 * Class RecursiveDispatcher
 *
 * A simple middleware dispatcher based on Slim
 *
 * @see          https://github.com/slimphp/Slim/blob/de07f779d229ec06080259a816b0740de830438c/Slim/MiddlewareDispatcher.php
 *
 * @created      15.04.2020
 * @author       smiley <smiley@chillerlan.net>
 * @copyright    2020 smiley
 * @license      MIT
 */

namespace chillerlan\HTTP\Psr15;

use Psr\Http\Message\{ResponseInterface, ServerRequestInterface};
use Psr\Http\Server\{MiddlewareInterface, RequestHandlerInterface};

class RecursiveDispatcher implements RequestHandlerInterface{

	/**
	 * Tip of the middleware call stack
	 */
	protected RequestHandlerInterface $tip;

	/**
	 * RecursiveDispatcher constructor.
	 */
	public function __construct(RequestHandlerInterface $kernel){
		$this->tip = $kernel;
	}

	/**
	 * Add a new middleware to the stack
	 *
	 * Middleware are organized as a stack. That means middleware
	 * that have been added before will be executed after the newly
	 * added one (last in, first out).
	 */
	public function add(MiddlewareInterface $middleware):RecursiveDispatcher{

		$this->tip = new class ($middleware, $this->tip) implements RequestHandlerInterface{

			private MiddlewareInterface     $middleware;
			private RequestHandlerInterface $next;

			public function __construct(MiddlewareInterface $middleware, RequestHandlerInterface $next){
				$this->middleware = $middleware;
				$this->next       = $next;
			}

			public function handle(ServerRequestInterface $request):ResponseInterface{
				return $this->middleware->process($request, $this->next);
			}

		};

		return $this;
	}

	/**
	 * @param \Psr\Http\Server\MiddlewareInterface[] $middlewareStack
	 *
	 * @throws \chillerlan\HTTP\Psr15\MiddlewareException
	 */
	public function addStack(iterable $middlewareStack):RecursiveDispatcher{

		foreach($middlewareStack as $middleware){

			if(!$middleware instanceof MiddlewareInterface){
				throw new MiddlewareException('invalid middleware');
			}

			$this->add($middleware);
		}

		return $this;
	}

	/**
	 * @inheritDoc
	 */
	public function handle(ServerRequestInterface $request):ResponseInterface{
		return $this->tip->handle($request);
	}

}