0 follower

Final Class Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareFactory

All Classes | Properties | Methods

Inheritance	Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareFactory » Yiisoft\Queue\Middleware\MiddlewareFactory
Implements	Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareFactoryInterface

Creates a middleware based on the definition provided.

Protected Properties

Hide inherited properties

Property	Type	Description	Defined By
$container	\Psr\Container\ContainerInterface		Yiisoft\Queue\Middleware\MiddlewareFactory

Public Methods

Hide inherited methods

Method	Description	Defined By
__construct()		Yiisoft\Queue\Middleware\MiddlewareFactory
createConsumeMiddleware()		Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareFactory

Protected Methods

Hide inherited methods

Method	Description	Defined By
create()		Yiisoft\Queue\Middleware\MiddlewareFactory
getInterfaceName()		Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareFactory
wrapMiddleware()		Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareFactory

Method Details

Hide inherited methods

__construct() public method

Defined in: Yiisoft\Queue\Middleware\MiddlewareFactory::__construct()

public mixed __construct ( \Psr\Container\ContainerInterface $container, Yiisoft\Queue\Middleware\CallableFactory $callableFactory )
$container	\Psr\Container\ContainerInterface
$callableFactory	Yiisoft\Queue\Middleware\CallableFactory

Source code

                public function __construct(
    protected readonly ContainerInterface $container,
    private readonly CallableFactory $callableFactory,
) {}

create() protected method

Defined in: Yiisoft\Queue\Middleware\MiddlewareFactory::create()

protected \Yiisoft\Queue\Middleware\T create ( callable\|array\|string $definition )
$definition	callable\|array\|string	Middleware definition in one of the following formats:
return	\Yiisoft\Queue\Middleware\T	Middleware instance
throws	Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException

Source code

                protected function create(callable|array|string $definition): object
{
    try {
        $callable = $this->callableFactory->create($definition);
        return $this->wrapMiddleware($callable);
    } catch (InvalidCallableConfigurationException) {
        // Not a callable, try internal checks
    }
    if (is_string($definition)) {
        return $this->getFromContainer($definition);
    }
    if (is_array($definition)) {
        return $this->tryGetFromArrayDefinition($definition)
            ?? throw new InvalidMiddlewareDefinitionException($definition);
    }
    throw new InvalidMiddlewareDefinitionException($definition);
}

createConsumeMiddleware() public method

public Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareInterface createConsumeMiddleware ( Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareInterface\|callable\|array\|string $middlewareDefinition )
$middlewareDefinition	Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareInterface\|callable\|array\|string	Middleware definition in one of the following formats: A middleware object. A name of a middleware class. The middleware instance will be obtained from container and executed. A callable with `function(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface` signature. A controller handler action in format `[TestController::class, 'index']`. `TestController` instance will be created and `index()` method will be executed. A function returning a middleware. The middleware returned will be executed. For handler action and callable typed parameters are automatically injected using dependency injection container. Current request and handler could be obtained by type-hinting for {@see \Yiisoft\Queue\Middleware\Consume\ServerRequestInterface} and {@see \Yiisoft\Queue\Middleware\Consume\RequestHandlerInterface}.
throws	Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException

Source code

                public function createConsumeMiddleware(
    ConsumeMiddlewareInterface|callable|array|string $middlewareDefinition,
): ConsumeMiddlewareInterface {
    if ($middlewareDefinition instanceof ConsumeMiddlewareInterface) {
        return $middlewareDefinition;
    }
    $middleware = $this->create($middlewareDefinition);
    if (!$middleware instanceof ConsumeMiddlewareInterface) {
        throw new InvalidMiddlewareDefinitionException($middlewareDefinition);
    }
    return $middleware;
}

getInterfaceName() protected method

protected string getInterfaceName ( )

Source code

                protected function getInterfaceName(): string
{
    return ConsumeMiddlewareInterface::class;
}

wrapMiddleware() protected method

protected Yiisoft\Queue\Middleware\Consume\ConsumeMiddlewareInterface wrapMiddleware ( callable $callback )
$callback	callable

Source code

                protected function wrapMiddleware(callable $callback): ConsumeMiddlewareInterface
{
    $container = $this->container;
    return new class ($callback, $container) implements ConsumeMiddlewareInterface {
        private $callback;
        public function __construct(
            callable $callback,
            private readonly ContainerInterface $container,
        ) {
            $this->callback = $callback;
        }
        public function processConsume(ConsumeRequest $request, ConsumeHandlerInterface $handler): ConsumeRequest
        {
            $response = (new Injector($this->container))->invoke($this->callback, [$request, $handler]);
            if ($response instanceof ConsumeRequest) {
                return $response;
            }
            if ($response instanceof ConsumeMiddlewareInterface) {
                return $response->processConsume($request, $handler);
            }
            throw new InvalidMiddlewareDefinitionException($this->callback);
        }
    };
}