Test input with messenger

Author: soyuka

features/main/input_output.feature

@@ -242,3 +242,26 @@ Feature: DTO input and output
       }
     }
     """
+
+  @createSchema
+  Scenario: Use messenger with an input where the handler gives a synchronous result
+    When I add "Content-Type" header equal to "application/ld+json"
+    And I send a "POST" request to "/messenger_with_inputs" with body:
+    """
+    {
+      "var": "test"
+    }
+    """
+    Then the response status code should be 201
+    And the response should be in JSON
+    And the header "Content-Type" should be equal to "application/ld+json; charset=utf-8"
+    And the JSON should be equal to:
+    """
+    {
+      "@context": "/contexts/MessengerWithInput",
+      "@id": "/messenger_with_inputs/1",
+      "@type": "MessengerWithInput",
+      "id": 1,
+      "name": "test"
+    }
+    """

tests/Fixtures/TestBundle/Dto/MessengerInput.php

@@ -0,0 +1,22 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <dunglas@gmail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace ApiPlatform\Core\Tests\Fixtures\TestBundle\Dto;
+
+class MessengerInput
+{
+    /**
+     * @var string
+     */
+    public $var;
+}

tests/Fixtures/TestBundle/Entity/MessengerWithInput.php

@@ -0,0 +1,33 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <dunglas@gmail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace ApiPlatform\Core\Tests\Fixtures\TestBundle\Entity;
+
+use ApiPlatform\Core\Annotation\ApiProperty;
+use ApiPlatform\Core\Annotation\ApiResource;
+use ApiPlatform\Core\Tests\Fixtures\TestBundle\Dto\MessengerInput;
+
+/**
+ * @ApiResource(messenger="input", input=MessengerInput::class)
+ */
+class MessengerWithInput
+{
+    /**
+     * @ApiProperty(identifier=true)
+     */
+    public $id;
+    /**
+     * @var string
+     */
+    public $name;
+}

tests/Fixtures/TestBundle/MessengerHandler/MessengerWithInputHandler.php

@@ -0,0 +1,30 @@
+<?php
+
+/*
+ * This file is part of the API Platform project.
+ *
+ * (c) Kévin Dunglas <dunglas@gmail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace ApiPlatform\Core\Tests\Fixtures\TestBundle\MessengerHandler;
+
+use ApiPlatform\Core\Tests\Fixtures\TestBundle\Dto\MessengerInput;
+use ApiPlatform\Core\Tests\Fixtures\TestBundle\Entity\MessengerWithInput;
+use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
+
+class MessengerWithInputHandler implements MessageHandlerInterface
+{
+    public function __invoke(MessengerInput $data)
+    {
+        $object = new MessengerWithInput();
+        $object->name = 'test';
+        $object->id = 1;
+
+        return $object;
+    }
+}

tests/Fixtures/app/config/config_common.yml

@@ -238,3 +238,9 @@ services:
         public: false
         tags:
             -  { name: 'api_platform.data_transformer' }
+
+    app.messenger_handler.messenger_with_inputs:
+        class: 'ApiPlatform\Core\Tests\Fixtures\TestBundle\MessengerHandler\MessengerWithInputHandler'
+        public: false
+        tags:
+            -  { name: 'messenger.message_handler' }