Provides an integration with the Symfony Messenger component

Author: dunglas

composer.json

@@ -60,7 +60,7 @@
         "symfony/framework-bundle": "^3.3 || ^4.0",
         "symfony/mercure": "*",
         "symfony/mercure-bundle": "*",
-        "symfony/messenger": "^4.1",
+        "symfony/messenger": "^4.2",
         "symfony/phpunit-bridge": "^3.3 || ^4.0",
         "symfony/routing": "^3.3 || ^4.0",
         "symfony/security": "^3.0 || ^4.0",

src/Annotation/ApiResource.php

@@ -42,6 +42,7 @@
  *     @Attribute("itemOperations", type="array"),
  *     @Attribute("maximumItemsPerPage", type="int"),
  *     @Attribute("mercure", type="mixed"),
+ *     @Attribute("messenger", type="bool"),
  *     @Attribute("normalizationContext", type="array"),
  *     @Attribute("order", type="array"),
  *     @Attribute("outputClass", type="mixed"),
@@ -183,6 +184,13 @@ final class ApiResource
      */
     private $mercure;
 
+    /**
+     * @see https://github.com/Haehnchen/idea-php-annotation-plugin/issues/112
+     *
+     * @var bool
+     */
+    private $messenger;
+
     /**
      * @see https://github.com/Haehnchen/idea-php-annotation-plugin/issues/112
      *

src/Bridge/Symfony/Bundle/DependencyInjection/ApiPlatformExtension.php

@@ -37,6 +37,7 @@
 use Symfony\Component\ExpressionLanguage\ExpressionLanguage;
 use Symfony\Component\Finder\Finder;
 use Symfony\Component\HttpKernel\DependencyInjection\Extension;
+use Symfony\Component\Messenger\MessageBusInterface;
 use Symfony\Component\Validator\Validator\ValidatorInterface;
 use Symfony\Component\Yaml\Yaml;
 
@@ -145,6 +146,10 @@ public function load(array $configs, ContainerBuilder $container)
         $this->registerValidatorConfiguration($container, $config);
         $this->registerDataCollectorConfiguration($container, $config, $loader);
         $this->registerMercureConfiguration($container, $config, $loader, $useDoctrine);
+
+        if (interface_exists(MessageBusInterface::class)) {
+            $loader->load('messenger.xml');
+        }
     }
 
     /**

tests/Annotation/ApiResourceTest.php

@@ -38,12 +38,15 @@ public function testConstruct()
             'formats' => ['foo', 'bar' => ['application/bar']],
             'filters' => ['foo', 'bar'],
             'graphql' => ['query' => ['normalization_context' => ['groups' => ['foo', 'bar']]]],
+            'inputClass' => 'Foo',
             'iri' => 'http://example.com/res',
             'itemOperations' => ['foo' => ['bar']],
             'maximumItemsPerPage' => 42,
             'mercure' => '[\'foo\', object.owner]',
+            'messenger' => true,
             'normalizationContext' => ['groups' => ['bar']],
             'order' => ['foo', 'bar' => 'ASC'],
+            'outputClass' => 'Bar',
             'paginationClientEnabled' => true,
             'paginationClientItemsPerPage' => true,
             'paginationClientPartial' => true,
@@ -74,10 +77,13 @@ public function testConstruct()
             'force_eager' => false,
             'formats' => ['foo', 'bar' => ['application/bar']],
             'filters' => ['foo', 'bar'],
+            'input_class' => 'Foo',
             'maximum_items_per_page' => 42,
             'mercure' => '[\'foo\', object.owner]',
+            'messenger' => true,
             'normalization_context' => ['groups' => ['bar']],
             'order' => ['foo', 'bar' => 'ASC'],
+            'output_class' => 'Bar',
             'pagination_client_enabled' => true,
             'pagination_client_items_per_page' => true,
             'pagination_client_partial' => true,

tests/Bridge/Symfony/Bundle/DependencyInjection/ApiPlatformExtensionTest.php

@@ -767,6 +767,7 @@ private function getBaseContainerBuilderProphecy()
             'api_platform.validator',
             'api_platform.mercure.listener.response.add_link_header',
             'api_platform.doctrine.listener.mercure.publish',
+            'api_platform.messenger.data_persister',
         ];
 
         foreach ($definitions as $definition) {
@@ -775,6 +776,7 @@ private function getBaseContainerBuilderProphecy()
 
         $aliases = [
             'api_platform.http_cache.purger' => 'api_platform.http_cache.purger.varnish',
+            'api_platform.message_bus' => 'message_bus',
             EagerLoadingExtension::class => 'api_platform.doctrine.orm.query_extension.eager_loading',
             FilterExtension::class => 'api_platform.doctrine.orm.query_extension.filter',
             FilterEagerLoadingExtension::class => 'api_platform.doctrine.orm.query_extension.filter_eager_loading',