Yiisoft\Queue\Middleware\MiddlewareStack

Complexity

Total Complexity

5

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	build()	0	9	2
A	handle()	0	8	2
	wrap()	0	18	?
A	__construct()	0	4	1
A	hp$0 ➔ wrap()	0	18	2
A	hp$0 ➔ __construct()	0	4	1
A	hp$0 ➔ handle()	0	7	2

<?php

declare(strict_types=1);

namespace Yiisoft\Queue\Middleware;

use Closure;

final class MiddlewareStack implements MessageHandlerInterface
{
    /**
     * Contains a stack of middleware wrapped in handlers.
     * Each handler points to the handler of middleware that will be processed next.
     *
     * @var MessageHandlerInterface|null stack of middleware
     */
    private ?MessageHandlerInterface $stack = null;

    /**
     * @param Closure[] $middlewares Middlewares.
     * @param MessageHandlerInterface $finishHandler Fallback handler
     * events.
     */
    public function __construct(
        private array $middlewares,
        private MessageHandlerInterface $finishHandler,
    ) {
    }

    public function handle(Request $request): Request
    {
        if ($this->stack === null) {
            $this->build();
        }

        /** @psalm-suppress PossiblyNullReference */
        return $this->stack->handle($request);

The method handle() does not exist on null.

    }

    private function build(): void
    {
        $handler = $this->finishHandler;

        foreach ($this->middlewares as $middleware) {
            $handler = $this->wrap($middleware, $handler);
        }

        $this->stack = $handler;
    }

    /**
     * Wrap handler by middlewares.
     */
    private function wrap(Closure $middlewareFactory, MessageHandlerInterface $handler): MessageHandlerInterface
    {
        return new class ($middlewareFactory, $handler) implements MessageHandlerInterface {
            private ?MiddlewareInterface $middleware = null;

            public function __construct(
                private Closure $middlewareFactory,
                private MessageHandlerInterface $handler,
            ) {
            }

            public function handle(Request $request): Request
            {
                if ($this->middleware === null) {
                    $this->middleware = ($this->middlewareFactory)();
                }

                return $this->middleware->process($request, $this->handler);

The method process() does not exist on null.

            }
        };
    }
}