Streaming WebSocket

Actualizaciones de cuotas y oportunidades en tiempo real mediante WebSocket en wss://ws.sharpapi.io.

SSE frente a WebSocketPermalink for this section

SharpAPI ofrece dos protocolos de streaming. Ambos entregan los mismos datos a la misma velocidad.

Elige SSE si configuras los filtros una vez y solo quieres que los datos fluyan. Elige WebSocket si necesitas cambiar los filtros sobre la marcha o prefieres un protocolo bidireccional.

Inicio rápidoPermalink for this section

1. ConectarPermalink for this section

Usa el parámetro channels para suscribirte únicamente a los datos que necesites:

// Only EV opportunities + odds — no middles, low_hold, or arbitrage
const ws = new WebSocket(
  'wss://ws.sharpapi.io?api_key=YOUR_KEY&channels=ev,odds&sport=basketball&sportsbook=draftkings&league=nba'
);

Canales disponibles: ev, arbitrage, middles, low_hold, odds. Omite channels para recibir todo lo que admita tu nivel de suscripción.

Filtros disponibles: sport, sportsbook, league, market, event_id — todos separados por comas.

Filtros de umbral: min_ev (predeterminado 2.0), min_profit (predeterminado 0.5, se aplica solo a arbitrage, no a low-hold) — descartan oportunidades de bajo valor en el lado del servidor.

2. Gestionar mensajesPermalink for this section

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
 
  switch (msg.type) {
    case 'connected':
      console.log(msg.message);                     // "Welcome to SharpAPI real-time odds stream"
      break;
    case 'opportunities_snapshot':
      if (msg.ev) console.log('EV:', msg.ev);       // EV opportunity snapshot
      break;
    case 'initial':
      console.log('Odds:', msg.data);                // Per-sportsbook odds snapshot
      break;
    case 'snapshot:complete':
      console.log('All initial data loaded');        // Safe to hide loading state
      break;
    case 'odds:update':
      console.log(msg.source, msg.data);             // Incremental odds update
      break;
    case 'ev:detected':
      console.log('+EV:', msg.data);                 // New or updated +EV opportunities (Pro+) — upsert by id
      break;
  }
};

3. Mantener viva la conexiónPermalink for this section

setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(JSON.stringify({ type: 'ping' }));
  }
}, 25000);

4. Actualizar canales y filtros (sin reconectar)Permalink for this section

ws.send(JSON.stringify({
  type: 'subscribe',
  channels: ['low_hold'],
  filters: { sports: ['football'], sportsbooks: ['fanduel', 'betmgm'], leagues: ['nfl'] }
}));

Flujo de mensajesPermalink for this section

Al conectarte recibes los mensajes en este orden:

1. connected — Mensaje de bienvenida con tu nivel de suscripción, características y canales activos
2. subscribed — Confirmación de los canales y filtros activos
3. opportunities_snapshot — Uno por cada canal de oportunidades suscrito (ev, arbitrage, middles, low_hold)
4. initial — Snapshot de cuotas por sportsbook (solo si está suscrito el canal odds)
5. snapshot:complete — Indica que se han enviado todos los datos iniciales

A partir de ahí, recibes actualizaciones incrementales de los canales suscritos:

• odds:update — Han cambiado las cuotas de un sportsbook (requiere el canal odds)
• odds:removed — Un sportsbook ha retirado cuotas (requiere el canal odds)
• ev:detected / ev:expired — Oportunidades de +EV (requiere el canal ev)
• arb:detected / arb:expired — Oportunidades de arbitraje (requiere el canal arbitrage)
• middles:detected / middles:expired — Oportunidades de middle (requiere el canal middles)
• low_hold:detected / low_hold:expired — Oportunidades de low-hold (requiere el canal low_hold)
• heartbeat — Keepalive del servidor cada 30 segundos

ReconexiónPermalink for this section

A diferencia de SSE, WebSocket no se reconecta automáticamente. Implementa un backoff exponencial:

let reconnectDelay = 1000;
let lastGlobalSeq = 0;
 
ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === 'connected') lastGlobalSeq = msg.global_seq;
  if (msg.global_seq) lastGlobalSeq = msg.global_seq;
};
 
ws.onclose = (event) => {
  if (event.code === 1000) return; // intentional close
  if (event.code === 4001 && event.reason.includes('displaced')) return; // newer session owns the slot
 
  setTimeout(() => {
    reconnectDelay = Math.min(reconnectDelay * 2, 30000);
    // Pass from_seq to attempt a resume (best-effort, ~5-min replay window).
    // If the server can't resume it falls back to a full snapshot and says so.
    connect({ from_seq: lastGlobalSeq });
  }, reconnectDelay);
};

Restablece reconnectDelay a 1000 cuando la conexión sea correcta.

Códigos de cierrePermalink for this section

Referencia completa de la APIPermalink for this section

Para acceder a la documentación completa, incluidos todos los esquemas de mensajes, la gestión de errores y los ejemplos en varios lenguajes, consulta la Referencia de la API WebSocket.