vendor/zenstruck/messenger-test/src/ZenstruckMessengerTestBundle.php line 26

  1. <?php
  3. /*
  4.  * This file is part of the zenstruck/messenger-test package.
  5.  *
  6.  * (c) Kevin Bond <kevinbond@gmail.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 Zenstruck\Messenger\Test;
  14. use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
  15. use Symfony\Component\DependencyInjection\ContainerBuilder;
  16. use Symfony\Component\DependencyInjection\Extension\ExtensionInterface;
  17. use Symfony\Component\DependencyInjection\Reference;
  18. use Symfony\Component\HttpKernel\Bundle\Bundle;
  19. use Symfony\Component\Messenger\Transport\TransportInterface;
  20. use Zenstruck\Messenger\Test\Transport\TestTransportFactory;
  21. use Zenstruck\Messenger\Test\Transport\TestTransportRegistry;
  23. /**
  24.  * @author Kevin Bond <kevinbond@gmail.com>
  25.  */
  26. final class ZenstruckMessengerTestBundle extends Bundle implements CompilerPassInterface
  27. {
  28.     public function build(ContainerBuilder $container): void
  29.     {
  30.         $container->register('zenstruck_messenger_test.transport_factory', TestTransportFactory::class)
  31.             ->setArguments([new Reference('messenger.routable_message_bus'), new Reference('event_dispatcher')])
  32.             ->addTag('messenger.transport_factory')
  33.         ;
  35.         $container->register('zenstruck_messenger_test.transport_registry', TestTransportRegistry::class)
  36.             ->setPublic(true)
  37.         ;
  39.         $container->addCompilerPass($this);
  40.     }
  42.     public function getContainerExtension(): ?ExtensionInterface
  43.     {
  44.         return null;
  45.     }
  47.     public function process(ContainerBuilder $container): void
  48.     {
  49.         $registry = $container->getDefinition('zenstruck_messenger_test.transport_registry');
  51.         foreach ($container->findTaggedServiceIds('messenger.receiver') as $id => $tags) {
  52.             $name = $id;
  54.             if (!$class = $container->getDefinition($name)->getClass()) {
  55.                 continue;
  56.             }
  58.             if (!\is_a($class, TransportInterface::class, true)) {
  59.                 continue;
  60.             }
  62.             foreach ($tags as $tag) {
  63.                 if (isset($tag['alias'])) {
  64.                     $name = $tag['alias'];
  65.                 }
  66.             }
  68.             $registry->addMethodCall('register', [$name, new Reference($id)]);
  69.         }
  70.     }
  71. }