vendor/jms/serializer-bundle/DependencyInjection/Compiler/RegisterEventListenersAndSubscribersPass.php line 70

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace JMS\SerializerBundle\DependencyInjection\Compiler;
  7. use JMS\Serializer\EventDispatcher\EventDispatcher;
  8. use Symfony\Component\DependencyInjection\Argument\ServiceClosureArgument;
  9. use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
  10. use Symfony\Component\DependencyInjection\ContainerBuilder;
  11. use Symfony\Component\DependencyInjection\Reference;
  13. /**
  14.  * @internal
  15.  */
  16. final class RegisterEventListenersAndSubscribersPass implements CompilerPassInterface
  17. {
  18.     public function process(ContainerBuilder $container)
  19.     {
  20.         $listeners = $this->findListeners($container);
  22.         $dispatcherDef = $container->findDefinition('jms_serializer.event_dispatcher');
  23.         $listenerServices = [];
  25.         foreach ($listeners as &$events) {
  26.             $events = array_merge(...$events);
  27.         }
  29.         foreach ($listeners as $event => $listenersPerEvent) {
  30.             foreach ($listenersPerEvent as $singleListener) {
  31.                 $id = (string) $singleListener[0][0];
  33.                 $listenerServices[$id] = new ServiceClosureArgument($singleListener[0][0]);
  34.                 $singleListener[0][0] = $id;
  36.                 $dispatcherDef->addMethodCall('addListener', array_merge([$event], $singleListener));
  37.             }
  38.         }
  40.         $container->findDefinition('jms_serializer.event_dispatcher.service_locator')
  41.             ->setArgument(0, $listenerServices);
  42.     }
  44.     private function findListeners(ContainerBuilder $container): array
  45.     {
  46.         $listeners = [];
  48.         foreach ($container->findTaggedServiceIds('jms_serializer.event_listener') as $id => $tags) {
  49.             foreach ($tags as $attributes) {
  50.                 if (!isset($attributes['event'])) {
  51.                     throw new \RuntimeException(sprintf('The tag "jms_serializer.event_listener" of service "%s" requires an attribute named "event".', $id));
  52.                 }
  54.                 $class = isset($attributes['class'])
  55.                     ? $container->getParameterBag()->resolveValue($attributes['class'])
  56.                     : null;
  58.                 $format = $attributes['format'] ?? null;
  59.                 $method = $attributes['method'] ?? EventDispatcher::getDefaultMethodName($attributes['event']);
  60.                 $priority = isset($attributes['priority']) ? (int) $attributes['priority'] : 0;
  61.                 $interface = $attributes['interface'] ?? null;
  63.                 $listeners[$attributes['event']][$priority][] = [[new Reference($id), $method], $class, $format, $interface];
  64.             }
  65.         }
  67.         foreach ($container->findTaggedServiceIds('jms_serializer.event_subscriber') as $id => $tags) {
  68.             $subscriberClass = $container->getDefinition($id)->getClass();
  70.             $subscriberClassReflectionObj = new \ReflectionClass($subscriberClass);
  72.             if (!$subscriberClassReflectionObj->implementsInterface('JMS\Serializer\EventDispatcher\EventSubscriberInterface')) {
  73.                 throw new \RuntimeException(sprintf('The service "%s" (class: %s) does not implement the EventSubscriberInterface.', $id, $subscriberClass));
  74.             }
  76.             foreach (call_user_func([$subscriberClass, 'getSubscribedEvents']) as $eventData) {
  77.                 if (!isset($eventData['event'])) {
  78.                     throw new \RuntimeException(sprintf('The service "%s" (class: %s) must return an event for each subscribed event.', $id, $subscriberClass));
  79.                 }
  81.                 $class = $eventData['class'] ?? null;
  82.                 $format = $eventData['format'] ?? null;
  83.                 $method = $eventData['method'] ?? EventDispatcher::getDefaultMethodName($eventData['event']);
  84.                 $priority = isset($eventData['priority']) ? (int) $eventData['priority'] : 0;
  85.                 $interface = $eventData['interface'] ?? null;
  87.                 $listeners[$eventData['event']][$priority][] = [[new Reference($id), $method], $class, $format, $interface];
  88.             }
  89.         }
  91.         array_walk($listeners, static function (&$value, $key) {
  92.             ksort($value);
  93.         });
  95.         return $listeners;
  96.     }
  97. }