vendor/prooph/service-bus-symfony-bundle/src/DependencyInjection/Configuration.php line 29

Open in your IDE?
  1. <?php
  2. /**
  3.  * prooph (http://getprooph.org/)
  4.  *
  5.  * @see       https://github.com/prooph/service-bus-symfony-bundle for the canonical source repository
  6.  * @copyright Copyright (c) 2016 prooph software GmbH (http://prooph-software.com/)
  7.  * @license   https://github.com/prooph/service-bus-symfony-bundle/blob/master/LICENSE.md New BSD License
  8.  */
  10. declare(strict_types=1);
  12. namespace Prooph\Bundle\ServiceBus\DependencyInjection;
  14. use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
  15. use Symfony\Component\Config\Definition\Builder\TreeBuilder;
  16. use Symfony\Component\Config\Definition\ConfigurationInterface;
  18. final class Configuration implements ConfigurationInterface
  19. {
  20.     /**
  21.      * Normalizes XML config and defines config tree
  22.      *
  23.      * {@inheritdoc}
  24.      */
  25.     public function getConfigTreeBuilder(): TreeBuilder
  26.     {
  27.         $treeBuilder = new TreeBuilder();
  28.         /** @var ArrayNodeDefinition $rootNode Help phpstan */
  29.         $rootNode = $treeBuilder->root('prooph_service_bus');
  31.         foreach (ProophServiceBusExtension::AVAILABLE_BUSES as $type) {
  32.             $this->addServiceBusSection($type, $rootNode);
  33.         }
  35.         return $treeBuilder;
  36.     }
  38.     /**
  39.      * Add service bus section to configuration tree
  40.      *
  41.      * @link https://github.com/prooph/service-bus
  42.      *
  43.      * @param string $type Bus type
  44.      * @param ArrayNodeDefinition $node
  45.      */
  46.     private function addServiceBusSection(string $type, ArrayNodeDefinition $node): void
  47.     {
  48.         $treeBuilder = new TreeBuilder();
  49.         /** @var ArrayNodeDefinition $routesNode */
  50.         $routesNode = $treeBuilder->root('routes');
  51.         $routesNode->useAttributeAsKey($type);
  52.         $handlerNode = $routesNode->prototype('event' === $type ? 'array' : 'scalar');
  54.         if ('event' === $type) {
  55.             $handlerNode
  56.                 ->beforeNormalization()
  57.                     ->ifTrue(function ($v) {
  58.                         // XML uses listener nodes
  59.                         return isset($v['listener']);
  60.                     })
  61.                     ->then(function ($v) {
  62.                         // fix single node in XML
  63.                         return (array) $v['listener'];
  64.                     })
  65.                 ->end()
  66.                 ->prototype('scalar')
  67.                     ->beforeNormalization()
  68.                         ->ifTrue(function ($v) {
  69.                             return strpos($v, '@') === 0;
  70.                         })
  71.                         ->then(function ($v) {
  72.                             return substr($v, 1);
  73.                         })
  74.                     ->end()
  75.                 ->end();
  76.         } else {
  77.             $handlerNode
  78.                 ->beforeNormalization()
  79.                     ->ifTrue(function ($v) {
  80.                         return strpos($v, '@') === 0;
  81.                     })
  82.                     ->then(function ($v) {
  83.                         return substr($v, 1);
  84.                     })
  85.                 ->end();
  86.         }
  87.         $handlerNode->end();
  89.         $node
  90.             ->fixXmlConfig($type . '_bus', $type . '_buses')
  91.             ->children()
  92.             ->arrayNode($type . '_buses')
  93.                 ->requiresAtLeastOneElement()
  94.                 ->useAttributeAsKey('name')
  95.                 ->prototype('array')
  96.                 ->fixXmlConfig('plugin', 'plugins')
  97.                 ->children()
  98.                     ->scalarNode('message_factory')
  99.                         ->beforeNormalization()
  100.                             ->ifTrue(function ($v) {
  101.                                 return strpos($v, '@') === 0;
  102.                             })
  103.                             ->then(function ($v) {
  104.                                 return substr($v, 1);
  105.                             })
  106.                         ->end()
  107.                         ->defaultValue('prooph_service_bus.message_factory')
  108.                     ->end()
  109.                     ->scalarNode('message_data_converter')
  110.                         ->beforeNormalization()
  111.                             ->ifTrue(function ($v) {
  112.                                 return strpos($v, '@') === 0;
  113.                             })
  114.                             ->then(function ($v) {
  115.                                 return substr($v, 1);
  116.                             })
  117.                         ->end()
  118.                         ->defaultValue('prooph_service_bus.message_data_converter.' . $type)
  119.                     ->end()
  120.                     ->scalarNode('message_converter')
  121.                         ->beforeNormalization()
  122.                             ->ifTrue(function ($v) {
  123.                                 return strpos($v, '@') === 0;
  124.                             })
  125.                             ->then(function ($v) {
  126.                                 return substr($v, 1);
  127.                             })
  128.                         ->end()
  129.                         ->defaultValue('prooph_service_bus.message_converter')
  130.                     ->end()
  131.                     ->arrayNode('plugins')
  132.                         ->beforeNormalization()
  133.                             // fix single node in XML
  134.                             ->ifString()->then(function ($v) {
  135.                                 return [$v];
  136.                             })
  137.                         ->end()
  138.                         ->prototype('scalar')
  139.                             ->beforeNormalization()
  140.                                 ->ifTrue(function ($v) {
  141.                                     return strpos($v, '@') === 0;
  142.                                 })
  143.                                 ->then(function ($v) {
  144.                                     return substr($v, 1);
  145.                                 })
  146.                             ->end()
  147.                         ->end()
  148.                     ->end()
  149.                     ->arrayNode('router')
  150.                         ->fixXmlConfig('route', 'routes')
  151.                         ->addDefaultsIfNotSet()
  152.                         ->children()
  153.                             ->scalarNode('type')
  154.                                 ->beforeNormalization()
  155.                                     ->ifTrue(function ($v) {
  156.                                         return strpos($v, '@') === 0;
  157.                                     })
  158.                                     ->then(function ($v) {
  159.                                         return substr($v, 1);
  160.                                     })
  161.                                 ->end()
  162.                                 ->defaultValue('prooph_service_bus.' . $type . '_bus_router')
  163.                             ->end()
  164.                             ->scalarNode('async_switch')
  165.                                 ->beforeNormalization()
  166.                                     ->ifTrue(function ($v) {
  167.                                         return strpos($v, '@') === 0;
  168.                                     })
  169.                                     ->then(function ($v) {
  170.                                         return substr($v, 1);
  171.                                     })
  172.                                 ->end()
  173.                             ->end()
  174.                             ->append($routesNode)
  175.                         ->end()
  176.                     ->end()
  177.                 ->end()
  178.             ->end();
  179.     }
  180. }