DoctrineOrmServiceProvider::register() - Code Metrics - jadephp/jade - Measure and Improve Code Quality continuously with Scrutinizer

DoctrineOrmServiceProvider::register() F
last analyzed 2019-09-24 05:32 UTC

↳ Parent: DoctrineOrmServiceProvider

Complexity

Conditions	19
Paths	3

Size

Total Lines

177

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	177
rs	3.6133
c	0
b	0
f	0
cc	19
nc	3
nop	1

How to fix Long Method Complexity

<?php

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

namespace Jade\Provider;

use Doctrine\Common\Persistence\Mapping\Driver\MappingDriverChain;
use Doctrine\ORM\Configuration;
use Doctrine\ORM\EntityManager;
use Doctrine\ORM\Mapping\Driver\SimplifiedXmlDriver;
use Doctrine\ORM\Mapping\Driver\SimplifiedYamlDriver;
use Doctrine\ORM\Mapping\Driver\XmlDriver;
use Doctrine\ORM\Mapping\Driver\YamlDriver;
use Doctrine\ORM\Tools\Console\ConsoleRunner;
use Doctrine\ORM\Tools\ResolveTargetEntityListener;
use Jade\CommandProviderInterface;
use Jade\Console\Application;
use Jade\Container;
use Jade\ContainerInterface;
use Jade\ServiceProviderInterface;

/**
 * Doctrine ORM Pimple Service Provider.
 *
 * @author Beau Simensen <[email protected]>
 */
class DoctrineOrmServiceProvider implements ServiceProviderInterface, CommandProviderInterface
{
    public function provide(Application $app, ContainerInterface $container)
    {
        ConsoleRunner::addCommands($app);
        $helperSet = $app->getHelperSet();
        $doctrineHelperSet = ConsoleRunner::createHelperSet($container['orm']);
        foreach ($doctrineHelperSet as $alias =>$helper) {
            $helperSet->set($helper, $alias);
        }
        $app->setHelperSet($helperSet);
    }

    public function register(ContainerInterface $container)
    {
        if (!isset($container['dbs'])) {
            throw new \LogicException(
                'You must register the DoctrineServiceProvider to use the DoctrineOrmServiceProvider.'
            );
        }

        if (!isset($container['caches'])) {
            throw new \LogicException(
                'You must register the DoctrineCacheServiceProvider to use the DoctrineOrmServiceProvider.'
            );
        }

        // 初始值
        $container->add($this->getOrmDefaults());

        $container['ems.options.initializer'] = $container->protect(function () use ($container) {
            static $initialized = false;

            if ($initialized) {
                return;
            }

            $initialized = true;

            if (!isset($container['ems.options'])) {
                $container['ems.options'] = [
                    'default' => $container['orm.options'] ?? [],
                ];
            }

            $container['ems.options'] = array_map(function ($options) use ($container) {
                return array_replace($container['orm.default_options'], $options);
            }, $container['ems.options']);

            if (!isset($container['ems.default'])) {
                $container['ems.default'] = array_keys(
                    array_slice($container['ems.options'], 0, 1)
                )[0];
            }
        });

        $container['ems'] = function (Container $container) {
            $container['ems.options.initializer']();

            $ems = new Container();
            foreach ($container['ems.options'] as $name => $options) {
                $config = $container['ems.default'] === $name
                    ? $container['orm.config']
                    : $container['ems.config'][$name];

                $connection = $container['dbs'][$options['connection']];
                $manager = $container['dbs.event_manager'][$options['connection']];

                if ($targetEntities = $options['resolve_target_entities'] ?? []) {
                    $manager->addEventSubscriber(
                        $container['orm.resolve_target_entity']($targetEntities)
                    );
                }

                $ems[$name] = function () use ($connection, $config, $manager) {
                    return EntityManager::create($connection, $config, $manager);
                };
            }

            return $ems;
        };

        $container['ems.config'] = function (Container $container) {
            $container['ems.options.initializer']();

            $configs = new Container();
            foreach ($container['ems.options'] as $name => $options) {
                $config = new Configuration();
                $config->setProxyDir($container['orm.proxy_dir']);
                $config->setProxyNamespace($container['orm.proxy_namespace']);
                $config->setAutoGenerateProxyClasses($container['orm.auto_generate_proxy_classes']);
                $config->setCustomStringFunctions($container['orm.custom_functions_string']);
                $config->setCustomNumericFunctions($container['orm.custom_functions_numeric']);
                $config->setCustomDatetimeFunctions($container['orm.custom_functions_datetime']);
                $config->setMetadataCacheImpl($container['orm.cache.factory']('metadata', $options));
                $config->setQueryCacheImpl($container['orm.cache.factory']('query', $options));
                $config->setResultCacheImpl($container['orm.cache.factory']('result', $options));
                $config->setMetadataDriverImpl($container['orm.mapping.chain']($config, $options['mappings']));

                $configs[$name] = $config;
            }

            return $configs;
        };

        $container['orm.cache.factory'] = $container->protect(function ($type, $options) use ($container) {
            $type = $type . '_cache_driver';

            $options[$type] = $options[$type] ?? 'array';

            if (!is_array($options[$type])) {
                $options[$type] = [
                    'driver' => $options[$type],
                ];
            }

            $driver = $options[$type]['driver'];
            $namespace = $options[$type]['namespace'] ?? null;

            $cache = $container['cache_factory']($driver, $options);
            $cache->setNamespace($namespace);

            return $cache;
        });

        $container['orm.mapping.chain'] = $container->protect(function (Configuration $config, array $mappings) {
            $chain = new MappingDriverChain();

            foreach ($mappings as $mapping) {
                if (!is_array($mapping)) {
                    throw new \InvalidArgumentException();
                }

                $path = $mapping['path'];
                $namespace = $mapping['namespace'];

                switch ($mapping['type']) {
                    case 'annotation':
                        $annotationDriver = $config->newDefaultAnnotationDriver(
                            $path,
                            $mapping['use_simple_annotation_reader'] ?? true
                        );
                        $chain->addDriver($annotationDriver, $namespace);
                        break;
                    case 'yml':
                        $chain->addDriver(new YamlDriver($path), $namespace);
                        break;
                    case 'simple_yml':
                        $driver = new SimplifiedYamlDriver([$path => $namespace]);
                        $chain->addDriver($driver, $namespace);
                        break;
                    case 'xml':
                        $chain->addDriver(new XmlDriver($path), $namespace);
                        break;
                    case 'simple_xml':
                        $driver = new SimplifiedXmlDriver([$path => $namespace]);
                        $chain->addDriver($driver, $namespace);
                        break;
                    default:
                        throw new \InvalidArgumentException();
                        break;
function fx() {
    try {
        doSomething();
        return true;
    }
    catch (\Exception $e) {
        return false;
    }

    return false;
}
                }
            }

            return $chain;
        });

        $container['orm.resolve_target_entity'] = $container->protect(function (array $targetEntities) {
            $rtel = new ResolveTargetEntityListener();

            foreach ($targetEntities as $originalEntity => $newEntity) {
                $rtel->addResolveTargetEntity($originalEntity, $newEntity, []);
            }

            return $rtel;
        });

        // shortcuts for the "first" ORM
        $container['orm'] = function (Container $container) {
            $ems = $container['ems'];

            return $ems[$container['ems.default']];
        };

        $container['orm.config'] = function (Container $container) {
            $ems = $container['ems.config'];

            return $ems[$container['ems.default']];
        };
    }

    protected function getOrmDefaults()
    {
        return [
            'orm.proxy_dir' => null,
            'orm.proxy_namespace' => 'Proxy',
            'orm.auto_generate_proxy_classes' => true,
            'orm.custom_functions_string' => [],
            'orm.custom_functions_numeric' => [],
            'orm.custom_functions_datetime' => [],
            'orm.default_options' => [
                'connection' => 'default',
                'mappings' => [],
            ]
        ];
    }
}

1			<?php
2
3			/*
4			* This file is part of the jade/jade package.
5			*
6			* (c) Slince <[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 Jade\Provider;
13
14			use Doctrine\Common\Persistence\Mapping\Driver\MappingDriverChain;
15			use Doctrine\ORM\Configuration;
16			use Doctrine\ORM\EntityManager;
17			use Doctrine\ORM\Mapping\Driver\SimplifiedXmlDriver;
18			use Doctrine\ORM\Mapping\Driver\SimplifiedYamlDriver;
19			use Doctrine\ORM\Mapping\Driver\XmlDriver;
20			use Doctrine\ORM\Mapping\Driver\YamlDriver;
21			use Doctrine\ORM\Tools\Console\ConsoleRunner;
22			use Doctrine\ORM\Tools\ResolveTargetEntityListener;
23			use Jade\CommandProviderInterface;
24			use Jade\Console\Application;
25			use Jade\Container;
26			use Jade\ContainerInterface;
27			use Jade\ServiceProviderInterface;
28
29			/**
30			* Doctrine ORM Pimple Service Provider.
31			*
32			* @author Beau Simensen <[email protected]>
33			*/
34			class DoctrineOrmServiceProvider implements ServiceProviderInterface, CommandProviderInterface
35			{
36			public function provide(Application $app, ContainerInterface $container)
37			{
38			ConsoleRunner::addCommands($app);
39			$helperSet = $app->getHelperSet();
40			$doctrineHelperSet = ConsoleRunner::createHelperSet($container['orm']);
41			foreach ($doctrineHelperSet as $alias =>$helper) {
42			$helperSet->set($helper, $alias);
43			}
44			$app->setHelperSet($helperSet);
45			}
46
47			public function register(ContainerInterface $container)
48			{
49			if (!isset($container['dbs'])) {
50			throw new \LogicException(
51			'You must register the DoctrineServiceProvider to use the DoctrineOrmServiceProvider.'
52			);
53			}
54
55			if (!isset($container['caches'])) {
56			throw new \LogicException(
57			'You must register the DoctrineCacheServiceProvider to use the DoctrineOrmServiceProvider.'
58			);
59			}
60
61			// 初始值
62			$container->add($this->getOrmDefaults());
63
64			$container['ems.options.initializer'] = $container->protect(function () use ($container) {
65			static $initialized = false;
66
67			if ($initialized) {
68			return;
69			}
70
71			$initialized = true;
72
73			if (!isset($container['ems.options'])) {
74			$container['ems.options'] = [
75			'default' => $container['orm.options'] ?? [],
76			];
77			}
78
79			$container['ems.options'] = array_map(function ($options) use ($container) {
80			return array_replace($container['orm.default_options'], $options);
81			}, $container['ems.options']);
82
83			if (!isset($container['ems.default'])) {
84			$container['ems.default'] = array_keys(
85			array_slice($container['ems.options'], 0, 1)
86			)[0];
87			}
88			});
89
90			$container['ems'] = function (Container $container) {
91			$container['ems.options.initializer']();
92
93			$ems = new Container();
94			foreach ($container['ems.options'] as $name => $options) {
95			$config = $container['ems.default'] === $name
96			? $container['orm.config']
97			: $container['ems.config'][$name];
98
99			$connection = $container['dbs'][$options['connection']];
100			$manager = $container['dbs.event_manager'][$options['connection']];
101
102			if ($targetEntities = $options['resolve_target_entities'] ?? []) {
103			$manager->addEventSubscriber(
104			$container['orm.resolve_target_entity']($targetEntities)
105			);
106			}
107
108			$ems[$name] = function () use ($connection, $config, $manager) {
109			return EntityManager::create($connection, $config, $manager);
110			};
111			}
112
113			return $ems;
114			};
115
116			$container['ems.config'] = function (Container $container) {
117			$container['ems.options.initializer']();
118
119			$configs = new Container();
120			foreach ($container['ems.options'] as $name => $options) {
121			$config = new Configuration();
122			$config->setProxyDir($container['orm.proxy_dir']);
123			$config->setProxyNamespace($container['orm.proxy_namespace']);
124			$config->setAutoGenerateProxyClasses($container['orm.auto_generate_proxy_classes']);
125			$config->setCustomStringFunctions($container['orm.custom_functions_string']);
126			$config->setCustomNumericFunctions($container['orm.custom_functions_numeric']);
127			$config->setCustomDatetimeFunctions($container['orm.custom_functions_datetime']);
128			$config->setMetadataCacheImpl($container['orm.cache.factory']('metadata', $options));
129			$config->setQueryCacheImpl($container['orm.cache.factory']('query', $options));
130			$config->setResultCacheImpl($container['orm.cache.factory']('result', $options));
131			$config->setMetadataDriverImpl($container['orm.mapping.chain']($config, $options['mappings']));
132
133			$configs[$name] = $config;
134			}
135
136			return $configs;
137			};
138
139			$container['orm.cache.factory'] = $container->protect(function ($type, $options) use ($container) {
140			$type = $type . '_cache_driver';
141
142			$options[$type] = $options[$type] ?? 'array';
143
144			if (!is_array($options[$type])) {
145			$options[$type] = [
146			'driver' => $options[$type],
147			];
148			}
149
150			$driver = $options[$type]['driver'];
151			$namespace = $options[$type]['namespace'] ?? null;
152
153			$cache = $container['cache_factory']($driver, $options);
154			$cache->setNamespace($namespace);
155
156			return $cache;
157			});
158
159			$container['orm.mapping.chain'] = $container->protect(function (Configuration $config, array $mappings) {
160			$chain = new MappingDriverChain();
161
162			foreach ($mappings as $mapping) {
163			if (!is_array($mapping)) {
164			throw new \InvalidArgumentException();
165			}
166
167			$path = $mapping['path'];
168			$namespace = $mapping['namespace'];
169
170			switch ($mapping['type']) {
171			case 'annotation':
172			$annotationDriver = $config->newDefaultAnnotationDriver(
173			$path,
174			$mapping['use_simple_annotation_reader'] ?? true
175			);
176			$chain->addDriver($annotationDriver, $namespace);
177			break;
178			case 'yml':
179			$chain->addDriver(new YamlDriver($path), $namespace);
180			break;
181			case 'simple_yml':
182			$driver = new SimplifiedYamlDriver([$path => $namespace]);
183			$chain->addDriver($driver, $namespace);
184			break;
185			case 'xml':
186			$chain->addDriver(new XmlDriver($path), $namespace);
187			break;
188			case 'simple_xml':
189			$driver = new SimplifiedXmlDriver([$path => $namespace]);
190			$chain->addDriver($driver, $namespace);
191			break;
192			default:
193			throw new \InvalidArgumentException();
194			break;
			0 ignored issues – show Unused Code introduced 2019-08-10 04:44 UTC by Report Bug Copy Issue Report `break;` does not seem to be reachable. This check looks for unreachable code. It uses sophisticated control flow analysis techniques to find statements which will never be executed. Unreachable code is most often the result of `return`, `die` or `exit` statements that have been added for debug purposes. function fx() { try { doSomething(); return true; } catch (\Exception $e) { return false; } return false; } In the above example, the last `return false` will never be executed, because a return statement has already been met in every possible execution path. Loading history...
195			}
196			}
197
198			return $chain;
199			});
200
201			$container['orm.resolve_target_entity'] = $container->protect(function (array $targetEntities) {
202			$rtel = new ResolveTargetEntityListener();
203
204			foreach ($targetEntities as $originalEntity => $newEntity) {
205			$rtel->addResolveTargetEntity($originalEntity, $newEntity, []);
206			}
207
208			return $rtel;
209			});
210
211			// shortcuts for the "first" ORM
212			$container['orm'] = function (Container $container) {
213			$ems = $container['ems'];
214
215			return $ems[$container['ems.default']];
216			};
217
218			$container['orm.config'] = function (Container $container) {
219			$ems = $container['ems.config'];
220
221			return $ems[$container['ems.default']];
222			};
223			}
224
225			protected function getOrmDefaults()
226			{
227			return [
228			'orm.proxy_dir' => null,
229			'orm.proxy_namespace' => 'Proxy',
230			'orm.auto_generate_proxy_classes' => true,
231			'orm.custom_functions_string' => [],
232			'orm.custom_functions_numeric' => [],
233			'orm.custom_functions_datetime' => [],
234			'orm.default_options' => [
235			'connection' => 'default',
236			'mappings' => [],
237			]
238			];
239			}
240			}

jadephp / jade

DoctrineOrmServiceProvider::register() F last analyzed 2019-09-24 05:32 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like

DoctrineOrmServiceProvider::register() F
last analyzed 2019-09-24 05:32 UTC