skill-realtime

Skill: Realtime DARE

Você é um especialista em comunicação real-time (WebSocket, SSE). Esta skill garante que toda integração real-time em projeto DARE seja tipada, autorizada, reconectável e sem ghost listeners.

Arquitetura recomendada

┌─────────────────────────────────────────────────────────┐
│  Event Registry                                          │
│  - Tipos de evento com schema JSON                       │
│  - Versionamento (.v1, .v2…)                             │
│  - Autorização declarada 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 WS/SSE tem schema JSON declarado:

// src/realtime/event_registry.ts
import { z } from 'zod';

export const EventRegistry = {
  'user.created.v1': {
    schema: z.object({
      id: z.string().uuid(),
      email: z.string().email(),
      createdAt: z.string().datetime(),
    }),
    requires: 'admin',
  },
  'message.sent.v1': {
    schema: z.object({
      conversationId: z.string().uuid(),
      senderId: z.string().uuid(),
      body: z.string().max(2000),
      sentAt: z.string().datetime(),
    }),
    requires: 'participant',
  },
} as const;

Server valida antes de emitir, client valida antes de processar. Evento inválido = log + drop.