Aplicar snapshot y deltas de Pinnacle en un Map de Node

Respuesta: tras subscribe, aplica las partes del snapshot en un Map indexado por id de mercado (eventId:key), luego cada changes[] de los deltas (upsert / remove). Cliente completo: guía Python/Node. Requiere Builder (€99/mes).

Lógica de fusión#

import WebSocket from "ws";

const markets = new Map(); // id -> market object
const KEY = process.env.PINNFEED_KEY;

function applyChange(ch) {
  if (ch.op === "upsert" || ch.type === "upsert") {
    const m = ch.market || ch.value;
    markets.set(m.id, m);
  } else if (ch.op === "remove" || ch.type === "remove") {
    markets.delete(ch.id || ch.marketId);
  }
}

const ws = new WebSocket("wss://pinnfeed.io/v1/stream", {
  headers: { "x-api-key": KEY },
  perMessageDeflate: true,
});

ws.on("open", () => {
  ws.send(JSON.stringify({
    type: "subscribe",
    sports: ["soccer"],
    markets: ["moneyline"],
    main: true,
  }));
});

ws.on("message", (buf) => {
  const msg = JSON.parse(buf.toString());
  if (msg.type === "ping") return ws.send(JSON.stringify({ type: "pong" }));
  if (msg.type === "snapshot" || msg.part != null) {
    for (const m of msg.markets || []) markets.set(m.id, m);
  }
  if (msg.type === "delta" && Array.isArray(msg.changes)) {
    for (const ch of msg.changes) applyChange(ch);
  }
});

Los nombres de campo siguen la doc WebSocket. Planes de pago: prueba de 3 días; se requiere tarjeta y se cobra tras el día 3 salvo que canceles.

Ver también: snapshot y delta · reconexión Node · frames raw (Pro).

Contenido educativo para mayores de 18 años. Sin pronósticos ni ganancias garantizadas. En España, apuesta solo con operadores con licencia de la DGOJ.

Preguntas frecuentes#

¿Los eventos se fusionan igual?#

Sí — guarda un segundo Map para eventos si necesitas metadatos home/away; snapshot y delta pueden llevar ambos.

¿Por qué Builder?#

Las claves Free/Hobby reciben 403 plan_lacks_ws en el WebSocket. El polling REST funciona en Free; el push necesita Builder o Pro.