vendor/doctrine/orm/src/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. * @phpstan-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. * @phpstan-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. }