README

Mercure Transport Layer for JSON-RPC Додає підтримку кросдоменних подій між сервісами через Mercure Hub.

🧬 Ідея

rpc-mercure-transport — це розширення для rpc-bundle, яке дозволяє публікувати події з RPC-сервера у Mercure Hub і отримувати їх іншими сервісами, що підписані на відповідні topics.

Це дає можливість побудови асинхронної подієвої взаємодії між мікросервісами, без потреби в RabbitMQ чи інших брокерах.

⚙️ Встановлення

composer require ufo-tech/rpc-mercure-transport

🔧 Конфігурація

config/packages/rpc_mercure_transport.yaml:

rpc_mercure_transport:
  hub_url: '%env(MERCURE_PUBLISH_URL)%'
  jwt_provider: 'App\Security\MercureJwtProvider'
  topics_prefix: 'rpc.events.'

🚀 Використання

Коли у RPC-сервісі dsl,e подія (через EventDispatcher), транспорт автоматично публікує її у Mercure Hub:

$this->dispatcher->dispatch(new ProductCreatedEvent($productId));

→ на боці Mercure ця подія піде в topic rpc.events.product.created.

інші сервіси, що підписані на цей topic, миттєво отримають повідомлення через SSE.

📡 Приклад підписки

const url = new URL('https://mercure.example.com/.well-known/mercure');
url.searchParams.append('topic', 'rpc.events.product.*');

const eventSource = new EventSource(url, { withCredentials: true });

eventSource.onmessage = e => {
    const event = JSON.parse(e.data);
    console.log('Event received:', event);
};

🧠 Основна ідея

кожен RPC-сервіс має власні події (domain events)
rpc-mercure-transport транслює їх у Mercure Hub
інші сервіси можуть реагувати на них без прямої залежності

Синхронні виклики → через RPC Асинхронні нотифікації → через Mercure

ufo-tech / rpc-mercure-transport

Maintainers

Details