GpsLab\Bundle\DomainEvent\Event\Listener\DomainEventPublisher::postFlush()

Complexity

Conditions	8
Paths	7

Size

Total Lines	30
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	15
CRAP Score	8

Importance

Changes

0

<?php
    public function postFlush(PostFlushEventArgs $args)
    {
        $em = $args->getEntityManager();

        if ($em->isOpen()) {
            $map = $em->getUnitOfWork()->getIdentityMap();
            $has_events = false;

            foreach ($map as $entities) {
                foreach ($entities as $entity) {
                    // ignore Doctrine proxy classes
                    // proxy class can't have a domain events
                    if ($entity instanceof Proxy || !($entity instanceof AggregateEvents)) {
                        break;
                    }

                    foreach ($entity->pullEvents() as $event) {
                        $this->bus->publish($event);
                        $has_events = true;
                    }
                }
            }

            // flush only if has domain events
            // it necessary for fix recursive handle flush
            if ($has_events) {
                $em->flush();
            }
        }
    }
}