vendor/symfony/ux-turbo/Stream/AddTurboStreamFormatSubscriber.php line 42

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.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. namespace Symfony\UX\Turbo\Stream;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpKernel\Event\RequestEvent;
  16. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  19. /**
  20.  * Detects if it's a Turbo Stream request and sets the format accordingly.
  21.  *
  22.  * @author Kévin Dunglas <kevin@dunglas.fr>
  23.  *
  24.  * @experimental
  25.  */
  26. final class AddTurboStreamFormatSubscriber implements EventSubscriberInterface
  27. {
  28.     public function onKernelRequest(RequestEvent $event): void
  29.     {
  30.         $request = $event->getRequest();
  31.         if (!($accept = $request->headers->get('Accept')) || 0 !== strpos($accept, TurboStreamResponse::STREAM_MEDIA_TYPE)) {
  32.             return;
  33.         }
  35.         $request->setFormat(TurboStreamResponse::STREAM_FORMAT, TurboStreamResponse::STREAM_MEDIA_TYPE);
  36.         $request->setRequestFormat(TurboStreamResponse::STREAM_FORMAT);
  37.     }
  39.     /**
  40.      * Prevents issues with Turbo Frames when sending a response that isn't in the Turbo Stream format.
  41.      */
  42.     public function onKernelResponse(ResponseEvent $event): void
  43.     {
  44.         $response = $event->getResponse();
  45.         if ($response instanceof TurboStreamResponse) {
  46.             return;
  47.         }
  49.         $request = $event->getRequest();
  50.         if (TurboStreamResponse::STREAM_FORMAT === $request->getRequestFormat(null)) {
  51.             $request->setRequestFormat(null);
  52.         }
  53.     }
  55.     /**
  56.      * Executed before AddRequestFormatsListener and ResponseListener.
  57.      *
  58.      * @return array<string, array>
  59.      */
  60.     public static function getSubscribedEvents(): array
  61.     {
  62.         return [
  63.             KernelEvents::REQUEST => ['onKernelRequest', 110],
  64.             KernelEvents::RESPONSE => ['onKernelResponse', 10],
  65.         ];
  66.     }
  67. }