MappingPass::handleDirectoryMapping() - Code Metrics - Inspection of "[POC] Implemtend working config with multiple inde..." - ongr-io/ElasticsearchBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#917)

by Toni

created 2020-02-11 10:11 UTC

MappingPass::handleDirectoryMapping() C

↳ Parent: Project

Complexity

Conditions	9
Paths	9

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	79
rs	6.9026
c	0
b	0
f	0
cc	9
nc	9
nop	2

How to fix Long Method

<?php

/*
 * This file is part of the ONGR package.
 *
 * (c) NFQ Technologies UAB <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace ONGR\ElasticsearchBundle\DependencyInjection\Compiler;

use ONGR\ElasticsearchBundle\Annotation\Index;
use ONGR\ElasticsearchBundle\DependencyInjection\Configuration;
use ONGR\ElasticsearchBundle\Exception\DocumentIndexParserException;
use ONGR\ElasticsearchBundle\Mapping\Converter;
use ONGR\ElasticsearchBundle\Mapping\DocumentParser;
use ONGR\ElasticsearchBundle\Mapping\IndexSettings;
use ONGR\ElasticsearchBundle\Service\IndexService;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\Container;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;

class MappingPass implements CompilerPassInterface
{
    /**
     * @var array
     */
    private $indexes = [];

    /**
     * @var string
     */
    private $defaultIndex = null;

    public function process(ContainerBuilder $container)
    {
        $kernelDir = $container->getParameter('kernel.project_dir');
        $parser = $container->get(DocumentParser::class);

        $indexClasses = [];
        $indexSettingsArray = [];
        foreach ($container->getParameter(Configuration::ONGR_SOURCE_DIR) as $dir) {
            foreach ($this->getNamespaces($kernelDir . $dir) as $namespace) {
                $indexClasses[$namespace] = $namespace;
            }
        }

        $overwrittenClasses = [];
        $indexOverrides = $container->getParameter(Configuration::ONGR_INDEXES_OVERRIDE);

        foreach ($indexOverrides as $name => $indexOverride) {
            $class = isset($indexOverride['class']) ? $indexOverride['class'] : $name;

            if (!isset($indexClasses[$class])) {
                throw new \RuntimeException(
                    sprintf(
                        'Document `%s` defined in ongr_elasticsearch.indexes config could not been found',
                        $class,
                    )

                );
            }

            $indexSettings = $this->parseIndexSettingsFromClass($parser, $class);

            if ($class !== $name) {
                $indexSettings->setIndexName('ongr.es.index.'.$name);
            }

            if (isset($indexOverride['alias'])) {
                $indexSettings->setAlias($indexOverride['alias']);
            }

            if (isset($indexOverride['settings'])) {
                $indexSettings->setIndexMetadata($indexOverride['settings']);
            }

            if (isset($indexOverride['hosts'])) {
                $indexSettings->setHosts($indexOverride['hosts']);
            }

            if (isset($indexOverride['default'])) {
                $indexSettings->setDefaultIndex($indexOverride['default']);
            }

            $indexSettingsArray[$name] = $indexSettings;
            $overwrittenClasses[$class] = $class;
        }

        foreach (array_diff($indexClasses, $overwrittenClasses) as $indexClass) {
            try {
                $indexSettingsArray[$indexClass] = $this->parseIndexSettingsFromClass($parser, $indexClass);
            } catch (DocumentIndexParserException $e) {}
        }

        foreach($indexSettingsArray as $indexSettings) {
            $this->createIndex($container, $indexSettings);
        }

        $container->setParameter(Configuration::ONGR_INDEXES, $this->indexes);
        $container->setParameter(
            Configuration::ONGR_DEFAULT_INDEX,
            $this->defaultIndex ?? current(array_keys($this->indexes))
        );
    }

    private function parseIndexSettingsFromClass(DocumentParser $parser, string $className) : IndexSettings
    {
        $class = new \ReflectionClass($className);

        /** @var Index $document */
        $document = $parser->getIndexAnnotation($class);

        if ($document === null) {
            throw new DocumentIndexParserException();
        }

        $indexSettings = new IndexSettings(
            $className,
            $className,
            $parser->getIndexAliasName($class),
            $parser->getIndexMetadata($class),
            $parser->getPropertyMetadata($class),
            $document->hosts,
            $parser->isDefaultIndex($class)
        );

        $indexSettings->setIndexMetadata(['settings' => [
            'number_of_replicas' => $document->numberOfReplicas,
            'number_of_shards' => $document->numberOfShards,
        ]]);

        return $indexSettings;
    }

    private function createIndex(Container $container, IndexSettings $indexSettings) {
        $converterDefinition = $container->getDefinition(Converter::class);

        $indexSettingsDefinition = new Definition(
            IndexSettings::class,
            [
                $indexSettings->getNamespace(),
                $indexSettings->getAlias(),
                $indexSettings->getAlias(),
                $indexSettings->getIndexMetadata(),
                $indexSettings->getPropertyMetadata(),
                $indexSettings->getHosts(),
                $indexSettings->isDefaultIndex(),
            ]
        );

        $indexServiceDefinition = new Definition(IndexService::class, [
            $indexSettings->getNamespace(),
            $converterDefinition,
            $container->getDefinition('event_dispatcher'),
            $indexSettingsDefinition,
            $container->getParameter(Configuration::ONGR_PROFILER_CONFIG)
                ? $container->getDefinition('ongr.esb.tracer') : null
        ]);

        $indexServiceDefinition->setPublic(true);
        $converterDefinition->addMethodCall(
            'addClassMetadata',
            [
                $indexSettings->getNamespace(),
                $indexSettings->getPropertyMetadata()
            ]
        );

        $container->setDefinition($indexSettings->getIndexName(), $indexServiceDefinition);
        $this->indexes[$indexSettings->getAlias()] = $indexSettings->getIndexName();
        $isCurrentIndexDefault = $indexSettings->isDefaultIndex();
        if ($this->defaultIndex && $isCurrentIndexDefault) {
            throw new \RuntimeException(
                sprintf(
                    'Only one index can be set as default. We found 2 indexes as default ones `%s` and `%s`',
                    $this->defaultIndex,
                    $indexSettings->getAlias()
                )
            );
        }

        if ($isCurrentIndexDefault) {
            $this->defaultIndex = $indexSettings->getAlias();
        }
    }

    private function getNamespaces($directory): array
    {
        if (!is_dir($directory)) {
            return [];
        }

        $iterator = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($directory));
        $files = new \RegexIterator($iterator, '/^.+\.php$/i', \RecursiveRegexIterator::GET_MATCH);

        $documents = [];

        foreach ($files as $file => $v) {
            $documents[] = $this->getFullNamespace($file) . '\\' . $this->getClassname($file);
        }

        return $documents;
    }

    private function getFullNamespace($filename)
    {
        $lines = preg_grep('/^namespace /', file($filename));
        $namespaceLine = array_shift($lines);
        $match = array();
        preg_match('/^namespace (.*);$/', $namespaceLine, $match);
        $fullNamespace = array_pop($match);

        return $fullNamespace;
    }

    private function getClassname($filename)
    {
        $directoriesAndFilename = explode('/', $filename);
        $filename = array_pop($directoriesAndFilename);
        $nameAndExtension = explode('.', $filename);
        $className = array_shift($nameAndExtension);

        return $className;
    }
}


1			<?php
2
3			/*
4			* This file is part of the ONGR package.
5			*
6			* (c) NFQ Technologies UAB <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace ONGR\ElasticsearchBundle\DependencyInjection\Compiler;
13
14			use ONGR\ElasticsearchBundle\Annotation\Index;
15			use ONGR\ElasticsearchBundle\DependencyInjection\Configuration;
16			use ONGR\ElasticsearchBundle\Exception\DocumentIndexParserException;
17			use ONGR\ElasticsearchBundle\Mapping\Converter;
18			use ONGR\ElasticsearchBundle\Mapping\DocumentParser;
19			use ONGR\ElasticsearchBundle\Mapping\IndexSettings;
20			use ONGR\ElasticsearchBundle\Service\IndexService;
21			use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
22			use Symfony\Component\DependencyInjection\Container;
23			use Symfony\Component\DependencyInjection\ContainerBuilder;
24			use Symfony\Component\DependencyInjection\Definition;
25
26			class MappingPass implements CompilerPassInterface
27			{
28			/**
29			* @var array
30			*/
31			private $indexes = [];
32
33			/**
34			* @var string
35			*/
36			private $defaultIndex = null;
37
38			public function process(ContainerBuilder $container)
39			{
40			$kernelDir = $container->getParameter('kernel.project_dir');
41			$parser = $container->get(DocumentParser::class);
42
43			$indexClasses = [];
44			$indexSettingsArray = [];
45			foreach ($container->getParameter(Configuration::ONGR_SOURCE_DIR) as $dir) {
46			foreach ($this->getNamespaces($kernelDir . $dir) as $namespace) {
47			$indexClasses[$namespace] = $namespace;
48			}
49			}
50
51			$overwrittenClasses = [];
52			$indexOverrides = $container->getParameter(Configuration::ONGR_INDEXES_OVERRIDE);
53
54			foreach ($indexOverrides as $name => $indexOverride) {
55			$class = isset($indexOverride['class']) ? $indexOverride['class'] : $name;
56
57			if (!isset($indexClasses[$class])) {
58			throw new \RuntimeException(
59			sprintf(
60			'Document `%s` defined in ongr_elasticsearch.indexes config could not been found',
61			$class,
62			)
			0 ignored issues – show Bug introduced 2020-02-11 10:13 UTC by Report Bug Copy Issue Report This code did not parse for me. Apparently, there is an error somewhere around this line: Syntax error, unexpected ')' Loading history...
63			);
64			}
65
66			$indexSettings = $this->parseIndexSettingsFromClass($parser, $class);
67
68			if ($class !== $name) {
69			$indexSettings->setIndexName('ongr.es.index.'.$name);
70			}
71
72			if (isset($indexOverride['alias'])) {
73			$indexSettings->setAlias($indexOverride['alias']);
74			}
75
76			if (isset($indexOverride['settings'])) {
77			$indexSettings->setIndexMetadata($indexOverride['settings']);
78			}
79
80			if (isset($indexOverride['hosts'])) {
81			$indexSettings->setHosts($indexOverride['hosts']);
82			}
83
84			if (isset($indexOverride['default'])) {
85			$indexSettings->setDefaultIndex($indexOverride['default']);
86			}
87
88			$indexSettingsArray[$name] = $indexSettings;
89			$overwrittenClasses[$class] = $class;
90			}
91
92			foreach (array_diff($indexClasses, $overwrittenClasses) as $indexClass) {
93			try {
94			$indexSettingsArray[$indexClass] = $this->parseIndexSettingsFromClass($parser, $indexClass);
95			} catch (DocumentIndexParserException $e) {}
96			}
97
98			foreach($indexSettingsArray as $indexSettings) {
99			$this->createIndex($container, $indexSettings);
100			}
101
102			$container->setParameter(Configuration::ONGR_INDEXES, $this->indexes);
103			$container->setParameter(
104			Configuration::ONGR_DEFAULT_INDEX,
105			$this->defaultIndex ?? current(array_keys($this->indexes))
106			);
107			}
108
109			private function parseIndexSettingsFromClass(DocumentParser $parser, string $className) : IndexSettings
110			{
111			$class = new \ReflectionClass($className);
112
113			/** @var Index $document */
114			$document = $parser->getIndexAnnotation($class);
115
116			if ($document === null) {
117			throw new DocumentIndexParserException();
118			}
119
120			$indexSettings = new IndexSettings(
121			$className,
122			$className,
123			$parser->getIndexAliasName($class),
124			$parser->getIndexMetadata($class),
125			$parser->getPropertyMetadata($class),
126			$document->hosts,
127			$parser->isDefaultIndex($class)
128			);
129
130			$indexSettings->setIndexMetadata(['settings' => [
131			'number_of_replicas' => $document->numberOfReplicas,
132			'number_of_shards' => $document->numberOfShards,
133			]]);
134
135			return $indexSettings;
136			}
137
138			private function createIndex(Container $container, IndexSettings $indexSettings) {
139			$converterDefinition = $container->getDefinition(Converter::class);
140
141			$indexSettingsDefinition = new Definition(
142			IndexSettings::class,
143			[
144			$indexSettings->getNamespace(),
145			$indexSettings->getAlias(),
146			$indexSettings->getAlias(),
147			$indexSettings->getIndexMetadata(),
148			$indexSettings->getPropertyMetadata(),
149			$indexSettings->getHosts(),
150			$indexSettings->isDefaultIndex(),
151			]
152			);
153
154			$indexServiceDefinition = new Definition(IndexService::class, [
155			$indexSettings->getNamespace(),
156			$converterDefinition,
157			$container->getDefinition('event_dispatcher'),
158			$indexSettingsDefinition,
159			$container->getParameter(Configuration::ONGR_PROFILER_CONFIG)
160			? $container->getDefinition('ongr.esb.tracer') : null
161			]);
162
163			$indexServiceDefinition->setPublic(true);
164			$converterDefinition->addMethodCall(
165			'addClassMetadata',
166			[
167			$indexSettings->getNamespace(),
168			$indexSettings->getPropertyMetadata()
169			]
170			);
171
172			$container->setDefinition($indexSettings->getIndexName(), $indexServiceDefinition);
173			$this->indexes[$indexSettings->getAlias()] = $indexSettings->getIndexName();
174			$isCurrentIndexDefault = $indexSettings->isDefaultIndex();
175			if ($this->defaultIndex && $isCurrentIndexDefault) {
176			throw new \RuntimeException(
177			sprintf(
178			'Only one index can be set as default. We found 2 indexes as default ones `%s` and `%s`',
179			$this->defaultIndex,
180			$indexSettings->getAlias()
181			)
182			);
183			}
184
185			if ($isCurrentIndexDefault) {
186			$this->defaultIndex = $indexSettings->getAlias();
187			}
188			}
189
190			private function getNamespaces($directory): array
191			{
192			if (!is_dir($directory)) {
193			return [];
194			}
195
196			$iterator = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($directory));
197			$files = new \RegexIterator($iterator, '/^.+\.php$/i', \RecursiveRegexIterator::GET_MATCH);
198
199			$documents = [];
200
201			foreach ($files as $file => $v) {
202			$documents[] = $this->getFullNamespace($file) . '\\' . $this->getClassname($file);
203			}
204
205			return $documents;
206			}
207
208			private function getFullNamespace($filename)
209			{
210			$lines = preg_grep('/^namespace /', file($filename));
211			$namespaceLine = array_shift($lines);
212			$match = array();
213			preg_match('/^namespace (.*);$/', $namespaceLine, $match);
214			$fullNamespace = array_pop($match);
215
216			return $fullNamespace;
217			}
218
219			private function getClassname($filename)
220			{
221			$directoriesAndFilename = explode('/', $filename);
222			$filename = array_pop($directoriesAndFilename);
223			$nameAndExtension = explode('.', $filename);
224			$className = array_shift($nameAndExtension);
225
226			return $className;
227			}
228			}
229

ongr-io / ElasticsearchBundle

Pull Request — master (#917)

MappingPass::handleDirectoryMapping() C

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like