vendor/doctrine/orm/lib/Doctrine/ORM/Event/ListenersInvoker.php line 79

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Doctrine\ORM\Event;
  7. use Doctrine\Common\EventArgs;
  8. use Doctrine\Common\EventManager;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Doctrine\ORM\Mapping\ClassMetadata;
  11. use Doctrine\ORM\Mapping\EntityListenerResolver;
  13. /**
  14.  * A method invoker based on entity lifecycle.
  15.  */
  16. class ListenersInvoker
  17. {
  18.     public const INVOKE_NONE      = 0;
  19.     public const INVOKE_LISTENERS = 1;
  20.     public const INVOKE_CALLBACKS = 2;
  21.     public const INVOKE_MANAGER   = 4;
  23.     /** @var EntityListenerResolver The Entity listener resolver. */
  24.     private $resolver;
  26.     /**
  27.      * The EventManager used for dispatching events.
  28.      *
  29.      * @var EventManager
  30.      */
  31.     private $eventManager;
  33.     public function __construct(EntityManagerInterface $em)
  34.     {
  35.         $this->eventManager = $em->getEventManager();
  36.         $this->resolver     = $em->getConfiguration()->getEntityListenerResolver();
  37.     }
  39.     /**
  40.      * Get the subscribed event systems
  41.      *
  42.      * @param ClassMetadata $metadata  The entity metadata.
  43.      * @param string        $eventName The entity lifecycle event.
  44.      *
  45.      * @return int Bitmask of subscribed event systems.
  46.      * @psalm-return int-mask-of<self::INVOKE_*>
  47.      */
  48.     public function getSubscribedSystems(ClassMetadata $metadata, $eventName)
  49.     {
  50.         $invoke = self::INVOKE_NONE;
  52.         if (isset($metadata->lifecycleCallbacks[$eventName])) {
  53.             $invoke |= self::INVOKE_CALLBACKS;
  54.         }
  56.         if (isset($metadata->entityListeners[$eventName])) {
  57.             $invoke |= self::INVOKE_LISTENERS;
  58.         }
  60.         if ($this->eventManager->hasListeners($eventName)) {
  61.             $invoke |= self::INVOKE_MANAGER;
  62.         }
  64.         return $invoke;
  65.     }
  67.     /**
  68.      * Dispatches the lifecycle event of the given entity.
  69.      *
  70.      * @param ClassMetadata $metadata  The entity metadata.
  71.      * @param string        $eventName The entity lifecycle event.
  72.      * @param object        $entity    The Entity on which the event occurred.
  73.      * @param EventArgs     $event     The Event args.
  74.      * @param int           $invoke    Bitmask to invoke listeners.
  75.      * @psalm-param int-mask-of<self::INVOKE_*> $invoke
  76.      *
  77.      * @return void
  78.      */
  79.     public function invoke(ClassMetadata $metadata, $eventName, $entity, EventArgs $event, $invoke)
  80.     {
  81.         if ($invoke & self::INVOKE_CALLBACKS) {
  82.             foreach ($metadata->lifecycleCallbacks[$eventName] as $callback) {
  83.                 $entity->$callback($event);
  84.             }
  85.         }
  87.         if ($invoke & self::INVOKE_LISTENERS) {
  88.             foreach ($metadata->entityListeners[$eventName] as $listener) {
  89.                 $class    = $listener['class'];
  90.                 $method   = $listener['method'];
  91.                 $instance = $this->resolver->resolve($class);
  93.                 $instance->$method($entity, $event);
  94.             }
  95.         }
  97.         if ($invoke & self::INVOKE_MANAGER) {
  98.             $this->eventManager->dispatchEvent($eventName, $event);
  99.         }
  100.     }
  101. }