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

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. }