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.     /**
  56.      * {@inheritdoc}
  57.      */
  58.     public function supports($data, array $context = []): bool
  59.     {
  60.         if ($this->resourceMetadataFactory instanceof ResourceMetadataCollectionFactoryInterface) {
  61.             try {
  62.                 $resourceMetadataCollection = $this->resourceMetadataFactory->create($context['resource_class'] ?? $this->getObjectClass($data));
  63.                 $operation = $resourceMetadataCollection->getOperation($context['operation_name'] ?? null);
  65.                 return false !== ($operation->getMessenger() ?? false);
  66.             } catch (OperationNotFoundException $e) {
  67.                 return false;
  68.             }
  69.         }
  71.         try {
  72.             $resourceMetadata = $this->resourceMetadataFactory->create($context['resource_class'] ?? $this->getObjectClass($data));
  73.         } catch (ResourceClassNotFoundException $e) {
  74.             return false;
  75.         }
  77.         if (null !== $operationName = $context['collection_operation_name'] ?? $context['item_operation_name'] ?? null) {
  78.             return false !== $resourceMetadata->getTypedOperationAttribute(
  79.                 $context['collection_operation_name'] ?? false ? OperationType::COLLECTION : OperationType::ITEM,
  80.                 $operationName,
  81.                 'messenger',
  82.                 false,
  83.                 true
  84.             );
  85.         }
  87.         if (isset($context['graphql_operation_name'])) {
  88.             return false !== $resourceMetadata->getGraphqlAttribute($context['graphql_operation_name'], 'messenger', false, true);
  89.         }
  91.         return false !== $resourceMetadata->getAttribute('messenger', false);
  92.     }
  94.     /**
  95.      * {@inheritdoc}
  96.      */
  97.     public function persist($data, array $context = [])
  98.     {
  99.         $envelope = $this->dispatch(
  100.             (new Envelope($data))
  101.                 ->with(new ContextStamp($context))
  102.         );
  104.         $handledStamp = $envelope->last(HandledStamp::class);
  105.         if (!$handledStamp instanceof HandledStamp) {
  106.             return $data;
  107.         }
  109.         return $handledStamp->getResult();
  110.     }
  112.     /**
  113.      * {@inheritdoc}
  114.      */
  115.     public function remove($data, array $context = [])
  116.     {
  117.         $this->dispatch(
  118.             (new Envelope($data))
  119.                 ->with(new RemoveStamp())
  120.         );
  121.     }
  122. }