0

Final Class Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareFactory

All Classes | Properties | Methods
InheritanceYiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareFactory » Yiisoft\Queue\Middleware\MiddlewareFactory
ImplementsYiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareFactoryInterface

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
createFailureMiddleware() Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareFactory

Protected Methods

Hide inherited methods

Method Description Defined By
create() Yiisoft\Queue\Middleware\MiddlewareFactory
getInterfaceName() Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareFactory
wrapMiddleware() Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareFactory

Method Details

Hide inherited methods

__construct() public method

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

public mixed __construct ( \Psr\Container\ContainerInterface $container, \Psr\Container\ContainerInterface|null $callableDependencyContainer = null )
$container \Psr\Container\ContainerInterface

Container used to resolve middleware.
$callableDependencyContainer \Psr\Container\ContainerInterface|null

Container used to resolve callable middleware dependencies. If not set, the main container is used.

 

                public function __construct(
    protected readonly ContainerInterface $container,
    ?ContainerInterface $callableDependencyContainer = null,
) {
    $this->callableFactory = new CallableFactory($container, $callableDependencyContainer);
}
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 

                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);
}
createFailureMiddleware() public method

public Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareInterface createFailureMiddleware ( array|callable|Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareInterface|string $middlewareDefinition )
$middlewareDefinition array|callable|Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareInterface|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\FailureHandling\ServerRequestInterface} and {@see \Yiisoft\Queue\Middleware\FailureHandling\RequestHandlerInterface}.
throws \Psr\Container\NotFoundExceptionInterface
throws \Psr\Container\ContainerExceptionInterface
throws Yiisoft\Queue\Middleware\InvalidMiddlewareDefinitionException 

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

protected string getInterfaceName ( )

                protected function getInterfaceName(): string
{
    return FailureMiddlewareInterface::class;
}
wrapMiddleware() protected method

protected Yiisoft\Queue\Middleware\FailureHandling\FailureMiddlewareInterface wrapMiddleware ( callable $callback )
$callback callable 

                protected function wrapMiddleware(callable $callback): FailureMiddlewareInterface
{
    return new class ($callback) implements FailureMiddlewareInterface {
        private $callback;
        public function __construct(callable $callback)
        {
            $this->callback = $callback;
        }
        public function processFailure(FailureHandlingRequest $request, FailureHandlerInterface $handler): FailureHandlingRequest
        {
            $response = ($this->callback)($request, $handler);
            if ($response instanceof FailureHandlingRequest) {
                return $response;
            }
            if ($response instanceof FailureMiddlewareInterface) {
                return $response->processFailure($request, $handler);
            }
            throw new InvalidMiddlewareDefinitionException($this->callback);
        }
    };
}