AppBundle\EventListener\FlushSubscriber

Complexity

Total Complexity

5

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	4	1
A	preFlush()	0	21	4

<?php

namespace AppBundle\EventListener;

use Doctrine\Common\EventSubscriber;
use Doctrine\ORM\Events;
use Doctrine\ORM\Event\PreFlushEventArgs;

class FlushSubscriber implements EventSubscriber
{
    public $flushed;
    public $inRequest = false;

    public function preFlush(PreFlushEventArgs $args)
    {
        if (!$this->inRequest) {
            // let console commands handle flushes anyway they want
            return;
        }

        $em = $args->getEntityManager();
        if ($em->getConnection()->isTransactionActive()) {
            // the transaction is managed manually and was already started
            // probably it won't be handled since it is the end of response
            // but anyways, it won't cause trouble
            return;
        }

        if ($this->flushed) {
            throw new \BadMethodCallException("The flush can be run only once and is run automatically in the end of each request to prevent data inconsistencies and bad design.");
        }

        $this->flushed = true;
    }

    public function getSubscribedEvents()
    {
        return [Events::preFlush];
    }
}