Actiane\EntityChangeWatchBundle\Listener\EntityModificationListener

Complexity

Total Complexity

6

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	onFlush()	0	15	3
A	postFlush()	0	7	2

<?php declare(strict_types = 1);

namespace Actiane\EntityChangeWatchBundle\Listener;

use Actiane\EntityChangeWatchBundle\Generator\LifecycleCallableGenerator;
use Doctrine\ORM\Event\OnFlushEventArgs;
use Doctrine\ORM\Event\PostFlushEventArgs;

/**
 * Class EntityModificationListener
 */
class EntityModificationListener
{
    private array $callable = [];
    private LifecycleCallableGenerator $lifecycleCallableGenerator;

    /**
     * @param LifecycleCallableGenerator $lifecycleCallableGenerator
     */
    public function __construct(LifecycleCallableGenerator $lifecycleCallableGenerator)
    {
        $this->lifecycleCallableGenerator = $lifecycleCallableGenerator;
    }

    /**
     * Called before the database queries, execute all the Generate $this->callable
     *
     * @param OnFlushEventArgs $eventArgs
     */
    public function onFlush(OnFlushEventArgs $eventArgs): void
    {
        $entityManager = $eventArgs->getEntityManager();
        $this->callable = $this->lifecycleCallableGenerator->generateLifeCycleCallable(
            $entityManager->getUnitOfWork()
        );

        foreach ($this->callable as $key => $callableItem) {
            if ($callableItem['flush'] !== false) {
                continue;
            }
            unset($this->callable[$key]);
            call_user_func_array(
                $callableItem['callable'],
                $callableItem['parameters'] + ['entityManager' => $entityManager]
            );
        }
    }

    /**
     * Called before the database queries, execute all the Generate $this->callableFlush
     *
     * @param PostFlushEventArgs $eventArgs
     */
    public function postFlush(PostFlushEventArgs $eventArgs): void
    {
        foreach ($this->callable as $key => $callableItem) {
            unset($this->callable[$key]);
            call_user_func_array(
                $callableItem['callable'],
                $callableItem['parameters'] + ['entityManager' => $eventArgs->getEntityManager()]
            );
        }
    }
}