vendor/can/rest/src/Can/RestBundle/EventListener/FetchListener.php line 51

Open in your IDE?
  1. <?php
  3. namespace Can\RestBundle\EventListener;
  5. use Can\RestBundle\CanRestBundle;
  6. use Can\RestBundle\Fetch\Fetch;
  7. use Can\RestBundle\Fetch\FetchConfiguration;
  8. use Can\RestBundle\Fetch\FetchHandlerInterface;
  9. use Can\RestBundle\Fetch\FetchHeader;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\HttpKernel\Event\RequestEvent;
  15. /**
  16.  * Manages fetch headers.
  17.  *
  18.  * @group fetch
  19.  *
  20.  * @package can/rest-bundle
  21.  * @author lechecacharro <lechecacharro@gmail.com>
  22.  */
  23. class FetchListener
  24. {
  26.     /**
  27.      * @var FetchConfiguration
  28.      */
  29.     private $configuration;
  31.     /**
  32.      * @var FetchHandlerInterface
  33.      */
  34.     private $handler;
  36.     /**
  37.      * FetchListener constructor.
  38.      *
  39.      * @param FetchConfiguration    $configuration
  40.      * @param FetchHandlerInterface $handler
  41.      */
  42.     public function __construct(FetchConfiguration $configuration, FetchHandlerInterface $handler)
  43.     {
  44.         $this->configuration = $configuration;
  45.         $this->handler = $handler;
  46.     }
  48.     /**
  49.      * @param RequestEvent $event
  50.      */
  51.     public function onRequest(RequestEvent $event): void
  52.     {
  53.         if (! $this->configuration->isEnabled()) {
  54.             return;
  55.         }
  57.         $request = $event->getRequest();
  59.         if (! $request->attributes->get(CanRestBundle::ATTR_SERVICE_ZONE)) {
  60.             return;
  61.         }
  63.         $fetch = new Fetch(
  64.             $this->getRequestHeader($request, FetchHeader::SEC_FETCH_DEST),
  65.             $this->getRequestHeader($request, FetchHeader::SEC_FETCH_MODE),
  66.             $this->getRequestHeader($request, FetchHeader::SEC_FETCH_SITE),
  67.             strtolower($this->getRequestHeader($request, FetchHeader::SEC_FETCH_USER)) === 'true'
  68.         );
  70.         $request->attributes->set(CanRestBundle::ATTR_FETCH, $fetch);
  72.         if ($fetch->isEmpty()) {
  73.             return;
  74.         }
  76.         $fetchApproved = $this->handler->handle($request, $fetch);
  78.         if (! $fetchApproved) {
  79.             // Reject the request returning an error response, using
  80.             // the HTTP status code specified by the fetchErrorStatus
  81.             // configuration option (a client error)
  82.             $event->setResponse(new Response('', $this->configuration->getFetchErrorStatus()));
  83.         }
  85.         $request->attributes->set(CanRestBundle::ATTR_FETCH_APPROVED, $fetchApproved);
  86.     }
  89.     /**
  90.      * @param Request $request
  91.      * @param string  $header
  92.      *
  93.      * @return string
  94.      */
  95.     protected function getRequestHeader(Request $request, string $header): string
  96.     {
  97.         $value = $request->headers->get($header);
  99.         if (is_array($value)) {
  100.             $value = $value[0];
  101.         }
  103.         return strval($value);
  104.     }
  106. }