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

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.     /**
  34.      * Initializes a new ListenersInvoker instance.
  35.      */
  36.     public function __construct(EntityManagerInterface $em)
  37.     {
  38.         $this->eventManager = $em->getEventManager();
  39.         $this->resolver     = $em->getConfiguration()->getEntityListenerResolver();
  40.     }
  42.     /**
  43.      * Get the subscribed event systems
  44.      *
  45.      * @param ClassMetadata $metadata  The entity metadata.
  46.      * @param string        $eventName The entity lifecycle event.
  47.      *
  48.      * @return int Bitmask of subscribed event systems.
  49.      */
  50.     public function getSubscribedSystems(ClassMetadata $metadata, $eventName)
  51.     {
  52.         $invoke = self::INVOKE_NONE;
  54.         if (isset($metadata->lifecycleCallbacks[$eventName])) {
  55.             $invoke |= self::INVOKE_CALLBACKS;
  56.         }
  58.         if (isset($metadata->entityListeners[$eventName])) {
  59.             $invoke |= self::INVOKE_LISTENERS;
  60.         }
  62.         if ($this->eventManager->hasListeners($eventName)) {
  63.             $invoke |= self::INVOKE_MANAGER;
  64.         }
  66.         return $invoke;
  67.     }
  69.     /**
  70.      * Dispatches the lifecycle event of the given entity.
  71.      *
  72.      * @param ClassMetadata $metadata  The entity metadata.
  73.      * @param string        $eventName The entity lifecycle event.
  74.      * @param object        $entity    The Entity on which the event occurred.
  75.      * @param EventArgs     $event     The Event args.
  76.      * @param int           $invoke    Bitmask to invoke listeners.
  77.      *
  78.      * @return void
  79.      */
  80.     public function invoke(ClassMetadata $metadata, $eventName, $entity, EventArgs $event, $invoke)
  81.     {
  82.         if ($invoke & self::INVOKE_CALLBACKS) {
  83.             foreach ($metadata->lifecycleCallbacks[$eventName] as $callback) {
  84.                 $entity->$callback($event);
  85.             }
  86.         }
  88.         if ($invoke & self::INVOKE_LISTENERS) {
  89.             foreach ($metadata->entityListeners[$eventName] as $listener) {
  90.                 $class    = $listener['class'];
  91.                 $method   = $listener['method'];
  92.                 $instance = $this->resolver->resolve($class);
  94.                 $instance->$method($entity, $event);
  95.             }
  96.         }
  98.         if ($invoke & self::INVOKE_MANAGER) {
  99.             $this->eventManager->dispatchEvent($eventName, $event);
  100.         }
  101.     }
  102. }