FOS\ElasticaBundle\Persister\InPlacePagerPersister::insert()

Complexity

Conditions	6
Paths	59

Size

Total Lines	57
Code Lines	36

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	35
CRAP Score	6.0007

Importance

Changes

0

<?php
    public function insert(PagerInterface $pager, array $options = array())
    {
        $objectPersister = $this->registry->getPersister($options['indexName'], $options['typeName']);

        $event = new PrePersistEvent($pager, $objectPersister, $options);
        $this->dispatcher->dispatch(Events::PRE_PERSIST, $event);
        $pager = $event->getPager();
        $options = $event->getOptions();

        $pager->setMaxPerPage($options['batch_size']);

        $page = $pager->getCurrentPage();
        while ($page <= $pager->getNbPages()) {
            try {
                $pager->setCurrentPage($page);

                $event = new PreFetchObjectsEvent($pager, $objectPersister, $options);
                $this->dispatcher->dispatch(Events::PRE_FETCH_OBJECTS, $event);
                $pager = $event->getPager();
                $options = $event->getOptions();

                $objects = $pager->getCurrentPageResults();

                if ($objects instanceof \Traversable) {
                    $objects = iterator_to_array($objects);
                }

                $event = new PreInsertObjectsEvent($pager, $objectPersister, $objects, $options);
                $this->dispatcher->dispatch(Events::PRE_INSERT_OBJECTS, $event);
                $pager = $event->getPager();
                $options = $event->getOptions();
                $objects = $event->getObjects();

                if (!empty($objects)) {
                    $objectPersister->insertMany($objects);
                }

                $event = new PostInsertObjectsEvent($pager, $objectPersister, $objects, $options);
                $this->dispatcher->dispatch(Events::POST_INSERT_OBJECTS, $event);
            } catch (\Exception $e) {
                $event = new OnExceptionEvent($pager, $objectPersister, $e, $options);
                $this->dispatcher->dispatch(Events::ON_EXCEPTION, $event);

                if (false == $event->isIgnored()) {

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

                    $e = $event->getException();

                    throw $e;
                }
            }

            $pager->setCurrentPage($page++);
        }

        $event = new PostPersistEvent($pager, $objectPersister, $options);
        $this->dispatcher->dispatch(Events::POST_PERSIST, $event);

    }
}