Add integration with symfony/ux-turbo

Author: nicolas-grekas

CHANGELOG.md

@@ -5,6 +5,7 @@ CHANGELOG
 -----
 
 * Add `mercure.publisher` tag on publisher services
+* Add integration with `symfony/ux-turbo`
 
 0.2.6
 -----

LICENSE

@@ -1,4 +1,4 @@
-Copyright (c) 2018 Kévin Dunglas
+Copyright (c) 2021 Kévin Dunglas
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

composer.json

@@ -31,7 +31,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-main": "0.3.x-dev"
+            "dev-main": "0.2.x-dev"
         }
     },
     "config": {

src/DependencyInjection/MercureExtension.php

@@ -41,6 +41,9 @@
 use Symfony\Component\Mercure\Publisher;
 use Symfony\Component\Mercure\PublisherInterface;
 use Symfony\Component\Stopwatch\Stopwatch;
+use Symfony\UX\Turbo\Bridge\Mercure\Broadcaster;
+use Symfony\UX\Turbo\Bridge\Mercure\TurboStreamListenRenderer;
+
 
 /**
  * @author Kévin Dunglas <dunglas@gmail.com>
@@ -201,6 +204,24 @@ public function load(array $configs, ContainerBuilder $container)
 
                 $traceableHubs[$name] = new Reference("$hubId.traceable");
             }
+
+            if (\PHP_VERSION_ID >= 80000 && class_exists(Broadcaster::class)) {
+                $container->register("turbo.mercure.{$name}.renderer", TurboStreamListenRenderer::class)
+                    ->addArgument(new Reference($hubId))
+                    ->addArgument(new Reference('webpack_encore.twig_stimulus_extension'))
+                    ->addArgument(new Reference('turbo.id_accessor'))
+                    ->addTag('turbo.renderer.stream_listen', ['transport' => $name]);
+
+                if ($defaultHubName === $name && 'default' !== $name) {
+                    $container->getDefinition("turbo.mercure.{$name}.renderer")
+                        ->addTag('turbo.renderer.stream_listen', ['transport' => 'default']);
+                }
+
+                $container->register("turbo.mercure.{$name}.broadcaster", Broadcaster::class)
+                    ->addArgument($name)
+                    ->addArgument(new Reference($hubId))
+                    ->addTag('turbo.broadcaster');
+            }
         }
 
         if ($enableProfiler) {