WebSocket-Streaming

Echtzeit-Updates für Quoten und Opportunitäten via WebSocket unter wss://ws.sharpapi.io.

SSE vs. WebSocket

SharpAPI bietet zwei Streaming-Protokolle. Beide liefern dieselben Daten mit derselben Geschwindigkeit.

Wählen Sie SSE, wenn Sie Filter einmal setzen und einfach Daten empfangen möchten. Wählen Sie WebSocket, wenn Sie Filter dynamisch ändern müssen oder ein bidirektionales Protokoll bevorzugen.

Schnellstart

1. Verbinden

Verwenden Sie den Parameter channels, um nur die Daten zu abonnieren, die Sie benötigen:

// 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'
);

Verfügbare Kanäle: ev, arbitrage, middles, low_hold, odds. Lassen Sie channels weg, um alles zu empfangen, was Ihr Tarif unterstützt.

Verfügbare Filter: sport, sportsbook, league, market, event_id — alle kommagetrennt.

Schwellenwert-Filter: min_ev (Standard 2.0), min_profit (Standard 0.5, gilt nur für Arbitrage, nicht für Low-Hold) — filtern Sie Opportunitäten mit geringem Wert serverseitig heraus.

2. Nachrichten verarbeiten

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 +EV opportunities (Pro+)
      break;
  }
};

3. Verbindung aufrechterhalten

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

4. Kanäle und Filter aktualisieren (keine Wiederverbindung erforderlich)

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

Nachrichtenfluss

Beim Verbindungsaufbau erhalten Sie Nachrichten in folgender Reihenfolge:

1. connected — Willkommensnachricht mit Ihrem Tarif, Funktionen und aktiven Kanälen
2. subscribed — Bestätigung der aktiven Kanäle und Filter
3. opportunities_snapshot — Eine pro abonniertem Opportunitäts-Kanal (ev, arbitrage, middles, low_hold)
4. initial — Quoten-Snapshot pro Sportsbook (nur wenn der odds-Kanal abonniert ist)
5. snapshot:complete — Signalisiert, dass alle initialen Daten gesendet wurden

Danach erhalten Sie inkrementelle Updates für Ihre abonnierten Kanäle:

• odds:update — Quoten haben sich für ein Sportsbook geändert (erfordert odds-Kanal)
• odds:removed — Quoten wurden von einem Sportsbook entfernt (erfordert odds-Kanal)
• ev:detected / ev:expired — +EV-Opportunitäten (erfordert ev-Kanal)
• arb:detected / arb:expired — Arbitrage-Opportunitäten (erfordert arbitrage-Kanal)
• middles:detected / middles:expired — Middle-Opportunitäten (erfordert middles-Kanal)
• low_hold:detected / low_hold:expired — Low-Hold-Opportunitäten (erfordert low_hold-Kanal)
• heartbeat — Server-Keepalive alle 30 Sekunden

Wiederverbindung

Anders als SSE führt WebSocket keine automatische Wiederverbindung durch. Implementieren Sie ein exponentielles Backoff:

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
 
  setTimeout(() => {
    reconnectDelay = Math.min(reconnectDelay * 2, 30000);
    // Use resume + from_seq for gap-free reconnection (2-min replay buffer)
    connect({ resume: true, from_seq: lastGlobalSeq });
  }, reconnectDelay);
};

Setzen Sie reconnectDelay bei erfolgreicher Verbindung auf 1000 zurück.

Schließcodes

Vollständige API-Referenz

Die vollständige Dokumentation einschließlich aller Nachrichtenschemata, Fehlerbehandlung und mehrsprachiger Beispiele finden Sie in der WebSocket-API-Referenz.