WebSocket de eventos

ws://localhost:8084/ws/instance/events?event=connection.update&token=<INSTANCE_JWT>
ws://localhost:8084/ws/global/events?event=message.batch.progress&token=<USER_JWT>

wss://api.example.com/ws/instance/events
wss://api.example.com/ws/global/events

{
  "event": "connection.update",
  "instance": {"id": 1, "name": "minha-instancia", "connectionStatus": "online", "ownerJid": "[email protected]", "externalAttributes": {}},
  "data": {"type": "connected", "connection": "open"},
  "timestamp": "2026-07-14T12:00:00Z"
}

{
  "event": "messages.upsert",
  "instance": {"id": 1, "name": "minha-instancia", "connectionStatus": "online", "ownerJid": "[email protected]", "externalAttributes": {}},
  "data": {
    "id": 1001,
    "keyRemoteJid": "[email protected]",
    "keyLid": null,
    "keyFromMe": false,
    "keyParticipant": null,
    "keyParticipantLid": null,
    "pushName": "Contato",
    "messageType": "text",
    "content": {"text": "Ola"},
    "messageTimestamp": 1784040000,
    "device": "web",
    "isGroup": false,
    "metadata": {}
  },
  "timestamp": "2026-07-14T12:00:00Z"
}

{
  "event": "qrcode.updated",
  "instance": {"id": 1, "name": "minha-instancia", "connectionStatus": "qr_code", "ownerJid": null, "externalAttributes": {}},
  "data": {"count": 1, "code": "2@codigo-ficticio", "base64": "data:image/png;base64,iVBORw0KGgoAAA...", "expiresInSeconds": 30, "expiresAt": "2026-07-14T12:00:30Z"},
  "timestamp": "2026-07-14T12:00:00Z"
}

{
  "event": "message.batch.progress",
  "timestamp": "2026-07-14T12:00:00Z",
  "data": {
    "batch": {
      "id": "019f6086-ce48-7ba3-83ca-02c15405d570",
      "ownerUserId": "11111111-1111-4111-8111-111111111111",
      "name": "campanha",
      "status": "PROCESSING",
      "instances": [{"id": 1, "name": "minha-instancia", "connectionStatus": "online"}],
      "counts": {"total": 10, "processed": 5, "pending": 5, "sending": 0, "success": 5, "failed": 0, "skipped": 0, "unknown": 0},
      "progress": 50,
      "createdAt": "2026-07-14T11:59:00Z",
      "updatedAt": "2026-07-14T12:00:00Z",
      "currentItem": {"id": "019f6087-0000-7000-8000-000000000001", "position": 4, "recipient": "5511888888888", "instanceName": "minha-instancia"}
    }
  }
}

{
  "event": "message.batch.completed",
  "timestamp": "2026-07-14T12:05:00Z",
  "data": {
    "batch": {
      "id": "019f6086-ce48-7ba3-83ca-02c15405d570",
      "ownerUserId": "11111111-1111-4111-8111-111111111111",
      "name": "campanha",
      "status": "COMPLETED",
      "instances": [{"id": 1, "name": "minha-instancia", "connectionStatus": "online"}],
      "counts": {"total": 10, "processed": 10, "pending": 0, "sending": 0, "success": 10, "failed": 0, "skipped": 0, "unknown": 0},
      "progress": 100,
      "completedAt": "2026-07-14T12:05:00Z",
      "createdAt": "2026-07-14T11:59:00Z",
      "updatedAt": "2026-07-14T12:05:00Z"
    }
  }
}

{
  "event": "message.batch.item.failed",
  "timestamp": "2026-07-14T12:03:00Z",
  "data": {
    "batchId": "019f6086-ce48-7ba3-83ca-02c15405d570",
    "itemId": "019f6087-0000-7000-8000-000000000009",
    "recipient": "5511777777777",
    "error": {"code": "SEND_MESSAGE_FAILED", "message": "Falha ao enviar a mensagem."},
    "instance": {"id": 1, "name": "minha-instancia"}
  }
}

function createSocketClient({ url, token, reconnectInterval = 5000 }) {
  return function socket(eventName, callback) {
    let ws = null;
    let reconnectTimer = null;
    let stopped = false;

    function connect() {
      const query = new URLSearchParams({ event: eventName, token });
      ws = new WebSocket(`${url}?${query.toString()}`);
      ws.onmessage = (messageEvent) => callback?.(JSON.parse(messageEvent.data), messageEvent);
      ws.onclose = () => {
        if (!stopped) reconnectTimer = setTimeout(connect, reconnectInterval);
      };
    }

    connect();

    return {
      close(code = 1000, reason = "Client closed connection") {
        stopped = true;
        if (reconnectTimer) clearTimeout(reconnectTimer);
        if (ws && (ws.readyState === WebSocket.OPEN || ws.readyState === WebSocket.CONNECTING)) ws.close(code, reason);
      },
      get connection() {
        return ws;
      }
    };
  };
}

const instanceSocket = createSocketClient({url: "ws://localhost:8084/ws/instance/events", token: "jwt-da-instancia"});
const connectionSubscription = instanceSocket("connection.update", (data) => console.log("connection.update", data));
const messagesSubscription = instanceSocket("messages.upsert", (data) => console.log("messages.upsert", data));
const qrcodeSubscription = instanceSocket("qrcode.updated", (data) => console.log("qrcode.updated", data));

const globalSocket = createSocketClient({url: "ws://localhost:8084/ws/global/events", token: "jwt-do-usuario"});
const progressSubscription = globalSocket("message.batch.progress", (data) => console.log("message.batch.progress", data));
const completedSubscription = globalSocket("message.batch.completed", (data) => console.log("message.batch.completed", data));
const failedItemSubscription = globalSocket("message.batch.item.failed", (data) => console.log("message.batch.item.failed", data));