vendor/api-platform/core/src/Core/Bridge/Symfony/Messenger/DataPersister.php line 45

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\Api\OperationType;
  17. use ApiPlatform\Core\DataPersister\ContextAwareDataPersisterInterface;
  18. use ApiPlatform\Core\Metadata\Resource\Factory\ResourceMetadataFactoryInterface;
  19. use ApiPlatform\Exception\OperationNotFoundException;
  20. use ApiPlatform\Exception\ResourceClassNotFoundException;
  21. use ApiPlatform\Metadata\Resource\Factory\ResourceMetadataCollectionFactoryInterface;
  22. use ApiPlatform\Symfony\Messenger\DispatchTrait;
  23. use ApiPlatform\Util\ClassInfoTrait;
  24. use Symfony\Component\Messenger\Envelope;
  25. use Symfony\Component\Messenger\MessageBusInterface;
  26. use Symfony\Component\Messenger\Stamp\HandledStamp;
  28. /**
  29.  * Dispatches the given resource using the message bus of Symfony Messenger.
  30.  *
  31.  * @experimental
  32.  *
  33.  * @author Kévin Dunglas <dunglas@gmail.com>
  34.  */
  35. final class DataPersister implements ContextAwareDataPersisterInterface
  36. {
  37.     use ClassInfoTrait;
  38.     use DispatchTrait;
  40.     /**
  41.      * @var ResourceMetadataCollectionFactoryInterface|ResourceMetadataFactoryInterface
  42.      */
  43.     private $resourceMetadataFactory;
  45.     public function __construct($resourceMetadataFactory, MessageBusInterface $messageBus)
  46.     {
  47.         $this->resourceMetadataFactory = $resourceMetadataFactory;
  48.         $this->messageBus = $messageBus;
  50.         if (!$resourceMetadataFactory instanceof ResourceMetadataCollectionFactoryInterface) {
  51.             trigger_deprecation('api-platform/core', '2.7', sprintf('Use "%s" instead of "%s".', ResourceMetadataCollectionFactoryInterface::class, ResourceMetadataFactoryInterface::class));
  52.         }
  53.     }
  55.     public function supports($data, array $context = []): bool
  56.     {
  57.         if ($this->resourceMetadataFactory instanceof ResourceMetadataCollectionFactoryInterface) {
  58.             try {
  59.                 $resourceMetadataCollection = $this->resourceMetadataFactory->create($context['resource_class'] ?? $this->getObjectClass($data));
  60.                 $operation = $resourceMetadataCollection->getOperation($context['operation_name'] ?? null);
  62.                 return false !== ($operation->getMessenger() ?? false);
  63.             } catch (OperationNotFoundException $e) {
  64.                 return false;
  65.             }
  66.         }
  68.         try {
  69.             $resourceMetadata = $this->resourceMetadataFactory->create($context['resource_class'] ?? $this->getObjectClass($data));
  70.         } catch (ResourceClassNotFoundException $e) {
  71.             return false;
  72.         }
  74.         if (null !== $operationName = $context['collection_operation_name'] ?? $context['item_operation_name'] ?? null) {
  75.             return false !== $resourceMetadata->getTypedOperationAttribute(
  76.                 $context['collection_operation_name'] ?? false ? OperationType::COLLECTION : OperationType::ITEM,
  77.                 $operationName,
  78.                 'messenger',
  79.                 false,
  80.                 true
  81.             );
  82.         }
  84.         if (isset($context['graphql_operation_name'])) {
  85.             return false !== $resourceMetadata->getGraphqlAttribute($context['graphql_operation_name'], 'messenger', false, true);
  86.         }
  88.         return false !== $resourceMetadata->getAttribute('messenger', false);
  89.     }
  91.     public function persist($data, array $context = [])
  92.     {
  93.         $envelope = $this->dispatch(
  94.             (new Envelope($data))
  95.                 ->with(new ContextStamp($context))
  96.         );
  98.         $handledStamp = $envelope->last(HandledStamp::class);
  99.         if (!$handledStamp instanceof HandledStamp) {
  100.             return $data;
  101.         }
  103.         return $handledStamp->getResult();
  104.     }
  106.     public function remove($data, array $context = [])
  107.     {
  108.         $this->dispatch(
  109.             (new Envelope($data))
  110.                 ->with(new RemoveStamp())
  111.         );
  112.     }
  113. }