[Turbo] add options to EventSource Mercure

Author: ytilotti

src/Turbo/assets/dist/turbo_stream_controller.d.ts

@@ -3,11 +3,13 @@ export default class extends Controller {
     static values: {
         topic: StringConstructor;
         hub: StringConstructor;
+        eventSourceOptions: ObjectConstructor;
     };
     es: EventSource | undefined;
     url: string | undefined;
     readonly topicValue: string;
     readonly hubValue: string;
+    readonly eventSourceOptionsValue: object;
     readonly hasHubValue: boolean;
     readonly hasTopicValue: boolean;
     initialize(): void;

src/Turbo/assets/dist/turbo_stream_controller.js

@@ -16,7 +16,7 @@ class default_1 extends Controller {
     }
     connect() {
         if (this.url) {
-            this.es = new EventSource(this.url);
+            this.es = new EventSource(this.url, this.eventSourceOptionsValue);
             connectStreamSource(this.es);
         }
     }
@@ -30,6 +30,7 @@ class default_1 extends Controller {
 default_1.values = {
     topic: String,
     hub: String,
+    eventSourceOptions: Object,
 };
 
 export { default_1 as default };

src/Turbo/assets/src/turbo_stream_controller.ts

@@ -17,12 +17,14 @@ export default class extends Controller {
     static values = {
         topic: String,
         hub: String,
+        eventSourceOptions: Object,
     };
     es: EventSource | undefined;
     url: string | undefined;
 
     declare readonly topicValue: string;
     declare readonly hubValue: string;
+    declare readonly eventSourceOptionsValue: object;
     declare readonly hasHubValue: boolean;
     declare readonly hasTopicValue: boolean;
 
@@ -40,7 +42,7 @@ export default class extends Controller {
 
     connect() {
         if (this.url) {
-            this.es = new EventSource(this.url);
+            this.es = new EventSource(this.url, this.eventSourceOptionsValue);
             connectStreamSource(this.es);
         }
     }

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

@@ -46,7 +46,7 @@ public function __construct(HubInterface $hub, StimulusHelper|StimulusTwigExtens
         $this->stimulusHelper = $stimulus;
     }
 
-    public function renderTurboStreamListen(Environment $env, $topic): string
+    public function renderTurboStreamListen(Environment $env, $topic, array $eventSourceOptions = []): string
     {
         if (\is_object($topic)) {
             $class = $topic::class;
@@ -61,11 +61,13 @@ public function renderTurboStreamListen(Environment $env, $topic): string
             $topic = sprintf(Broadcaster::TOPIC_PATTERN, rawurlencode($topic), '{id}');
         }
 
+        $params = ['topic' => $topic, 'hub' => $this->hub->getPublicUrl()];
+        if ($eventSourceOptions) {
+            $params['eventSourceOptions'] = $eventSourceOptions;
+        }
+
         $stimulusAttributes = $this->stimulusHelper->createStimulusAttributes();
-        $stimulusAttributes->addController(
-            'symfony/ux-turbo/mercure-turbo-stream',
-            ['topic' => $topic, 'hub' => $this->hub->getPublicUrl()]
-        );
+        $stimulusAttributes->addController('symfony/ux-turbo/mercure-turbo-stream', $params);
 
         return (string) $stimulusAttributes;
     }

src/Turbo/src/Twig/TurboStreamListenRendererInterface.php

@@ -23,5 +23,5 @@ interface TurboStreamListenRendererInterface
     /**
      * @param string|object $topic
      */
-    public function renderTurboStreamListen(Environment $env, $topic): string;
+    public function renderTurboStreamListen(Environment $env, $topic, array $eventSourceOptions): string;
 }

src/Turbo/src/Twig/TwigExtension.php

@@ -38,14 +38,14 @@ public function getFunctions(): iterable
     /**
      * @param object|string $topic
      */
-    public function turboStreamListen(Environment $env, $topic, string $transport = null): string
+    public function turboStreamListen(Environment $env, $topic, string $transport = null, array $eventSourceOptions = []): string
     {
         $transport = $transport ?? $this->default;
 
         if (!$this->turboStreamListenRenderers->has($transport)) {
             throw new \InvalidArgumentException(sprintf('The Turbo stream transport "%s" doesn\'t exist.', $transport));
         }
 
-        return $this->turboStreamListenRenderers->get($transport)->renderTurboStreamListen($env, $topic);
+        return $this->turboStreamListenRenderers->get($transport)->renderTurboStreamListen($env, $topic, $eventSourceOptions);
     }
 }