Sauls\Bundle\ObjectRegistryBundle\EvenListener\DoctrineEventsSubscriber

Complexity

Total Complexity

9

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	7	1
A	onPreUpdate()	0	3	1
A	getSubscribedEvents()	0	9	1
A	onPrePersist()	0	3	1
A	onPreRemove()	0	3	1
A	onPostUpdate()	0	3	1
A	__construct()	0	4	1
A	onPostRemove()	0	3	1
A	onPostPersist()	0	3	1

<?php
/**
 * This file is part of the sauls/object-registry-bundle package.
 *
 * @author    Saulius Vaičeliūnas <vaiceliunas@inbox.lt>
 * @link      http://saulius.vaiceliunas.lt
 * @copyright 2018
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sauls\Bundle\ObjectRegistryBundle\EvenListener;

use Doctrine\ORM\Event\LifecycleEventArgs;
use Doctrine\ORM\Event\PreUpdateEventArgs;
use Doctrine\ORM\Events;
use Sauls\Bundle\ObjectRegistryBundle\Event\DoctrineObjectEvents;
use Sauls\Bundle\ObjectRegistryBundle\Event\GenericDoctrineObjectEvent;
use Sauls\Bundle\ObjectRegistryBundle\EventDispatcher\EventDispatcherInterface;
use Sauls\Bundle\ObjectRegistryBundle\Factory\EventNameFactoryInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class DoctrineEventsSubscriber implements EventSubscriberInterface
{
    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;
    /**
     * @var EventNameFactoryInterface
     */
    private $eventNameFactory;

    public function __construct(EventDispatcherInterface $eventDispatcher, EventNameFactoryInterface $eventNameFactory)
    {
        $this->eventDispatcher = $eventDispatcher;
        $this->eventNameFactory = $eventNameFactory;
    }

    /**
     * {@inheritdoc}
     */
    public static function getSubscribedEvents(): array
    {
        return [
            Events::prePersist => ['onPrePersist'],
            Events::postPersist => ['onPostPersist'],
            Events::preUpdate => ['onPreUpdate'],
            Events::postUpdate => ['onPostUpdate'],
            Events::preRemove => ['onPreRemove'],
            Events::postRemove => ['onPostRemove'],
        ];
    }

    public function onPrePersist(LifecycleEventArgs $event): void
    {
        $this->process(DoctrineObjectEvents::PRE_PERSIST, $event);
    }

    /**
     * @param string $eventName
     * @param LifecycleEventArgs|PreUpdateEventArgs $event
     */
    private function process(string $eventName, LifecycleEventArgs $event): void
    {
        $entity = $event->getEntity();
        $eventName = $this->eventNameFactory->create($eventName, $entity);
        $newEvent = new GenericDoctrineObjectEvent($entity, $event);

        $this->eventDispatcher->dispatch($eventName, $newEvent);
    }

    public function onPostPersist(LifecycleEventArgs $event): void
    {
        $this->process(DoctrineObjectEvents::POST_PERSIST, $event);
    }

    public function onPreUpdate(PreUpdateEventArgs $event): void
    {
        $this->process(DoctrineObjectEvents::PRE_UPDATE, $event);
    }

    public function onPostUpdate(LifecycleEventArgs $event): void
    {
        $this->process(DoctrineObjectEvents::POST_UPDATE, $event);
    }

    public function onPreRemove(LifecycleEventArgs $event): void
    {
        $this->process(DoctrineObjectEvents::PRE_REMOVE, $event);
    }

    public function onPostRemove(LifecycleEventArgs $event): void
    {
        $this->process(DoctrineObjectEvents::POST_REMOVE, $event);
    }
}