Tempo real com WebSocket e Redis

1. Uma operação HTTP altera um dado e conclui a transação
2. RealtimePublisher publica um sinal de invalidação no Redis
3. O gateway Node.js recebe o sinal pelo Redis Pub/Sub
4. O gateway filtra as conexões pelo público, papel ou UUID
5. O navegador recebe o evento WebSocket
6. O frontend invalida o cache e consulta o endpoint HTTP autorizado

PHP-FPM ──publica──> Redis ──avisa──> Gateway WebSocket ──entrega──> Frontend

cd /var/www/vupi.us
php vupi setup

# Selecione:
# 32) [TEMPO REAL] Instalar Redis + WebSocket automaticamente

cd /var/www/vupi.us
php vupi setup --realtime \
  --realtime-domain=realtime.vupi.us

<?php

use Src\Kernel\Realtime\RealtimePublisher;

// Somente gerentes e funcionários conectados recebem o aviso.
RealtimePublisher::publish(
    topic: 'pedidos.created',
    roles: ['gerente', 'funcionario'],
    entityId: $pedidoUuid,
);

// Atualização exclusiva de um usuário.
RealtimePublisher::publish(
    topic: 'pedidos.status.updated',
    users: [$clienteUuid],
    entityId: $pedidoUuid,
);

// Evento público, adequado apenas a dados realmente públicos.
RealtimePublisher::publish(
    topic: 'catalogo.updated',
    public: true,
);

{
  "type": "event",
  "id": "identificador-aleatorio",
  "topic": "pedidos.status.updated",
  "entity_id": "uuid-do-pedido",
  "occurred_at": "2026-07-27T21:23:14+00:00"
}

<?php

use Src\Kernel\Realtime\RealtimeTicketService;

final class RealtimeController
{
    public function ticket(Request $request): Response
    {
        // Obtenha a identidade validada pelo middleware; nunca use valores
        // livres enviados no body para definir o usuário ou o papel.
        $usuario = $request->attribute('auth_user');
        if ($usuario === null) {
            return Response::json(['error' => 'Não autenticado.'], 401);
        }

        $dados = (new RealtimeTicketService())->issue(
            (string) $usuario->getAuthId(),
            (string) $usuario->getAuthRole(),
        );

        return Response::json($dados);
    }
}

{
  "ticket": "payload.assinatura",
  "expires_at": 1785187454,
  "websocket_url": "wss://realtime.vupi.us/realtime"
}

async function conectarRealtime() {
  const resposta = await fetch('/v1/realtime/ticket', {
    method: 'POST',
    credentials: 'include',
    headers: { 'Content-Type': 'application/json' },
    body: '{}',
  });

  if (!resposta.ok) throw new Error('Não foi possível emitir o ticket.');

  const { ticket, websocket_url: url } = await resposta.json();
  const socket = new WebSocket(url);

  socket.addEventListener('open', () => {
    socket.send(JSON.stringify({ type: 'authenticate', ticket }));
  });

  socket.addEventListener('message', async event => {
    const mensagem = JSON.parse(event.data);

    if (mensagem.type === 'ready') {
      console.info('Tempo real autenticado.');
      return;
    }

    if (mensagem.type === 'event') {
      // Invalide apenas o recurso indicado pelo tópico.
      await atualizarRecurso(mensagem.topic, mensagem.entity_id);
    }
  });

  return socket;
}

let tentativa = 0;

async function iniciarComReconexao() {
  try {
    const socket = await conectarRealtime();
    socket.addEventListener('open', () => { tentativa = 0; });
    socket.addEventListener('close', reagendar);
    socket.addEventListener('error', () => socket.close());
  } catch {
    reagendar();
  }
}

function reagendar() {
  const base = Math.min(30000, 1000 * (2 ** tentativa++));
  const atraso = base + Math.floor(Math.random() * 750);
  window.setTimeout(iniciarComReconexao, atraso);
}

# Saúde pública
curl -fsS https://realtime.vupi.us/health

# Serviços essenciais
sudo systemctl is-active nginx redis-server vupi-realtime

# Configuração habilitada
sudo grep '^REALTIME_ENABLED=' /var/www/vupi.us/.env

# Logs recentes
sudo journalctl -u vupi-realtime -n 100 --no-pager

# Logs acompanhados ao vivo
sudo journalctl -u vupi-realtime -f

[Realtime] CORS sincronizado (6 origens).
[Realtime] Redis conectado.
[Realtime] Subscriber conectado.
[Realtime] Gateway ouvindo em 127.0.0.1:8090