ONGR\ElasticsearchBundle\DependencyInjection\Compiler\MappingPass::process()

Complexity

Conditions	8
Paths	18

Size

Total Lines	75
Code Lines	42

Duplication

Lines	0
Ratio	0 %

Importance

Changes	4
Bugs	0	Features	1

<?php
    public function process(ContainerBuilder $container)
    {
        $analysis = $container->getParameter('es.analysis');
        $connections = $container->getParameter('es.connections');
        $managers = $container->getParameter('es.managers');

        $collector = $container->get('es.metadata_collector');

        foreach ($managers as $managerName => $manager) {
            if (!empty($manager['index'])) {
                $connection = $manager['index'];
            } else {
                if (!isset($manager['connection']) || !isset($connections[$manager['connection']])) {
                    throw new InvalidConfigurationException(
                        'There is an error in the ES connection configuration of the manager: ' . $managerName
                    );
                }

                $connection = $connections[$manager['connection']];
            }

            if (isset($connection['auth'])) {
                trigger_error(
                    '`auth` usage in elasticsearch bundle configuration is deprecated, ' .
                    'add your auth configuration directly in the host. This will be removed in v3.0. More: ' .
                    'https://www.elastic.co/guide/en/elasticsearch/client/php-api/2.0/_security.html',
                    E_USER_DEPRECATED
                );
            }

            $managerName = strtolower($managerName);

            $managerDefinition = new Definition(
                'ONGR\ElasticsearchBundle\Service\Manager',
                [
                    $managerName,
                    $connection,
                    $analysis,
                    $manager,
                ]
            );
            $managerDefinition->setFactory(
                [
                    new Reference('es.manager_factory'),
                    'createManager',
                ]
            );

            $container->setDefinition(sprintf('es.manager.%s', $managerName), $managerDefinition);

            // Make es.manager.default as es.manager service.
            if ($managerName === 'default') {
                $container->setAlias('es.manager', 'es.manager.default');
            }

            $mappings = $collector->getMappings($manager['mappings']);

            // Building repository services.
            foreach ($mappings as $repositoryType => $repositoryDetails) {
                $repositoryDefinition = new Definition(
                    'ONGR\ElasticsearchBundle\Service\Repository',
                    [$repositoryDetails['namespace']]
                );
                $repositoryDefinition->setFactory(
                    [
                        new Reference(sprintf('es.manager.%s', $managerName)),
                        'getRepository',
                    ]
                );

                $repositoryId = sprintf('es.manager.%s.%s', $managerName, $repositoryType);
                $container->setDefinition($repositoryId, $repositoryDefinition);
            }
        }
    }
}