TMV\Messenger\Factory\Retry\RetryStrategyLocatorFactory

Complexity

Total Complexity

3

Size/Duplication

Total Lines	15
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	13	3

<?php

declare(strict_types=1);

namespace TMV\Messenger\Factory\Retry;

use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Retry\RetryStrategyInterface;
use Zend\ServiceManager\ServiceManager;

final class RetryStrategyLocatorFactory
{
    public function __invoke(ContainerInterface $container): ContainerInterface
    {
        $config = $container->has('config') ? $container->get('config') : [];
        $transports = $config['messenger']['transports'] ?? [];
        $factories = [];

        foreach ($transports as $name => $transport) {
            $factories[$name] = static function () use ($name, $container): RetryStrategyInterface {
                return (new RetryStrategyFactory($name))($container);
            };
        }

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