Silverback\ApiComponentBundle\EventListener\Doctrine\RouteAwareListener

Complexity

Total Complexity

12

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	preFlush()	0	16	4
A	getSubscribedEvents()	0	6	1
A	__construct()	0	4	1
A	prePersist()	0	6	2
A	createPageRoute()	0	6	2
A	preUpdate()	0	6	2

<?php

namespace Silverback\ApiComponentBundle\EventListener\Doctrine;

use Doctrine\ORM\Event\LifecycleEventArgs;
use Doctrine\ORM\Event\PreFlushEventArgs;
use Doctrine\ORM\Event\PreUpdateEventArgs;
use Silverback\ApiComponentBundle\Entity\Route\Route;
use Silverback\ApiComponentBundle\Entity\Route\RouteAwareInterface;
use Silverback\ApiComponentBundle\Factory\Entity\Route\RouteFactory;

class RouteAwareListener
{
    /**
     * @var RouteFactory
     */
    private $routeFactory;

    public function __construct(
        RouteFactory $routeFactory
    ) {
        $this->routeFactory = $routeFactory;
    }

    /**
     * @return array
     */
    public function getSubscribedEvents(): array
    {
        return [
            'prePersist',
            'preUpdate',
            'preFlush'
        ];
    }

    /**
     * @param LifecycleEventArgs $eventArgs
     * @throws \Doctrine\ORM\ORMException
     */
    public function prePersist(LifecycleEventArgs $eventArgs): void
    {
        $entity = $eventArgs->getEntity();
        if ($entity instanceof RouteAwareInterface) {
            $route = $this->createPageRoute($entity);
            $eventArgs->getEntityManager()->persist($route);
        }
    }

    /**
     * @param PreUpdateEventArgs $eventArgs
     * @throws \Doctrine\ORM\ORMException
     */
    public function preUpdate(PreUpdateEventArgs $eventArgs): void
    {
        $entity = $eventArgs->getEntity();
        if ($entity instanceof RouteAwareInterface) {
            $route = $this->createPageRoute($entity);
            $eventArgs->getEntityManager()->persist($route);
        }
    }

    /**
     * @param PreFlushEventArgs $eventArgs
     * @throws \Doctrine\ORM\ORMException
     * @throws \Doctrine\ORM\OptimisticLockException
     */
    public function preFlush(PreFlushEventArgs $eventArgs): void
    {
        $em = $eventArgs->getEntityManager();
        $uow = $em->getUnitOfWork();
        foreach ($uow->getScheduledEntityUpdates() as $entity) {
            if (
                $entity instanceof RouteAwareInterface &&
                $route = $this->createPageRoute($entity)
            ) {
                $pageClassMetaData = $em->getClassMetadata(\get_class($entity));
                $uow = $em->getUnitOfWork();
                $uow->recomputeSingleEntityChangeSet($pageClassMetaData, $entity);
                $em->persist($route);
            }
        }
        $em->flush();
    }

    /**
     * @param RouteAwareInterface $entity
     * @return null|Route
     */
    private function createPageRoute(RouteAwareInterface $entity): ?Route
    {
        if (0 === $entity->getRoutes()->count()) {
            return $this->routeFactory->createFromRouteAwareEntity($entity);
        }
        return null;
    }
}