Mercure – Real-time push avec Symfony

services:
    mercure:
        image: dunglas/mercure
        restart: unless-stopped
        environment:
            SERVER_NAME: 'mercure, :80'
            MERCURE_PUBLISHER_JWT_KEY: ${MERCURE_JWT_SECRET}
            MERCURE_SUBSCRIBER_JWT_KEY: ${MERCURE_JWT_SECRET}
        volumes:
            - mercure_data:/data

    php:
        environment:
            MERCURE_URL: http://mercure/.well-known/mercure # interne réseau Docker
            MERCURE_PUBLIC_URL: https://localhost/.well-known/mercure # navigateur → Hub
            MERCURE_JWT_SECRET: ${MERCURE_JWT_SECRET}

use Symfony\Component\Mercure\HubInterface;
use Symfony\Component\Mercure\Update;

class StockController extends AbstractController
{
    public function update(HubInterface $hub): Response 
    {
        $update = new Update(
            'https://example.com/products/42', // topic (IRI)
            json_encode([
                'stock' => 0,
                'message' => 'Rupture de stock',
            ])
        );
        
        $hub->publish($update); // POST vers le Hub
        
         return new Response('OK');
    }
}

$update = new Update(
    topic: 'https://example.com/orders/99',
    data: json_encode(['status' => 'expédié']),
    private: true // seuls les abonnés autorisés reçoivent
);

{# templates/product/show.html.twig #}
<script>
const es = new EventSource(
    "{{ mercure('https://example.com/products/42') |escape('js') }}"
);

es.onmessage = (event) => {
    const data = JSON.parse(event.data);
    document.getElementById('stock').textContent = data.stock;
};
</script>

const es = new EventSource("{{ mercure([
    'https://example.com/products/42',
    'https://example.com/notifications/user/{{ app.user.id }}'
]) |escape('js') }}");

use Symfony\Component\Messenger\MessageBusInterface;

class OrderService
{
    public function ship(Order $order): void
    {
        // ... logique métier ...
    
        // Envoi délégué à un worker (Redis/RabbitMQ/Doctrine)
        $this->bus->dispatch(new Update(
            'https://example.com/orders/' . $order->getId(),
            json_encode(['status' => 'expédié'])
        ));
    }
}