Cormy\Server\Onion

Complexity

Total Complexity

6

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	6	1
B	processMiddleware()	0	22	4

<?php

namespace Cormy\Server;

use Throwable;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;

/**
 * Onion style PSR-7 middleware stack.
 */
class Onion implements RequestHandlerInterface
{
    /**
     * @var callable|RequestHandlerInterface
     */
    protected $core;

    /**
     * @var callable[]|MiddlewareInterface[]
     */
    protected $scales;

    /**
     * Constructs an onion style PSR-7 middleware stack.
     *
     * @param callable|RequestHandlerInterface $core   the innermost request handler
     * @param callable[]|MiddlewareInterface[] $scales the middlewares to wrap around the core
     */
    public function __construct(callable $core, callable ...$scales)
    {
        $this->core = $core;
        $this->scales = $scales;
    }

    /**
     * {@inheritdoc}
     */
    public function __invoke(ServerRequestInterface $request):ResponseInterface
    {
        $topIndex = count($this->scales) - 1;

        return $this->processMiddleware($topIndex, $request);
    }

    /**
     * Process an incoming server request by delegating it to the middleware specified by $index.
     *
     * @param int                    $index   the $scales index
     * @param ServerRequestInterface $request
     *
     * @return ResponseInterface
     */
    protected function processMiddleware(int $index, ServerRequestInterface $request):ResponseInterface
    {
        if ($index < 0) {
            return ($this->core)($request);
        }

        $current = $this->scales[$index]($request);
        $nextIndex = $index - 1;

        while ($current->valid()) {
            $nextRequest = $current->current();

            try {
                $nextResponse = $this->processMiddleware($nextIndex, $nextRequest);
                $current->send($nextResponse);
            } catch (Throwable $exception) {

The class Throwable does not exist. Is this class maybe located in a folder that is not analyzed, or in a newer version of your dependencies than listed in your composer.lock/composer.json?

                $current->throw($exception);
            }
        }

        return $current->getReturn();
    }
}