TMV\Laminas\Messenger\Factory\Transport\Receiver\ReceiversLocatorFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	25	5

<?php

declare(strict_types=1);

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

use Symfony\Contracts\Service\ServiceProviderInterface;
use TMV\Laminas\Messenger\ServiceProvider;
use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
use TMV\Laminas\Messenger\Exception\InvalidArgumentException;

use function array_key_exists;
use function array_keys;

/**
 * @psalm-api
 */
final class ReceiversLocatorFactory
{
    public function __invoke(ContainerInterface $container): ServiceProviderInterface
    {
        $factories = [];

        $config = $container->has('config') ? $container->get('config') : [];
        $transportNames = array_keys($config['messenger']['transports'] ?? []);
        $receivers = $config['messenger']['receivers'] ?? [];

        foreach ($transportNames as $name) {
            $factories[$name] = static function () use ($name, $container): ReceiverInterface {
                return $container->get($name);
            };
        }

        foreach ($receivers as $name => $serviceName) {
            if (array_key_exists($name, $factories)) {
                throw new InvalidArgumentException(sprintf('A receiver named "%s" already exists as a transport name', $name));
            }

            $factories[$name] = static function () use ($serviceName, $container): ReceiverInterface {
                return $container->get($serviceName);
            };
        }

        return new ServiceProvider($factories);
    }
}