Bdf\QueueBundle\DependencyInjection\BdfQueueExtension

Complexity

Total Complexity

13

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Test Coverage

Coverage

79.63%

Importance

Changes	2
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	12	1
A	configureFailer()	0	13	2
A	configureDestinations()	0	24	5
A	getConfiguration()	0	3	1
A	configureSerializer()	0	7	2
A	configureConnections()	0	22	2

<?php

namespace Bdf\QueueBundle\DependencyInjection;

use Bdf\Queue\Connection\ConnectionDriverInterface;
use Bdf\Queue\Failer\DbFailedJobStorage;

The type Bdf\Queue\Failer\DbFailedJobStorage was not found. Maybe you did not declare it correctly or list all dependencies?

use Bdf\QueueBundle\ConnectionFactory\Configuration as DriverConfiguration;
use Bdf\QueueBundle\ConnectionFactory\ConnectionDriverFactory;
use Bdf\QueueBundle\FailerFactory\FailerFactory;
use Bdf\QueueBundle\FailerFactory\PrimeFailerFactory;
use Symfony\Component\Config\FileLocator;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Extension\Extension;
use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
use Symfony\Component\DependencyInjection\Reference;

/**
 * QueueExtension
 */
class BdfQueueExtension extends Extension
{
    /**
     * {@inheritDoc}
     */
    public function load(array $configs, ContainerBuilder $container)
    {
        $configuration = $this->getConfiguration($configs, $container);
        $config = $this->processConfiguration($configuration, $configs);

        $loader = new YamlFileLoader($container, new FileLocator(__DIR__ . '/../Resources/config'));
        $loader->load('queue.yaml');

        $this->configureConnections($config, $container);
        $this->configureDestinations($config, $container);

        $container->setParameter('bdf_queue.failer_dsn', $config['failer']);
    }

    /**
     * @param array $config
     * @param ContainerBuilder $container
     */
    public function configureConnections(array $config, ContainerBuilder $container): void
    {
        $connectionConfigs = [];

        foreach ($config['connections'] as $name => $options) {
            $connectionConfigs[$name] = $options;

            $container->register('bdf_queue.config_definition.'.$name, DriverConfiguration::class)
                ->setFactory([DriverConfiguration::class, 'createConfiguration'])
                ->setArguments([$name, $options]);

            $container->register('bdf_queue.connection_definition.'.$name, ConnectionDriverInterface::class)
                ->setPublic(true)
                ->setFactory($options['connection_factory'] ?? [new Reference(ConnectionDriverFactory::class), 'createDriver'])
                ->setArguments([
                    new Reference('bdf_queue.config_definition.'.$name),
                    new Reference($this->configureSerializer($options['serializer'], $config['default_serializer']))
                ]);
        }

        $container->setParameter('bdf_queue.default_connection', $config['default_connection'] ?? key($connectionConfigs));
        $container->setParameter('bdf_queue.connections', $connectionConfigs);
    }

    /**
     * @param array $config
     * @param string $default
     *
     * @return string
     */
    private function configureSerializer(array $config, string $default): string
    {
        if (isset($config['service'])) {
            return $config['service'];
        }

        return 'bdf_queue.serializer.'.($config['id'] ?? $default);
    }

    /**
     * @param array $config
     * @param ContainerBuilder $container
     */
    public function configureDestinations(array $config, ContainerBuilder $container): void
    {
        $destinations = [];
        $consumptionConfig = [];

        foreach ($config['destinations'] as $name => $options) {
            $destinations[$name] = $options['url'];

            // TODO build a builder rule in the container for this destination
            foreach ($options['consumer'] as $option => $value) {
                if ($value !== null) {
                    if (($value[0] ?? '') === '@') {
                        $value = new Reference(ltrim($value, '@'));
                    }

                    $consumptionConfig[$name][$option] = $value;
                }
            }
        }

        $container->getDefinition('bdf_queue.receiver.loader')
            ->replaceArgument(1, $consumptionConfig);

        $container->setParameter('bdf_queue.destinations', $destinations);
    }

    /**
     * @param array $config
     * @param ContainerBuilder $container
     */
    public function configureFailer(array $config, ContainerBuilder $container): void
    {
        if (PrimeFailerFactory::supported()) {
            $container->register(PrimeFailerFactory::class)
                ->setClass(PrimeFailerFactory::class)
                ->setArguments([new Reference('prime')])
            ;

            $container->findDefinition(FailerFactory::class)
                ->addMethodCall('register', [new Reference(PrimeFailerFactory::class)]);
        }

        $container->setParameter('bdf_queue.failer_dsn', $config['failer']);
    }

    /**
     * {@inheritDoc}
     */
    public function getConfiguration(array $config, ContainerBuilder $container): Configuration
    {
        return new Configuration($container->getParameter('kernel.debug'));
    }
}