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

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\Compiler\CompilerPassInterface;
  9. use Symfony\Component\DependencyInjection\Compiler\ServiceLocatorTagPass;
  10. use Symfony\Component\DependencyInjection\ContainerBuilder;
  11. use Symfony\Component\DependencyInjection\Reference;
  13. class RegisterEventListenersAndSubscribersPass implements CompilerPassInterface
  14. {
  15.     public function process(ContainerBuilder $container)
  16.     {
  17.         $listeners = [];
  18.         $listenerServices = [];
  19.         foreach ($container->findTaggedServiceIds('jms_serializer.event_listener') as $id => $tags) {
  20.             foreach ($tags as $attributes) {
  21.                 if (!isset($attributes['event'])) {
  22.                     throw new \RuntimeException(sprintf('The tag "jms_serializer.event_listener" of service "%s" requires an attribute named "event".', $id));
  23.                 }
  25.                 $class = isset($attributes['class'])
  26.                     ? $container->getParameterBag()->resolveValue($attributes['class'])
  27.                     : null;
  29.                 $format = $attributes['format'] ?? null;
  30.                 $method = $attributes['method'] ?? EventDispatcher::getDefaultMethodName($attributes['event']);
  31.                 $priority = isset($attributes['priority']) ? (int) $attributes['priority'] : 0;
  33.                 if (class_exists(ServiceLocatorTagPass::class) || $container->getDefinition($id)->isPublic()) {
  34.                     $listenerServices[$id] = new Reference($id);
  35.                     $listeners[$attributes['event']][$priority][] = [[$id, $method], $class, $format];
  36.                 } else {
  37.                     $listeners[$attributes['event']][$priority][] = [[new Reference($id), $method], $class, $format];
  38.                 }
  39.             }
  40.         }
  42.         foreach ($container->findTaggedServiceIds('jms_serializer.event_subscriber') as $id => $tags) {
  43.             $subscriberClass = $container->getDefinition($id)->getClass();
  45.             $subscriberClassReflectionObj = new \ReflectionClass($subscriberClass);
  47.             if (!$subscriberClassReflectionObj->implementsInterface('JMS\Serializer\EventDispatcher\EventSubscriberInterface')) {
  48.                 throw new \RuntimeException(sprintf('The service "%s" (class: %s) does not implement the EventSubscriberInterface.', $id, $subscriberClass));
  49.             }
  51.             foreach (call_user_func([$subscriberClass, 'getSubscribedEvents']) as $eventData) {
  52.                 if (!isset($eventData['event'])) {
  53.                     throw new \RuntimeException(sprintf('The service "%s" (class: %s) must return an event for each subscribed event.', $id, $subscriberClass));
  54.                 }
  56.                 $class = $eventData['class'] ?? null;
  57.                 $format = $eventData['format'] ?? null;
  58.                 $method = $eventData['method'] ?? EventDispatcher::getDefaultMethodName($eventData['event']);
  59.                 $priority = isset($eventData['priority']) ? (int) $eventData['priority'] : 0;
  60.                 $interface = $eventData['interface'] ?? null;
  62.                 if (class_exists(ServiceLocatorTagPass::class) || $container->getDefinition($id)->isPublic()) {
  63.                     $listenerServices[$id] = new Reference($id);
  64.                     $listeners[$eventData['event']][$priority][] = [[$id, $method], $class, $format, $interface];
  65.                 } else {
  66.                     $listeners[$eventData['event']][$priority][] = [[new Reference($id), $method], $class, $format, $interface];
  67.                 }
  68.             }
  69.         }
  71.         if ($listeners) {
  72.             array_walk($listeners, static function (&$value, $key) {
  73.                 ksort($value);
  74.             });
  76.             foreach ($listeners as &$events) {
  77.                 $events = call_user_func_array('array_merge', $events);
  78.             }
  80.             $container->findDefinition('jms_serializer.event_dispatcher')
  81.                 ->addMethodCall('setListeners', [$listeners]);
  82.         }
  84.         if (class_exists(ServiceLocatorTagPass::class)) {
  85.             $serviceLocator = ServiceLocatorTagPass::register($container, $listenerServices);
  86.             $container->getDefinition('jms_serializer.event_dispatcher')->replaceArgument(0, $serviceLocator);
  87.         }
  88.     }
  89. }