Add messenger transport routing per job name (#175)

* Add messenger transport routing per job name

* Fixed missing sentence end in doc

* Fixed unclosed prototypes in config

* Fixed potentially undefined messenger config

* Fixed validate rules not set on prototyped config vars

Author: yann-eugone

src/DependencyInjection/Configuration.php

@@ -33,6 +33,9 @@
  * @phpstan-type LauncherConfig array{
  *      default: string|null,
  *      launchers: array<string, string>,
+ *      messenger?: array{
+ *          routing: array<string, string>,
+ *      },
  *  }
  * @phpstan-type ParametersConfig array{
  *      global: array<string, mixed>,
@@ -130,8 +133,18 @@ private function launcher(): ArrayNodeDefinition
                     ->defaultValue(['simple' => 'simple://simple'])
                     ->useAttributeAsKey('name')
                     ->scalarPrototype()
-                    ->validate()
-                        ->ifTrue($isInvalidDsn)->thenInvalid('Invalid job launcher DSN.')
+                        ->validate()
+                            ->ifTrue($isInvalidDsn)->thenInvalid('Invalid job launcher DSN.')
+                        ->end()
+                    ->end()
+                ->end()
+                ->arrayNode('messenger')
+                    ->children()
+                        ->arrayNode('routing')
+                            ->normalizeKeys(false)
+                            ->useAttributeAsKey('name')
+                            ->scalarPrototype()->end()
+                        ->end()
                     ->end()
                 ->end()
             ->end()
@@ -164,15 +177,15 @@ private function parameters(): ArrayNodeDefinition
             ->children()
                 ->arrayNode('global')
                     ->useAttributeAsKey('name')
-                    ->variablePrototype()
-                    ->end()
+                    ->variablePrototype()->end()
                 ->end()
                 ->arrayNode('per_job')
                     ->useAttributeAsKey('name')
                     ->variablePrototype()
-                    ->validate()
-                        ->ifTrue(fn(mixed $value) => !$isStringAssociativeArray($value))
-                            ->thenInvalid('Should be an array<string, mixed>.')
+                        ->validate()
+                            ->ifTrue(fn(mixed $value) => !$isStringAssociativeArray($value))
+                                ->thenInvalid('Should be an array<string, mixed>.')
+                        ->end()
                     ->end()
                 ->end()
             ->end()

src/DependencyInjection/JobLauncherDefinitionFactory.php

@@ -11,6 +11,7 @@
 use Yokai\Batch\Bridge\Symfony\Console\CommandRunner;
 use Yokai\Batch\Bridge\Symfony\Console\RunCommandJobLauncher;
 use Yokai\Batch\Bridge\Symfony\Messenger\DispatchMessageJobLauncher;
+use Yokai\Batch\Bridge\Symfony\Messenger\MessengerJobsConfiguration;
 use Yokai\Batch\Launcher\JobLauncherInterface;
 use Yokai\Batch\Launcher\SimpleJobLauncher;
 use Yokai\Batch\Storage\JobExecutionStorageInterface;
@@ -71,6 +72,9 @@ private static function messenger(): Definition
             '$jobExecutionFactory' => new Reference('yokai_batch.job_execution_factory'),
             '$jobExecutionStorage' => new Reference(JobExecutionStorageInterface::class),
             '$messageBus' => new Reference(MessageBusInterface::class),
+            '$messengerJobsConfiguration' => new Definition(MessengerJobsConfiguration::class, [
+                '$routing' => '%yokai_batch.launcher.messenger_routing%',
+            ]),
         ]);
     }
 

src/DependencyInjection/YokaiBatchExtension.php

@@ -144,6 +144,8 @@ private function configureLauncher(ContainerBuilder $container, array $config):
             ));
         }
 
+        $container->setParameter('yokai_batch.launcher.messenger_routing', $config['messenger']['routing'] ?? []);
+
         $launcherIdPerLauncherName = [];
         foreach ($config['launchers'] as $name => $dsn) {
             $definitionOrReference = JobLauncherDefinitionFactory::fromDsn($dsn);