Bdf\QueueBundle\DependencyInjection\Compiler\RegisterFailerDriverPass::process()

Complexity

Conditions	4
Paths	4

Size

Total Lines	23
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	4.0582

Importance

Changes

0

<?php
    public function process(ContainerBuilder $container)
    {
        $dsn = Dsn::parse($container->getParameter('bdf_queue.failer_dsn'));
        $scheme = $dsn->getScheme();
        $availableScheme = [];

        foreach ($container->findTaggedServiceIds(self::CONFIGURATOR_TAG_NAME) as $serviceId => $tag) {
            /** @var FailerDriverConfiguratorInterface $configurator */
            $configurator = $container->get($serviceId);

            if (!$configurator->available($container)) {
                continue;
            }

            $availableScheme[] = $configurator->scheme();
            if ($scheme === $configurator->scheme()) {
                $container->setAlias(FailedJobRepositoryInterface::class, $configurator->configure($dsn, $container));

                return;
            }
        }

        throw new \InvalidArgumentException('Unsupported failer DSN scheme '.$scheme.'. Available : '.implode(', ', $availableScheme));
    }