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

  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.      * {@inheritdoc}
  48.      *
  49.      * @return object
  50.      */
  51.     public function transform($object, string $to, array $context = [])
  52.     {
  53.         return $object;
  54.     }
  56.     /**
  57.      * {@inheritdoc}
  58.      */
  59.     public function supportsTransformation($data, string $to, array $context = []): bool
  60.     {
  61.         if (
  62.             \is_object($data) // data is not normalized yet, it should be an array
  63.             ||
  64.             null === ($context['input']['class'] ?? null)
  65.         ) {
  66.             return false;
  67.         }
  69.         if ($this->resourceMetadataFactory instanceof ResourceMetadataCollectionFactoryInterface) {
  70.             try {
  71.                 $resourceMetadataCollection = $this->resourceMetadataFactory->create($context['resource_class'] ?? $to);
  72.                 $operation = $resourceMetadataCollection->getOperation($context['operation_name'] ?? null);
  74.                 return 'input' === $operation->getMessenger();
  75.             } catch (OperationNotFoundException $e) {
  76.                 return false;
  77.             }
  78.         }
  80.         $metadata = $this->resourceMetadataFactory->create($context['resource_class'] ?? $to);
  82.         if (isset($context['graphql_operation_name'])) {
  83.             return 'input' === $metadata->getGraphqlAttribute($context['graphql_operation_name'], 'messenger', null, true);
  84.         }
  86.         if (!isset($context['operation_type'])) {
  87.             return 'input' === $metadata->getAttribute('messenger');
  88.         }
  90.         return 'input' === $metadata->getTypedOperationAttribute(
  91.             $context['operation_type'],
  92.             $context[$context['operation_type'].'_operation_name'] ?? '',
  93.             'messenger',
  94.             null,
  95.             true
  96.         );
  97.     }
  98. }