Padam87\AttributeBundle\EventListener\AttributeCreatorListener

Complexity

Total Complexity

9

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	4
Bugs	1	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	postLoad()	0	47	6
A	getEntities()	0	8	2

<?php

namespace Padam87\AttributeBundle\EventListener;

use Doctrine\Common\Annotations\AnnotationReader;
use Doctrine\DBAL\DBALException;
use Doctrine\ORM\Event\LifecycleEventArgs;
use Doctrine\ORM\UnitOfWork;
use Padam87\AttributeBundle\Entity\Attribute;
use Padam87\AttributeBundle\Entity\Schema;

class AttributeCreatorListener
{
    private $entities = null;

    private $cacheDir;

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

    public function postLoad(LifecycleEventArgs $eventArgs)
    {
        $em = $eventArgs->getEntityManager();
        $uow = $em->getUnitOfWork();
        $entity = $eventArgs->getEntity();
        $classname = get_class($entity);

        if (!array_key_exists($classname, $this->getEntities())) {
            return null;
        }

        /** @var Schema $schema */
        $schema = $em->getRepository('Padam87AttributeBundle:Schema')->findOneBy([
            'className' => $classname,
        ]);

        if ($schema === null) {
            throw new \UnexpectedValueException('Schema not found for ' . $classname);
        }

        $qb = $em->getRepository($classname)->createQueryBuilder('main');

        $qb
            ->distinct()
            ->select('d.id')
            ->join('main.attributes', 'a')
            ->join('a.definition', 'd', null, null, 'd.id')
            ->where('main = :main')
            ->setParameter('main', $entity)
        ;

        $definitions = $qb->getQuery()->getArrayResult();

        foreach ($schema->getDefinitions() as $definition) {
            if (!array_key_exists($definition->getId(), $definitions)) {
                $attribute = new Attribute();
                $attribute->setDefinition($definition);

                $entity->addAttribute($attribute);
            }
        }

        if ($uow->getEntityState($entity) == UnitOfWork::STATE_MANAGED) {
            $em->persist($entity);
            $em->flush($entity);
        }
    }

    /**
     * @return array
     */
    protected function getEntities()
    {
        if ($this->entities === null) {
            $this->entities = include $this->cacheDir . '/padam87/attribute_bundle/Entity.cache.php';
        }

        return $this->entities;
    }
}