vendor/symfony/event-dispatcher/Debug/TraceableEventDispatcher.php line 276

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\EventDispatcher\Debug;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\EventDispatcher\Event;
  16. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Stopwatch\Stopwatch;
  20. /**
  21.  * Collects some data about event listeners.
  22.  *
  23.  * This event dispatcher delegates the dispatching to another one.
  24.  *
  25.  * @author Fabien Potencier <fabien@symfony.com>
  26.  */
  27. class TraceableEventDispatcher implements TraceableEventDispatcherInterface
  28. {
  29.     protected $logger;
  30.     protected $stopwatch;
  32.     private $callStack;
  33.     private $dispatcher;
  34.     private $wrappedListeners;
  35.     private $orphanedEvents;
  37.     public function __construct(EventDispatcherInterface $dispatcher, Stopwatch $stopwatch, LoggerInterface $logger = null)
  38.     {
  39.         $this->dispatcher = $dispatcher;
  40.         $this->stopwatch = $stopwatch;
  41.         $this->logger = $logger;
  42.         $this->wrappedListeners = [];
  43.         $this->orphanedEvents = [];
  44.     }
  46.     /**
  47.      * {@inheritdoc}
  48.      */
  49.     public function addListener($eventName, $listener, $priority = 0)
  50.     {
  51.         $this->dispatcher->addListener($eventName, $listener, $priority);
  52.     }
  54.     /**
  55.      * {@inheritdoc}
  56.      */
  57.     public function addSubscriber(EventSubscriberInterface $subscriber)
  58.     {
  59.         $this->dispatcher->addSubscriber($subscriber);
  60.     }
  62.     /**
  63.      * {@inheritdoc}
  64.      */
  65.     public function removeListener($eventName, $listener)
  66.     {
  67.         if (isset($this->wrappedListeners[$eventName])) {
  68.             foreach ($this->wrappedListeners[$eventName] as $index => $wrappedListener) {
  69.                 if ($wrappedListener->getWrappedListener() === $listener) {
  70.                     $listener = $wrappedListener;
  71.                     unset($this->wrappedListeners[$eventName][$index]);
  72.                     break;
  73.                 }
  74.             }
  75.         }
  77.         return $this->dispatcher->removeListener($eventName, $listener);
  78.     }
  80.     /**
  81.      * {@inheritdoc}
  82.      */
  83.     public function removeSubscriber(EventSubscriberInterface $subscriber)
  84.     {
  85.         return $this->dispatcher->removeSubscriber($subscriber);
  86.     }
  88.     /**
  89.      * {@inheritdoc}
  90.      */
  91.     public function getListeners($eventName = null)
  92.     {
  93.         return $this->dispatcher->getListeners($eventName);
  94.     }
  96.     /**
  97.      * {@inheritdoc}
  98.      */
  99.     public function getListenerPriority($eventName, $listener)
  100.     {
  101.         // we might have wrapped listeners for the event (if called while dispatching)
  102.         // in that case get the priority by wrapper
  103.         if (isset($this->wrappedListeners[$eventName])) {
  104.             foreach ($this->wrappedListeners[$eventName] as $index => $wrappedListener) {
  105.                 if ($wrappedListener->getWrappedListener() === $listener) {
  106.                     return $this->dispatcher->getListenerPriority($eventName, $wrappedListener);
  107.                 }
  108.             }
  109.         }
  111.         return $this->dispatcher->getListenerPriority($eventName, $listener);
  112.     }
  114.     /**
  115.      * {@inheritdoc}
  116.      */
  117.     public function hasListeners($eventName = null)
  118.     {
  119.         return $this->dispatcher->hasListeners($eventName);
  120.     }
  122.     /**
  123.      * {@inheritdoc}
  124.      */
  125.     public function dispatch($eventName, Event $event = null)
  126.     {
  127.         if (null === $this->callStack) {
  128.             $this->callStack = new \SplObjectStorage();
  129.         }
  131.         if (null === $event) {
  132.             $event = new Event();
  133.         }
  135.         if (null !== $this->logger && $event->isPropagationStopped()) {
  136.             $this->logger->debug(sprintf('The "%s" event is already stopped. No listeners have been called.', $eventName));
  137.         }
  139.         $this->preProcess($eventName);
  140.         try {
  141.             $this->preDispatch($eventName, $event);
  142.             try {
  143.                 $e = $this->stopwatch->start($eventName, 'section');
  144.                 try {
  145.                     $this->dispatcher->dispatch($eventName, $event);
  146.                 } finally {
  147.                     if ($e->isStarted()) {
  148.                         $e->stop();
  149.                     }
  150.                 }
  151.             } finally {
  152.                 $this->postDispatch($eventName, $event);
  153.             }
  154.         } finally {
  155.             $this->postProcess($eventName);
  156.         }
  158.         return $event;
  159.     }
  161.     /**
  162.      * {@inheritdoc}
  163.      */
  164.     public function getCalledListeners()
  165.     {
  166.         if (null === $this->callStack) {
  167.             return [];
  168.         }
  170.         $called = [];
  171.         foreach ($this->callStack as $listener) {
  172.             list($eventName) = $this->callStack->getInfo();
  174.             $called[] = $listener->getInfo($eventName);
  175.         }
  177.         return $called;
  178.     }
  180.     /**
  181.      * {@inheritdoc}
  182.      */
  183.     public function getNotCalledListeners()
  184.     {
  185.         try {
  186.             $allListeners = $this->getListeners();
  187.         } catch (\Exception $e) {
  188.             if (null !== $this->logger) {
  189.                 $this->logger->info('An exception was thrown while getting the uncalled listeners.', ['exception' => $e]);
  190.             }
  192.             // unable to retrieve the uncalled listeners
  193.             return [];
  194.         }
  196.         $notCalled = [];
  197.         foreach ($allListeners as $eventName => $listeners) {
  198.             foreach ($listeners as $listener) {
  199.                 $called = false;
  200.                 if (null !== $this->callStack) {
  201.                     foreach ($this->callStack as $calledListener) {
  202.                         if ($calledListener->getWrappedListener() === $listener) {
  203.                             $called = true;
  205.                             break;
  206.                         }
  207.                     }
  208.                 }
  210.                 if (!$called) {
  211.                     if (!$listener instanceof WrappedListener) {
  212.                         $listener = new WrappedListener($listener, null, $this->stopwatch, $this);
  213.                     }
  214.                     $notCalled[] = $listener->getInfo($eventName);
  215.                 }
  216.             }
  217.         }
  219.         uasort($notCalled, [$this, 'sortNotCalledListeners']);
  221.         return $notCalled;
  222.     }
  224.     public function getOrphanedEvents(): array
  225.     {
  226.         return $this->orphanedEvents;
  227.     }
  229.     public function reset()
  230.     {
  231.         $this->callStack = null;
  232.         $this->orphanedEvents = [];
  233.     }
  235.     /**
  236.      * Proxies all method calls to the original event dispatcher.
  237.      *
  238.      * @param string $method    The method name
  239.      * @param array  $arguments The method arguments
  240.      *
  241.      * @return mixed
  242.      */
  243.     public function __call($method, $arguments)
  244.     {
  245.         return $this->dispatcher->{$method}(...$arguments);
  246.     }
  248.     /**
  249.      * Called before dispatching the event.
  250.      *
  251.      * @param string $eventName The event name
  252.      * @param Event  $event     The event
  253.      */
  254.     protected function preDispatch($eventName, Event $event)
  255.     {
  256.     }
  258.     /**
  259.      * Called after dispatching the event.
  260.      *
  261.      * @param string $eventName The event name
  262.      * @param Event  $event     The event
  263.      */
  264.     protected function postDispatch($eventName, Event $event)
  265.     {
  266.     }
  268.     private function preProcess($eventName)
  269.     {
  270.         if (!$this->dispatcher->hasListeners($eventName)) {
  271.             $this->orphanedEvents[] = $eventName;
  273.             return;
  274.         }
  276.         foreach ($this->dispatcher->getListeners($eventName) as $listener) {
  277.             $priority = $this->getListenerPriority($eventName, $listener);
  278.             $wrappedListener = new WrappedListener($listener instanceof WrappedListener ? $listener->getWrappedListener() : $listener, null, $this->stopwatch, $this);
  279.             $this->wrappedListeners[$eventName][] = $wrappedListener;
  280.             $this->dispatcher->removeListener($eventName, $listener);
  281.             $this->dispatcher->addListener($eventName, $wrappedListener, $priority);
  282.             $this->callStack->attach($wrappedListener, [$eventName]);
  283.         }
  284.     }
  286.     private function postProcess($eventName)
  287.     {
  288.         unset($this->wrappedListeners[$eventName]);
  289.         $skipped = false;
  290.         foreach ($this->dispatcher->getListeners($eventName) as $listener) {
  291.             if (!$listener instanceof WrappedListener) { // #12845: a new listener was added during dispatch.
  292.                 continue;
  293.             }
  294.             // Unwrap listener
  295.             $priority = $this->getListenerPriority($eventName, $listener);
  296.             $this->dispatcher->removeListener($eventName, $listener);
  297.             $this->dispatcher->addListener($eventName, $listener->getWrappedListener(), $priority);
  299.             if (null !== $this->logger) {
  300.                 $context = ['event' => $eventName, 'listener' => $listener->getPretty()];
  301.             }
  303.             if ($listener->wasCalled()) {
  304.                 if (null !== $this->logger) {
  305.                     $this->logger->debug('Notified event "{event}" to listener "{listener}".', $context);
  306.                 }
  307.             } else {
  308.                 $this->callStack->detach($listener);
  309.             }
  311.             if (null !== $this->logger && $skipped) {
  312.                 $this->logger->debug('Listener "{listener}" was not called for event "{event}".', $context);
  313.             }
  315.             if ($listener->stoppedPropagation()) {
  316.                 if (null !== $this->logger) {
  317.                     $this->logger->debug('Listener "{listener}" stopped propagation of the event "{event}".', $context);
  318.                 }
  320.                 $skipped = true;
  321.             }
  322.         }
  323.     }
  325.     private function sortNotCalledListeners(array $a, array $b)
  326.     {
  327.         if (0 !== $cmp = strcmp($a['event'], $b['event'])) {
  328.             return $cmp;
  329.         }
  331.         if (\is_int($a['priority']) && !\is_int($b['priority'])) {
  332.             return 1;
  333.         }
  335.         if (!\is_int($a['priority']) && \is_int($b['priority'])) {
  336.             return -1;
  337.         }
  339.         if ($a['priority'] === $b['priority']) {
  340.             return 0;
  341.         }
  343.         if ($a['priority'] > $b['priority']) {
  344.             return -1;
  345.         }
  347.         return 1;
  348.     }
  349. }