bug symfony#3147 [Turbo] Fix Mercure custom transport with turbo_steam_listen (Fan2Shrek)

This PR was merged into the 2.x branch.

Discussion
----------

[Turbo] Fix Mercure custom transport with `turbo_steam_listen`

Fix symfony#3128

| Q              | A
| -------------- | ---
| Bug fix?       | yes
| New feature?   | no <!-- please update src/**/CHANGELOG.md files -->
| Deprecations?  | no <!-- if yes, also update UPGRADE-*.md and src/**/CHANGELOG.md -->
| Documentation? | no <!-- required for new features, or documentation updates -->
| Issues         | Fix symfony#3128 <!-- prefix each issue number with "Fix #", no need to create an issue if none exist, explain below instead -->
| License        | MIT

This PR passes `$transport` to `$options`, allowing Mercure to successfully create authentication for the correct hub.

Commits
-------

603bab8 [Turbo] Fix mercure auth the wrong hub with turbo_steam_listen

Author: Kocal

src/Turbo/src/Twig/TurboRuntime.php

@@ -36,7 +36,11 @@ public function __construct(
      */
     public function renderTurboStreamListen(Environment $env, $topic, ?string $transport = null, array $options = []): string
     {
-        $options['transport'] = $transport ??= $this->defaultTransport;
+        if (\array_key_exists('hub', $options) && $transport !== $options['hub']) {
+            throw new \InvalidArgumentException('When passing the "transport" option, the "hub" key in options is not allowed.');
+        }
+
+        $options['hub'] = $transport ??= $this->defaultTransport;
 
         if (!$this->turboStreamListenRenderers->has($transport)) {
             throw new \InvalidArgumentException(\sprintf('The Turbo stream transport "%s" does not exist.', $transport));

src/Turbo/tests/Twig/TurboRuntimeTest.php

@@ -0,0 +1,71 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\UX\Turbo\Tests\Twig;
+
+use PHPUnit\Framework\TestCase;
+use Symfony\Contracts\Service\ServiceLocatorTrait;
+use Symfony\Contracts\Service\ServiceProviderInterface;
+use Symfony\UX\Turbo\Twig\TurboRuntime;
+use Symfony\UX\Turbo\Twig\TurboStreamListenRendererInterface;
+use Symfony\UX\Turbo\Twig\TurboStreamListenRendererWithOptionsInterface;
+use Twig\Environment;
+
+final class TurboRuntimeTest extends TestCase
+{
+    public function testRenderTurboStreamListen()
+    {
+        $twig = $this->createMock(Environment::class);
+        $renderer = $this->createMock(TurboStreamListenRendererInterface::class);
+        $renderer->expects($this->once())
+            ->method('renderTurboStreamListen')
+            ->willReturn('rendered-attributes')
+        ;
+        $container = new class(['default' => fn () => $renderer]) implements ServiceProviderInterface {
+            use ServiceLocatorTrait;
+        };
+
+        $runtime = new TurboRuntime($container, 'default');
+        $runtime->renderTurboStreamListen($twig, 'a_topic');
+    }
+
+    public function testRenderTurboStreamListenWithMultipleHubs()
+    {
+        $twig = $this->createMock(Environment::class);
+        $renderer1 = $this->createMock(TurboStreamListenRendererInterface::class);
+        $renderer2 = $this->createMock(TurboStreamListenRendererWithOptionsInterface::class);
+        $renderer2->expects($this->once())
+            ->method('renderTurboStreamListen')
+            ->with($twig, 'a_topic', ['hub' => 'hub2'])
+            ->willReturn('rendered-attributes')
+        ;
+        $container = new class(['hub1' => fn () => $renderer1, 'hub2' => fn () => $renderer2]) implements ServiceProviderInterface {
+            use ServiceLocatorTrait;
+        };
+
+        $runtime = new TurboRuntime($container, 'hub1');
+        $runtime->renderTurboStreamListen($twig, 'a_topic', 'hub2');
+    }
+
+    public function testRenderTurboStreamListenWithDifferentsHub()
+    {
+        $this->expectException(\InvalidArgumentException::class);
+
+        $twig = $this->createMock(Environment::class);
+        $renderer = $this->createMock(TurboStreamListenRendererInterface::class);
+        $container = new class(['default' => fn () => $renderer]) implements ServiceProviderInterface {
+            use ServiceLocatorTrait;
+        };
+
+        $runtime = new TurboRuntime($container, 'default');
+        $runtime->renderTurboStreamListen($twig, 'a_topic', 'default', ['hub' => 'hub3']);
+    }
+}