Chubbyphp\ServiceProvider\DoctrineDbalServiceProvider

Complexity

Total Complexity

21

Size/Duplication

Total Lines	188
Duplicated Lines	36.17 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	register()	0	11	1
A	getDbDefaultOptions()	0	10	1
B	getDbsOptionsInitializerServiceDefinition()	29	29	6
B	getDbsServiceDefinition()	0	24	3
B	getDbsConfigServiceDefinition()	0	26	5
A	getDbsEventManagerServiceDefinition()	15	15	2
A	getDbServiceDefinition()	8	8	1
A	getDbConfigServiceDefinition()	8	8	1
A	getDbEventManagerServiceDefinition()	8	8	1

<?php

declare(strict_types=1);

/*
 * (c) Fabien Potencier <fabien@symfony.com> (https://github.com/silexphp/Silex-Providers)
 */

namespace Chubbyphp\ServiceProvider;

use Pimple\Container;
use Pimple\ServiceProviderInterface;
use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Configuration;
use Doctrine\Common\EventManager;
use Symfony\Bridge\Doctrine\Logger\DbalLogger;

final class DoctrineDbalServiceProvider implements ServiceProviderInterface
{
    /**
     * @param Container $container
     */
    public function register(Container $container)
    {
        $container['db.default_options'] = $this->getDbDefaultOptions();
        $container['dbs.options.initializer'] = $this->getDbsOptionsInitializerServiceDefinition($container);
        $container['dbs'] = $this->getDbsServiceDefinition($container);
        $container['dbs.config'] = $this->getDbsConfigServiceDefinition($container);
        $container['dbs.event_manager'] = $this->getDbsEventManagerServiceDefinition($container);
        $container['db'] = $this->getDbServiceDefinition($container);
        $container['db.config'] = $this->getDbConfigServiceDefinition($container);
        $container['db.event_manager'] = $this->getDbEventManagerServiceDefinition($container);
    }

    /**
     * @return array
     */
    private function getDbDefaultOptions(): array
    {
        return [
            'driver' => 'pdo_mysql',
            'dbname' => null,
            'host' => 'localhost',
            'user' => 'root',
            'password' => null,
        ];
    }

    /**
     * @param Container $container
     *
     * @return \Closure
     */
    private function getDbsOptionsInitializerServiceDefinition(Container $container): \Closure

This method seems to be duplicated in your project.

    {
        return $container->protect(function () use ($container) {
            static $initialized = false;

            if ($initialized) {
                return;
            }

            $initialized = true;

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

            $tmp = $container['dbs.options'];
            foreach ($tmp as $name => &$options) {
                $options = array_replace($container['db.default_options'], $options);

                if (!isset($container['dbs.default'])) {
                    $container['dbs.default'] = $name;
                }
            }

            $container['dbs.options'] = $tmp;
        });
    }

    /**
     * @param Container $container
     *
     * @return \Closure
     */
    private function getDbsServiceDefinition(Container $container): \Closure
    {
        return function () use ($container) {
            $container['dbs.options.initializer']();

            $dbs = new Container();
            foreach ($container['dbs.options'] as $name => $options) {
                if ($container['dbs.default'] === $name) {
                    // we use shortcuts here in case the default has been overridden
                    $config = $container['db.config'];
                    $manager = $container['db.event_manager'];
                } else {
                    $config = $container['dbs.config'][$name];
                    $manager = $container['dbs.event_manager'][$name];
                }

                $dbs[$name] = function () use ($options, $config, $manager) {
                    return DriverManager::getConnection($options, $config, $manager);
                };
            }

            return $dbs;
        };
    }

    /**
     * @param Container $container
     *
     * @return \Closure
     */
    private function getDbsConfigServiceDefinition(Container $container): \Closure
    {
        return function () use ($container) {
            $container['dbs.options.initializer']();

            $addLogger = isset($container['logger']) && null !== $container['logger']
                && class_exists('Symfony\Bridge\Doctrine\Logger\DbalLogger');
            $stopwatch = $container['stopwatch'] ?? null;

            $configs = new Container();
            foreach ($container['dbs.options'] as $name => $options) {
                $configs[$name] = function () use ($addLogger, $container, $stopwatch) {
                    $config = new Configuration();
                    if ($addLogger) {
                        $config->setSQLLogger(
                            new DbalLogger($container['logger'], $stopwatch)
                        );
                    }

                    return $config;
                };
            }

            return $configs;
        };
    }

    /**
     * @param Container $container
     *
     * @return \Closure
     */
    private function getDbsEventManagerServiceDefinition(Container $container): \Closure

This method seems to be duplicated in your project.

    {
        return function () use ($container) {
            $container['dbs.options.initializer']();

            $managers = new Container();
            foreach ($container['dbs.options'] as $name => $options) {
                $managers[$name] = function () {
                    return new EventManager();
                };
            }

            return $managers;
        };
    }

    /***
     * @param Container $container
     * @return \Closure
     */
    private function getDbServiceDefinition(Container $container): \Closure

This method seems to be duplicated in your project.

    {
        return function () use ($container) {
            $dbs = $container['dbs'];

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

    /***
     * @param Container $container
     * @return \Closure
     */
    private function getDbConfigServiceDefinition(Container $container): \Closure

This method seems to be duplicated in your project.

    {
        return function () use ($container) {
            $dbs = $container['dbs.config'];

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

    /***
     * @param Container $container
     * @return \Closure
     */
    private function getDbEventManagerServiceDefinition(Container $container): \Closure

This method seems to be duplicated in your project.

    {
        return function () use ($container) {
            $dbs = $container['dbs.event_manager'];

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