WebSocket

wss://ws.wovepay.com/v1

{ "event": "authenticated", "version": "1" }

{ "action": "subscribe", "pattern": "payment.*" }

{ "event": "subscribed", "pattern": "payment.*" }

{ "action": "subscribe", "paymentId": "clx_transacao" }

{ "action": "unsubscribe", "pattern": "payment.*" }
{ "action": "unsubscribe", "paymentId": "clx_transacao" }

{ "event": "unsubscribed", "pattern": "payment.*" }

{
  "id": "wsevt_abc123",
  "event": "payment.paid",
  "createdAt": "2026-07-31T10:00:00.000Z",
  "data": {
    "id": "clx_transacao",
    "type": "PIX_IN",
    "status": "COMPLETED",
    "amount": 1500,
    "feeAmount": 7.5,
    "netAmount": 1492.5,
    "currency": "BRL",
    "externalReference": "pedido-123",
    "referenceId": "ref_pix_abc",
    "endToEndId": "E12345678202505301234567890123456",
    "payer": {
      "name": "João da Silva",
      "document": "12345678909"
    },
    "completedAt": "2026-07-31T10:00:00.000Z",
    "createdAt": "2026-07-31T09:55:00.000Z"
  }
}

{ "action": "ack", "id": "wsevt_abc123" }

const seen = new Set<string>();

function onEvent(msg: { id: string; event: string; data: unknown }) {
  if (msg.event === "ping") {
    ws.send(JSON.stringify({ action: "ping" }));
    return;
  }
  if (!msg.id || seen.has(msg.id)) return;
  seen.add(msg.id);

  void processEvent(msg).then(() => {
    ws.send(JSON.stringify({ action: "ack", id: msg.id }));
  });
}

{ "event": "error", "code": "INVALID_API_KEY" }

{
  "id": "wsevt_001",
  "event": "payment.created",
  "createdAt": "2026-05-24T11:55:00.000Z",
  "data": {
    "id": "clx_transacao",
    "type": "PIX_IN",
    "status": "PENDING",
    "amount": 100,
    "feeAmount": 0.5,
    "netAmount": 99.5,
    "currency": "BRL",
    "externalReference": "pedido-123",
    "referenceId": "ref_pix_abc",
    "copyPaste": "00020101021226820014br.gov.bcb.pix...",
    "qrCodeBase64": "data:image/png;base64,iVBORw0KGgo...",
    "expiresAt": "2026-05-25T11:55:00.000Z",
    "createdAt": "2026-05-24T11:55:00.000Z"
  }
}

{
  "id": "wsevt_inv",
  "event": "invoice.issued",
  "createdAt": "2026-06-02T15:01:00.000Z",
  "data": {
    "invoiceId": "clx_invoice"
  }
}

import WebSocket from "ws";

const API_KEY = process.env.WovePay_API_KEY;
const WS_URL = "wss://ws.wovepay.com/v1";

const seen = new Set();
let backoffMs = 1000;
let ws;

function connect() {
  ws = new WebSocket(WS_URL, {
    headers: { Authorization: `Bearer ${API_KEY}` },
  });

  ws.on("open", () => {
    backoffMs = 1000;
    ws.send(JSON.stringify({ action: "subscribe", pattern: "payment.*" }));
    ws.send(JSON.stringify({ action: "subscribe", pattern: "transfer.*" }));
  });

  ws.on("message", (raw) => {
    const msg = JSON.parse(String(raw));

    if (msg.event === "ping") {
      ws.send(JSON.stringify({ action: "ping" }));
      return;
    }

    if (msg.event === "authenticated" || msg.event === "subscribed") {
      console.log(msg.event, msg);
      return;
    }

    if (msg.event === "error") {
      console.error("WS error:", msg.code);
      return;
    }

    if (!msg.id || seen.has(msg.id)) return;
    seen.add(msg.id);

    console.log(msg.event, msg.data?.id ?? msg.data);
    ws.send(JSON.stringify({ action: "ack", id: msg.id }));
  });

  ws.on("close", () => {
    setTimeout(connect, backoffMs);
    backoffMs = Math.min(backoffMs * 2, 30_000);
  });

  ws.on("error", (err) => console.error("WS socket error:", err.message));
}

connect();

import asyncio
import json
import os
import websockets

API_KEY = os.environ["WovePay_API_KEY"]
WS_URL = f"wss://ws.wovepay.com/v1?token={API_KEY}"
seen = set()

async def run():
    backoff = 1
    while True:
        try:
            async with websockets.connect(WS_URL) as ws:
                backoff = 1
                await ws.send(json.dumps({"action": "subscribe", "pattern": "payment.*"}))

                async for raw in ws:
                    msg = json.loads(raw)
                    event = msg.get("event")

                    if event == "ping":
                        await ws.send(json.dumps({"action": "ping"}))
                        continue

                    if event in ("authenticated", "subscribed"):
                        print(event, msg)
                        continue

                    if event == "error":
                        print("WS error:", msg.get("code"))
                        continue

                    delivery_id = msg.get("id")
                    if not delivery_id or delivery_id in seen:
                        continue
                    seen.add(delivery_id)

                    print(event, msg.get("data"))
                    await ws.send(json.dumps({"action": "ack", "id": delivery_id}))

        except Exception as exc:
            print("reconnecting:", exc)
            await asyncio.sleep(backoff)
            backoff = min(backoff * 2, 30)

asyncio.run(run())