TMV\Messenger\Factory\Transport\Receiver\ReceiversLocatorFactory::__invoke()

Complexity

Conditions	5
Paths	12

Size

Total Lines	25
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	5

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function __invoke(ContainerInterface $container): ContainerInterface
    {
        $factories = [];

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

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

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

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

        return new ServiceManager(['factories' => $factories]);
    }