Mercure em tempo real

O Doggy implementa push em tempo real no servidor baseado no protocolo Mercure. O Mercure Hub está integrado no FrankenPHP e fica ativo apenas configurando o Caddyfile, sem necessidade de contentores ou serviços adicionais.

Arquitetura

Cliente (EventSource)
    ↑ SSE
    └── http://localhost:8000/.well-known/mercure
            ↑
    Caddyfile (FrankenPHP)
        ↑ Hub embutido na diretiva mercure
    FrankenPHP (Hub integrado)

Configuração do Caddyfile

O Mercure Hub está incorporado no Caddyfile do FrankenPHP:

http://localhost:8000 {
    route /.well-known/mercure {
        mercure {
            transport bolt {
                path /var/www/var/mercure.db
            }
            publisher_jwt !ChangeThisMercureHubJWTSecretKey!
            subscriber_jwt !ChangeThisMercureHubJWTSecretKey!
            cors_origins http://localhost:8000
            publish_origins *
            anonymous
        }
    }
}

Token JWT

MercureTokenFactory gera um JWT com permissões de subscrição:

// src/Security/MercureTokenFactory.php
$token = $factory->createSubscribeToken(
    topics: ['/user/123/*', '/entity/*'],
    roles: ['ROLE_USER'],
    expiresIn: 3600
);

Cookie Mercure

MercureCookieSubscriber injeta o cookie mercureAuthorization em cada resposta:

// Tópicos de subscrição gerados automaticamente
$topics = [
    'https://enterprise.local/user/' . $userId . '/export',
    '/user/' . $userId . '/*',
    '/entity/*',
];

Subscrição no frontend

const url = new URL('/.well-known/mercure', window.location.origin);
url.searchParams.append('topic', '/user/' + userId + '/*');
const eventSource = new EventSource(url);
eventSource.onmessage = (event) => {
    const data = JSON.parse(event.data);
    // Processar a mensagem push
};

Aplicações principais

• Progresso de exportação: push de progresso em tempo real na exportação de ficheiros grandes
• Estado online: PresenceService + PresenceApiController
• Notificações em tempo real: mensagens de sistema, lembretes de aprovação
• Sincronização de dados: atualização em tempo real na colaboração de múltiplos utilizadores