TMV\Laminas\Messenger\Factory\Middleware\SendMessageMiddlewareFactory

Complexity

Total Complexity

10

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	__invoke()	0	20	5
A	__callStatic()	0	10	3
A	__set_state()	0	3	1

<?php

declare(strict_types=1);

namespace TMV\Laminas\Messenger\Factory\Middleware;

use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
use Symfony\Component\Messenger\Middleware\SendMessageMiddleware;
use TMV\Laminas\Messenger\Exception\InvalidArgumentException;
use TMV\Laminas\Messenger\Factory\Transport\Sender\SendersLocatorFactory;

use function array_key_exists;
use function sprintf;

final class SendMessageMiddlewareFactory
{
    private string $busName;

    public function __construct(string $busName = 'messenger.bus.default')
    {
        $this->busName = $busName;
    }

    public function __invoke(ContainerInterface $container): SendMessageMiddleware
    {
        /** @var array<string, mixed> $config */
        $config = $container->has('config') ? $container->get('config') : [];
        /** @var string|null $logger */
        $logger = $config['messenger']['logger'] ?? null;
        /** @var string|null $eventDispatcher */
        $eventDispatcher = $config['messenger']['event_dispatcher'] ?? null;

        $factory = new SendersLocatorFactory($this->busName);
        $middleware = new SendMessageMiddleware(
            $factory($container),
            $eventDispatcher ? $container->get($eventDispatcher) : null
        );

        if ($logger && $container->has($logger)) {
            $middleware->setLogger($container->get($logger));
        }

        return $middleware;
    }

    public static function __set_state(array $data): self
    {
        return new self($data['busName'] ?? null);

It seems like $data['busName'] ?? null can also be of type null; however, parameter $busName of TMV\Laminas\Messenger\Factory\Middleware\SendMessageMiddlewareFactory::__construct() does only seem to accept string, maybe add an additional type check?

    }

    /**
     * @psalm-api
     *
     * @param array<int, mixed> $arguments
     */
    public static function __callStatic(string $name, array $arguments): MiddlewareInterface
    {
        if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) {
            throw new InvalidArgumentException(sprintf(
                'The first argument must be of type %s',
                ContainerInterface::class
            ));
        }

        return (new self($name))($arguments[0]);
    }
}