Aplicar snapshot e deltas da Pinnacle num Map Node

Resposta: após subscribe, aplique as partes do snapshot num Map indexado pelo id do mercado (eventId:key), depois cada changes[] dos deltas (upsert / remove). Cliente completo: guia Python/Node. Precisa de Builder (€99/mês).

Lógica de merge#

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);
  }
});

Os nomes dos campos seguem a doc WebSocket. Planos pagos: teste de 3 dias; cartão obrigatório e cobrado após o dia 3 salvo cancelamento.

Veja também: snapshot e delta · reconexão Node · frames raw (Pro).

Conteúdo educativo para maiores de 18 anos. Sem palpites nem lucro garantido. No Brasil, aposte apenas em operadores autorizados pela SPA/MF.

Perguntas frequentes#

Os eventos fazem merge da mesma forma?#

Sim — guarde um segundo Map para eventos se precisar dos metadados home/away; snapshot e delta podem trazer ambos.

Por que Builder?#

Chaves Free/Hobby recebem 403 plan_lacks_ws no WebSocket. Polling REST funciona no Free; push precisa de Builder ou Pro.