Streaming-Übersicht

Client                           Server
  |                                |
  |--- GET /api/v1/stream ------->|
  |                                |
  |<-- event: connected ----------|  Stream established
  |<-- event: snapshot -----------|  Full current state
  |<-- event: odds:update --------|  Delta update
  |<-- event: odds:update --------|  Delta update
  |<-- event: ev:detected --------|  Opportunity found
  |<-- event: heartbeat ----------|  Keep-alive (every 30s)
  |         ...                    |

// Local odds map — snapshot fills it, deltas merge into it
const oddsMap = new Map();
 
const eventSource = new EventSource(
  'https://api.sharpapi.io/api/v1/stream?channel=all&league=nba&api_key=YOUR_KEY'
);
 
eventSource.addEventListener('connected', (e) => {
  const { stream_id, reconnected } = JSON.parse(e.data);
  if (reconnected) oddsMap.clear();
  console.log('Stream connected:', stream_id);
});
 
eventSource.addEventListener('snapshot', (e) => {
  const { odds } = JSON.parse(e.data);
  for (const odd of odds) oddsMap.set(odd.id, odd);
  console.log('Snapshot chunk:', odds.length, 'odds');
});
 
eventSource.addEventListener('odds:update', (e) => {
  const { odds, book } = JSON.parse(e.data);
  // Delta only contains dynamic fields — merge into local state by ID
  for (const delta of odds) {
    const full = oddsMap.get(delta.id);
    if (full) Object.assign(full, delta);
  }
  console.log(`${book}: ${odds.length} odds updated`);
});
 
eventSource.addEventListener('ev:detected', (e) => {
  const opps = JSON.parse(e.data);
  opps.forEach(opp => console.log(`+EV: ${opp.selection} at ${opp.ev_percentage}% EV`));
});
 
eventSource.addEventListener('heartbeat', () => {
  console.log('Connection alive');
});
 
eventSource.onerror = () => {
  console.log('Connection lost, auto-reconnecting...');
};

import EventSource from 'eventsource';
 
const oddsMap = new Map();
 
const es = new EventSource(
  'https://api.sharpapi.io/api/v1/stream?channel=odds&league=nba',
  { headers: { 'X-API-Key': 'YOUR_KEY' } }
);
 
es.addEventListener('snapshot', (e) => {
  const { odds } = JSON.parse(e.data);
  for (const odd of odds) oddsMap.set(odd.id, odd);
  console.log(`Received ${odds.length} initial odds`);
});
 
es.addEventListener('odds:update', (e) => {
  const { odds, book } = JSON.parse(e.data);
  // Merge compact deltas into local state
  for (const delta of odds) {
    const full = oddsMap.get(delta.id);
    if (full) Object.assign(full, delta);
  }
  console.log(`${book}: ${odds.length} odds updated`);
});

import sseclient
import requests
import json
 
url = 'https://api.sharpapi.io/api/v1/stream'
params = {'channel': 'all', 'league': 'nba'}
headers = {'X-API-Key': 'YOUR_KEY'}
 
odds_map: dict[str, dict] = {}
 
response = requests.get(url, params=params, headers=headers, stream=True)
client = sseclient.SSEClient(response)
 
for event in client.events():
    data = json.loads(event.data) if event.data else {}
 
    if event.event == 'connected':
        if data.get('reconnected'):
            odds_map.clear()
        print(f"Stream {data['stream_id']} connected")
    elif event.event == 'snapshot':
        for odd in data.get('odds', []):
            odds_map[odd['id']] = odd
        print(f"Snapshot: {data['count']} odds")
    elif event.event == 'odds:update':
        # Delta only has dynamic fields — merge by ID
        for delta in data.get('odds', []):
            existing = odds_map.get(delta['id'])
            if existing:
                existing.update(delta)
        print(f"{data['book']}: {data['count']} odds updated")
    elif event.event == 'ev:detected':
        for opp in data:
            print(f"+EV: {opp['selection']} at {opp['ev_percentage']}%")