vendor/cnge/common-bundle/NotifiableDiscovery.php line 38

Open in your IDE?
  1. <?php
  3. namespace Cnge\CommonBundle;
  5. use Doctrine\Common\Annotations\Reader;
  6. use Doctrine\Common\Util\ClassUtils;
  7. use Doctrine\ORM\EntityManager;
  8. use Metadata\ClassMetadata;
  10. class NotifiableDiscovery {
  11.     
  12.     /**
  13.      * @var Reader
  14.      */
  15.     private $annotationReader;
  17.     /**
  18.      * @var EntityManager
  19.      */
  20.     private $em;
  22.     /**
  23.      * @var array
  24.      */
  25.     private $notifiables = [];
  27.     /**
  28.      * WorkerDiscovery constructor.
  29.      *
  30.      * @param EntityManager $em
  31.      * @param Reader        $annotationReader
  32.      *
  33.      * @throws \InvalidArgumentException
  34.      */
  35.     public function __construct(EntityManager $em, Reader $annotationReader) {
  36.         $this->annotationReader = $annotationReader;
  37.         $this->em = $em;
  38.         $this->discoverNotifiables();
  39.     }
  41.     /**
  42.      * Returns all the workers
  43.      * @throws \InvalidArgumentException
  44.      */
  45.     public function getNotifiables() {
  46.         return $this->notifiables;
  47.     }
  49.     /**
  50.      * @param NotifiableInterface $notifiable
  51.      *
  52.      * @return string|null
  53.      */
  54.     public function getNotifiableName(NotifiableInterface $notifiable) {
  55.         // fixes the case when the notifiable is a proxy
  56.         $class = ClassUtils::getRealClass(get_class($notifiable));
  57.         $annotation = $this->annotationReader->getClassAnnotation(new \ReflectionClass($class), 'Cnge\CommonBundle\Annotation\Notifiable');
  58.         if ($annotation) {
  59.             return $annotation->getName();
  60.         }
  62.         return null;
  63.     }
  65.     /**
  66.      * Discovers workers
  67.      * @throws \InvalidArgumentException
  68.      */
  69.     private function discoverNotifiables() {
  70.         /** @var ClassMetadata[] $entities */
  71.         $entities = $this->em->getMetadataFactory()->getAllMetadata();
  72.         foreach ($entities as $entity) {
  73.             $class = $entity->name;
  74.             $annotation = $this->annotationReader->getClassAnnotation(new \ReflectionClass($class), 'Cnge\CommonBundle\Annotation\Notifiable');
  75.             if ($annotation) {
  76.                 $this->notifiables[$annotation->getName()] = [
  77.                     'class' => $entity->name,
  78.                     'annotation' => $annotation,
  79.                     'identifiers' => $entity->getIdentifier()
  80.                 ];
  81.             }
  82.         }
  83.     }
  85. }