How to Register a Custom Transport

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

// src/Turbo/Broadcaster.php
namespace App\Turbo;

use Symfony\UX\Turbo\Attribute\Broadcast;
use Symfony\UX\Turbo\Broadcaster\BroadcasterInterface;

class Broadcaster implements BroadcasterInterface
{
    public function broadcast(object $entity, string $action): void
    {
        // Called every time an object marked with #[Broadcast] changes
        $attribute = (new \ReflectionClass($entity))
            ->getAttributes(Broadcast::class)[0] ?? null;
        // ...
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

// src/Turbo/MyStreamSourceRenderer.php
namespace App\Turbo;

use Symfony\Component\DependencyInjection\Attribute\AsTaggedItem;
use Symfony\UX\Turbo\StreamSourceRendererInterface;

#[AsTaggedItem(index: 'my-transport')]
class MyStreamSourceRenderer implements StreamSourceRendererInterface
{
    public function render(string|object|array $topics, array $options = []): string
    {
        $url = 'https://my-transport.example.com/subscribe?topic='.$topics;
        $private = $options['private'] ?? false;

        return \sprintf(
            '<my-custom-stream-source src="%s"%s></my-custom-stream-source>',
            htmlspecialchars($url, \ENT_QUOTES | \ENT_SUBSTITUTE, 'UTF-8'),
            $private ? ' private' : '',
        );
    }
}