TMV\Laminas\Messenger\Factory\Transport\Sender\SendersLocatorFactory

Complexity

Total Complexity

7

Size/Duplication

Total Lines	24
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	14	6
A	__construct()	0	3	1

<?php

declare(strict_types=1);

namespace TMV\Laminas\Messenger\Factory\Transport\Sender;

use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Transport\Sender\SendersLocator;
use Symfony\Component\Messenger\Transport\Sender\SendersLocatorInterface;
use TMV\Laminas\Messenger\Exception\LogicException;

use function class_exists;
use function interface_exists;
use function sprintf;

/**
 * @psalm-api
 */
final class SendersLocatorFactory
{
    /** @var string */
    private $busName;

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

    public function __invoke(ContainerInterface $container): SendersLocatorInterface
    {
        /** @var array<string, mixed> $config */
        $config = $container->has('config') ? $container->get('config') : [];
        /** @var string[][]|array<string, string[]> $routing */
        $routing = $config['messenger']['buses'][$this->busName]['routes'] ?? [];

        foreach ($routing as $message => $_) {
            if ('*' !== $message && ! class_exists((string) $message) && ! interface_exists((string) $message, false)) {
                throw new LogicException(sprintf('Invalid Messenger routing configuration: class or interface "%s" not found.', $message));
            }
        }

        return new SendersLocator($routing, $container);
    }
}