vendor/enqueue/async-event-dispatcher/DependencyInjection/AsyncEventsPass.php line 93

Open in your IDE?
  1. <?php
  3. namespace Enqueue\AsyncEventDispatcher\DependencyInjection;
  5. use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
  6. use Symfony\Component\DependencyInjection\ContainerBuilder;
  7. use Symfony\Component\EventDispatcher\DependencyInjection\RegisterListenersPass;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. class AsyncEventsPass implements CompilerPassInterface
  11. {
  12.     public function process(ContainerBuilder $container): void
  13.     {
  14.         if (false == $container->hasDefinition('enqueue.events.async_listener')) {
  15.             return;
  16.         }
  18.         if (false == $container->hasDefinition('enqueue.events.registry')) {
  19.             return;
  20.         }
  22.         $defaultClient = $container->getParameter('enqueue.default_client');
  24.         $registeredToEvent = [];
  25.         foreach ($container->findTaggedServiceIds('kernel.event_listener') as $serviceId => $tagAttributes) {
  26.             foreach ($tagAttributes as $tagAttribute) {
  27.                 if (false == isset($tagAttribute['async'])) {
  28.                     continue;
  29.                 }
  31.                 $event = $tagAttribute['event'];
  33.                 $service = $container->getDefinition($serviceId);
  35.                 $service->clearTag('kernel.event_listener');
  36.                 $service->addTag('enqueue.async_event_listener', $tagAttribute);
  38.                 if (false == isset($registeredToEvent[$event])) {
  39.                     $container->getDefinition('enqueue.events.async_listener')
  40.                         ->addTag('kernel.event_listener', [
  41.                             'event' => $event,
  42.                             'method' => 'onEvent',
  43.                         ])
  44.                     ;
  46.                     $container->getDefinition('enqueue.events.async_processor')
  47.                         ->addTag('enqueue.processor', [
  48.                             'topic' => 'event.'.$event,
  49.                             'client' => $defaultClient,
  50.                         ])
  51.                     ;
  53.                     $registeredToEvent[$event] = true;
  54.                 }
  55.             }
  56.         }
  58.         foreach ($container->findTaggedServiceIds('kernel.event_subscriber') as $serviceId => $tagAttributes) {
  59.             foreach ($tagAttributes as $tagAttribute) {
  60.                 if (false == isset($tagAttribute['async'])) {
  61.                     continue;
  62.                 }
  64.                 $service = $container->getDefinition($serviceId);
  65.                 $service->clearTag('kernel.event_subscriber');
  66.                 $service->addTag('enqueue.async_event_subscriber', $tagAttribute);
  68.                 /** @var EventSubscriberInterface $serviceClass */
  69.                 $serviceClass = $service->getClass();
  71.                 foreach ($serviceClass::getSubscribedEvents() as $event => $data) {
  72.                     if (false == isset($registeredToEvent[$event])) {
  73.                         $container->getDefinition('enqueue.events.async_listener')
  74.                             ->addTag('kernel.event_listener', [
  75.                                 'event' => $event,
  76.                                 'method' => 'onEvent',
  77.                             ])
  78.                         ;
  80.                         $container->getDefinition('enqueue.events.async_processor')
  81.                             ->addTag('enqueue.processor', [
  82.                                 'topicName' => 'event.'.$event,
  83.                                 'client' => $defaultClient,
  84.                             ])
  85.                         ;
  87.                         $registeredToEvent[$event] = true;
  88.                     }
  89.                 }
  90.             }
  91.         }
  93.         $registerListenersPass = new RegisterListenersPass(
  94.             'enqueue.events.event_dispatcher',
  95.             'enqueue.async_event_listener',
  96.             'enqueue.async_event_subscriber'
  97.         );
  98.         $registerListenersPass->process($container);
  99.     }
  100. }