vendor/api-platform/core/src/Core/Bridge/Symfony/Messenger/DataTransformer.php line 42

Open in your IDE?
  1. <?php
  3. /*
  4. * This file is part of the API Platform project.
  5. *
  6. * (c) Kévin Dunglas <dunglas@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. declare(strict_types=1);
  14. namespace ApiPlatform\Core\Bridge\Symfony\Messenger;
  16. use ApiPlatform\Core\DataTransformer\DataTransformerInterface;
  17. use ApiPlatform\Core\Metadata\Resource\Factory\ResourceMetadataFactoryInterface;
  18. use ApiPlatform\Exception\OperationNotFoundException;
  19. use ApiPlatform\Metadata\Resource\Factory\ResourceMetadataCollectionFactoryInterface;
  20. use ApiPlatform\Util\ClassInfoTrait;
  22. /**
  23. * Transforms an Input to itself. This gives the ability to send the Input to a
  24. * message handler and process it asynchronously.
  25. *
  26. * @author Antoine Bluchet <soyuka@gmail.com>
  27. */
  28. final class DataTransformer implements DataTransformerInterface
  29. {
  30. use ClassInfoTrait;
  32. /**
  33. * @var ResourceMetadataCollectionFactoryInterface|ResourceMetadataFactoryInterface
  34. */
  35. private $resourceMetadataFactory;
  37. public function __construct($resourceMetadataFactory)
  38. {
  39. $this->resourceMetadataFactory = $resourceMetadataFactory;
  41. if (!$resourceMetadataFactory instanceof ResourceMetadataCollectionFactoryInterface) {
  42. trigger_deprecation('api-platform/core', '2.7', sprintf('Use "%s" instead of "%s".', ResourceMetadataCollectionFactoryInterface::class, ResourceMetadataFactoryInterface::class));
  43. }
  44. }
  46. /**
  47. * @return object
  48. */
  49. public function transform($object, string $to, array $context = [])
  50. {
  51. return $object;
  52. }
  54. public function supportsTransformation($data, string $to, array $context = []): bool
  55. {
  56. if (
  57. \is_object($data) // data is not normalized yet, it should be an array
  58. || null === ($context['input']['class'] ?? null)
  59. ) {
  60. return false;
  61. }
  63. if ($this->resourceMetadataFactory instanceof ResourceMetadataCollectionFactoryInterface) {
  64. try {
  65. $resourceMetadataCollection = $this->resourceMetadataFactory->create($context['resource_class'] ?? $to);
  66. $operation = $resourceMetadataCollection->getOperation($context['operation_name'] ?? null);
  68. return 'input' === $operation->getMessenger();
  69. } catch (OperationNotFoundException $e) {
  70. return false;
  71. }
  72. }
  74. $metadata = $this->resourceMetadataFactory->create($context['resource_class'] ?? $to);
  76. if (isset($context['graphql_operation_name'])) {
  77. return 'input' === $metadata->getGraphqlAttribute($context['graphql_operation_name'], 'messenger', null, true);
  78. }
  80. if (!isset($context['operation_type'])) {
  81. return 'input' === $metadata->getAttribute('messenger');
  82. }
  84. return 'input' === $metadata->getTypedOperationAttribute(
  85. $context['operation_type'],
  86. $context[$context['operation_type'].'_operation_name'] ?? '',
  87. 'messenger',
  88. null,
  89. true
  90. );
  91. }
  92. }