Use mercure extension for creating the cookie

Author: Fan2Shrek

src/Turbo/src/Bridge/Mercure/TurboStreamListenRenderer.php

@@ -14,6 +14,7 @@
 use Symfony\Component\HttpFoundation\RequestStack;
 use Symfony\Component\Mercure\Authorization;
 use Symfony\Component\Mercure\HubInterface;
+use Symfony\Component\Mercure\Twig\MercureExtension;
 use Symfony\UX\StimulusBundle\Helper\StimulusHelper;
 use Symfony\UX\Turbo\Broadcaster\IdAccessor;
 use Symfony\UX\Turbo\Twig\TurboStreamListenRendererWithOptionsInterface;
@@ -33,8 +34,7 @@ public function __construct(
         private HubInterface $hub,
         StimulusHelper|StimulusTwigExtension $stimulus,
         private IdAccessor $idAccessor,
-        private ?Authorization $authorization = null,
-        private ?RequestStack $requestStack = null,
+        private Environment $twig,
     ) {
         if ($stimulus instanceof StimulusTwigExtension) {
             trigger_deprecation('symfony/ux-turbo', '2.9', 'Passing an instance of "%s" as second argument of "%s" is deprecated, pass an instance of "%s" instead.', StimulusTwigExtension::class, __CLASS__, StimulusHelper::class);
@@ -64,21 +64,8 @@ public function renderTurboStreamListen(Environment $env, $topic /* array $event
         }
 
         if (isset($eventSourceOptions)) {
-            if (
-                null !== $this->authorization
-                && null !== $this->requestStack
-                && (isset($eventSourceOptions['subscribe']) || isset($eventSourceOptions['publish']) || isset($eventSourceOptions['additionalClaims']))
-                && null !== $request = $this->requestStack->getMainRequest()
-            ) {
-                $this->authorization->setCookie(
-                    $request,
-                    $eventSourceOptions['subscribe'] ?? [],
-                    $eventSourceOptions['publish'] ?? [],
-                    $eventSourceOptions['additionalClaims'] ?? [],
-                    $eventSourceOptions['transport'] ?? null,
-                );
-
-                unset($eventSourceOptions['subscribe'], $eventSourceOptions['publish'], $eventSourceOptions['additionalClaims'], $eventSourceOptions['transport']);
+            if ($mercure = $this->twig->getExtension(MercureExtension::class)) {
+                $mercure->mercure($topic, $eventSourceOptions);
             }
 
             if (isset($eventSourceOptions['withCredentials'])) {