vendor/api-platform/core/src/Symfony/EventListener/ReadListener.php line 59

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\Symfony\EventListener;
  16. use ApiPlatform\Api\UriVariablesConverterInterface as LegacyUriVariablesConverterInterface;
  17. use ApiPlatform\Exception\InvalidIdentifierException;
  18. use ApiPlatform\Exception\InvalidUriVariableException;
  19. use ApiPlatform\Metadata\Put;
  20. use ApiPlatform\Metadata\Resource\Factory\ResourceMetadataCollectionFactoryInterface;
  21. use ApiPlatform\Metadata\UriVariablesConverterInterface;
  22. use ApiPlatform\Metadata\Util\CloneTrait;
  23. use ApiPlatform\Serializer\SerializerContextBuilderInterface;
  24. use ApiPlatform\State\Exception\ProviderNotFoundException;
  25. use ApiPlatform\State\ProviderInterface;
  26. use ApiPlatform\State\UriVariablesResolverTrait;
  27. use ApiPlatform\State\Util\OperationRequestInitiatorTrait;
  28. use ApiPlatform\State\Util\RequestParser;
  29. use ApiPlatform\Symfony\Util\RequestAttributesExtractor;
  30. use Symfony\Component\HttpKernel\Event\RequestEvent;
  31. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  33. /**
  34.  * Retrieves data from the applicable data provider and sets it as a request parameter called data.
  35.  *
  36.  * @author Kévin Dunglas <dunglas@gmail.com>
  37.  */
  38. final class ReadListener
  39. {
  40.     use CloneTrait;
  41.     use OperationRequestInitiatorTrait;
  42.     use UriVariablesResolverTrait;
  44.     public function __construct(
  45.         private readonly ProviderInterface $provider,
  46.         ?ResourceMetadataCollectionFactoryInterface $resourceMetadataCollectionFactory = null,
  47.         private readonly ?SerializerContextBuilderInterface $serializerContextBuilder = null,
  48.         LegacyUriVariablesConverterInterface|UriVariablesConverterInterface|null $uriVariablesConverter = null,
  49.     ) {
  50.         $this->resourceMetadataCollectionFactory = $resourceMetadataCollectionFactory;
  51.         $this->uriVariablesConverter = $uriVariablesConverter;
  52.     }
  54.     /**
  55.      * Calls the data provider and sets the data attribute.
  56.      *
  57.      * @throws NotFoundHttpException
  58.      */
  59.     public function onKernelRequest(RequestEvent $event): void
  60.     {
  61.         $request = $event->getRequest();
  62.         $operation = $this->initializeOperation($request);
  64.         if ('api_platform.symfony.main_controller' === $operation?->getController() || $request->attributes->get('_api_platform_disable_listeners')) {
  65.             return;
  66.         }
  68.         if (!($attributes = RequestAttributesExtractor::extractAttributes($request))) {
  69.             return;
  70.         }
  72.         if (!$attributes['receive'] || !$operation || !($operation->canRead() ?? true) || (!$operation->getUriVariables() && !$request->isMethodSafe())) {
  73.             return;
  74.         }
  76.         $context = ['operation' => $operation];
  78.         if (null === $filters = $request->attributes->get('_api_filters')) {
  79.             $queryString = RequestParser::getQueryString($request);
  80.             $filters = $queryString ? RequestParser::parseRequestParams($queryString) : null;
  81.         }
  83.         if ($filters) {
  84.             $context['filters'] = $filters;
  85.         }
  87.         if ($this->serializerContextBuilder) {
  88.             // Builtin data providers are able to use the serialization context to automatically add join clauses
  89.             $context += $normalizationContext = $this->serializerContextBuilder->createFromRequest($request, true, $attributes);
  90.             $request->attributes->set('_api_normalization_context', $normalizationContext);
  91.         }
  93.         $parameters = $request->attributes->all();
  94.         $resourceClass = $operation->getClass() ?? $attributes['resource_class'];
  95.         try {
  96.             $uriVariables = $this->getOperationUriVariables($operation, $parameters, $resourceClass);
  97.             $data = $this->provider->provide($operation, $uriVariables, $context);
  98.         } catch (InvalidIdentifierException|InvalidUriVariableException $e) {
  99.             throw new NotFoundHttpException('Invalid identifier value or configuration.', $e);
  100.         } catch (ProviderNotFoundException $e) {
  101.             $data = null;
  102.         }
  104.         if (
  105.             null === $data
  106.             && 'POST' !== $operation->getMethod()
  107.             && (
  108.                 'PUT' !== $operation->getMethod()
  109.                 || ($operation instanceof Put && !($operation->getAllowCreate() ?? false))
  110.             )
  111.         ) {
  112.             throw new NotFoundHttpException('Not Found');
  113.         }
  115.         $request->attributes->set('data', $data);
  116.         $request->attributes->set('previous_data', $this->clone($data));
  117.     }
  118. }