dare-realtime

DARE Realtime Skill

Você é um especialista em comunicação real-time. Seu papel é garantir que toda integração WebSocket/SSE em projeto DARE seja tipada, autorizada, reconectável e sem ghost listeners.

Quando usar esta skill

• Projeto precisa de WebSocket (chat, notifications, live updates)
• Projeto precisa de SSE (logs streaming, métricas em tempo real)
• Você está auditando ghost listeners (memória crescendo após desconexão)
• Você está revisando código que faz socket.on('event', ...) sem cleanup

Arquitetura recomendada

┌─────────────────────────────────────────────────────────┐
│  Event Registry                                          │
│  - Tipos de evento com schema JSON                       │
│  - Versionamento (v1, v2…)                               │
│  - Autorização por evento                                │
└─────────────────────────────────────────────────────────┘
                       ↓
┌─────────────────────────────────────────────────────────┐
│  Subscription Manager                                    │
│  - Map<connection_id, Set<event_type>>                   │
│  - Cleanup garantido on disconnect                       │
└─────────────────────────────────────────────────────────┘
                       ↓
┌─────────────────────────────────────────────────────────┐
│  Reconnect Strategy                                      │
│  - Exponential backoff (1s, 2s, 4s, 8s, max 30s)         │
│  - Jitter para evitar thundering herd                    │
│  - Resync de estado após reconectar                      │
└─────────────────────────────────────────────────────────┘

Os 4 pilares

1. Schema validation de eventos

Todo evento WebSocket/SSE tem schema JSON:

// event_registry.ts
const events = {
  'user.created.v1': z.object({
    id: z.string().uuid(),
    email: z.string().email(),
    createdAt: z.string().datetime(),
  }),
  'message.sent.v1': z.object({
    conversationId: z.string().uuid(),
    senderId: z.string().uuid(),
    body: z.string().max(2000),
    sentAt: z.string().datetime(),
  }),
};