FOS\ElasticaBundle\Doctrine\RegisterListenersService::register()

Complexity

Conditions	7
Paths	16

Size

Total Lines	46
Code Lines	26

Duplication

Lines	24
Ratio	52.17 %

Code Coverage

Tests	21
CRAP Score	8.645

Importance

Changes

0

<?php
    public function register(ObjectManager $manager, PagerInterface $pager, array $options)
    {
        $options = array_replace([
            'clear_object_manager' => true,
            'debug_logging'        => false,
            'sleep'                => 0,
        ], $options);

        if ($options['clear_object_manager']) {
            $this->addListener($pager, Events::POST_INSERT_OBJECTS, function() use ($manager) {
                $manager->clear();
            });
        }

        if ($options['sleep']) {
            $this->addListener($pager, Events::POST_INSERT_OBJECTS, function() use ($options) {
                usleep($options['sleep']);
            });
        }

        if (false == $options['debug_logging'] && $manager instanceof EntityManagerInterface) {

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

            $configuration = $manager->getConnection()->getConfiguration();
            $logger = $configuration->getSQLLogger();
            
            $this->addListener($pager, Events::PRE_FETCH_OBJECTS, function() use ($configuration) {
                $configuration->setSQLLogger(null);
            });

            $this->addListener($pager, Events::PRE_INSERT_OBJECTS, function() use ($configuration, $logger) {
                $configuration->setSQLLogger($logger);
            });
        }

        if (false == $options['debug_logging'] && $manager instanceof DocumentManager) {

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

The class Doctrine\ODM\MongoDB\DocumentManager does not exist. Did you forget a USE statement, or did you not list all dependencies?

            $configuration = $manager->getConnection()->getConfiguration();
            $logger = $configuration->getLoggerCallable();

            $this->addListener($pager, Events::PRE_FETCH_OBJECTS, function() use ($configuration) {
                $configuration->setLoggerCallable(null);
            });

            $this->addListener($pager, Events::PRE_INSERT_OBJECTS, function() use ($configuration, $logger) {
                $configuration->setLoggerCallable($logger);
            });
        }
    }