Unified Stream

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, channel, filters } = JSON.parse(e.data);
  console.log(`Stream ${stream_id} connected (${channel}) with filters:`, filters);
});
 
eventSource.addEventListener('snapshot', (e) => {
  const data = JSON.parse(e.data);
  console.log('Snapshot chunk received');
});
 
eventSource.addEventListener('snapshot:complete', (e) => {
  const { books, total_odds } = JSON.parse(e.data);
  console.log(`Snapshot complete: ${total_odds} odds from ${books.join(', ')}`);
});
 
eventSource.addEventListener('odds:update', (e) => {
  const update = JSON.parse(e.data);
  const books = Object.keys(update).filter(k => k !== 'timestamp');
  console.log(`Odds updated for: ${books.join(', ')}`);
});
 
eventSource.addEventListener('odds:removed', (e) => {
  const { source, ids } = JSON.parse(e.data);
  console.log(`${source}: ${ids.length} odds removed`);
});
 
eventSource.addEventListener('ev:detected', (e) => {
  const opps = JSON.parse(e.data);
  opps.forEach(opp => console.log(`+EV: ${opp.selection} at ${opp.ev_percent}%`));
});
 
eventSource.addEventListener('arb:detected', (e) => {
  const arbs = JSON.parse(e.data);
  arbs.forEach(arb => console.log(`Arb: ${arb.profit_percent}% profit`));
});
 
eventSource.addEventListener('middles:detected', (e) => {
  const middles = JSON.parse(e.data);
  middles.forEach(m => console.log(`Middle: ${m.event_name} — EV ${m.expected_value}%`));
});
 
eventSource.addEventListener('low_hold:detected', (e) => {
  const holds = JSON.parse(e.data);
  holds.forEach(h => console.log(`Low hold: ${h.hold_percentage}%`));
});
 
eventSource.addEventListener('heartbeat', () => {
  console.log('Connection alive');
});
 
eventSource.onerror = () => {
  console.log('Connection lost, auto-reconnecting...');
};

import EventSource from 'eventsource';
 
const es = new EventSource(
  'https://api.sharpapi.io/api/v1/stream?channel=all&sport=basketball&league=nba',
  { headers: { 'X-API-Key': 'YOUR_KEY' } }
);
 
es.addEventListener('connected', (e) => {
  const { stream_id, reconnected } = JSON.parse(e.data);
  console.log(`Stream ${stream_id} connected (reconnected: ${reconnected})`);
});
 
es.addEventListener('snapshot', (e) => {
  const data = JSON.parse(e.data);
  console.log('Snapshot chunk received');
});
 
es.addEventListener('snapshot:complete', (e) => {
  const { books, total_odds } = JSON.parse(e.data);
  console.log(`Ready: ${total_odds} odds from ${books.join(', ')}`);
});
 
es.addEventListener('odds:update', (e) => {
  const update = JSON.parse(e.data);
  const books = Object.keys(update).filter(k => k !== 'timestamp');
  console.log(`Odds updated: ${books.join(', ')}`);
});
 
es.addEventListener('odds:removed', (e) => {
  const { source, count } = JSON.parse(e.data);
  console.log(`${source}: ${count} odds removed`);
});
 
es.addEventListener('ev:detected', (e) => {
  const opps = JSON.parse(e.data);
  opps.forEach(opp =>
    console.log(`+EV: ${opp.selection} — ${opp.ev_percent}% EV`)
  );
});
 
es.addEventListener('ev:expired', (e) => {
  const { expired } = JSON.parse(e.data);
  console.log(`EV expired: ${expired.length} opportunities`);
});
 
es.addEventListener('arb:detected', (e) => {
  const arbs = JSON.parse(e.data);
  arbs.forEach(arb =>
    console.log(`Arb: ${arb.profit_percent}% across ${arb.legs.length} legs`)
  );
});
 
es.addEventListener('arb:expired', (e) => {
  const { expired } = JSON.parse(e.data);
  console.log(`Arb expired: ${expired.length} opportunities`);
});
 
es.onerror = (err) => {
  console.error('Stream error:', err.message);
};

import sseclient
import requests
import json
 
url = 'https://api.sharpapi.io/api/v1/stream'
params = {
    'channel': 'all',
    'sport': 'basketball',
    'league': 'nba',
}
headers = {'X-API-Key': 'YOUR_KEY'}
 
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':
        print(f"Stream {data['stream_id']} connected ({data['channel']})")
 
    elif event.event == 'snapshot':
        print("Snapshot chunk received")
 
    elif event.event == 'snapshot:complete':
        print(f"Ready: {data['total_odds']} odds from {', '.join(data['books'])}")
 
    elif event.event == 'odds:update':
        books = [k for k in data if k != 'timestamp']
        print(f"Odds updated: {', '.join(books)}")
 
    elif event.event == 'odds:removed':
        print(f"{data['source']}: {data['count']} odds removed")
 
    elif event.event == 'ev:detected':
        for opp in data:
            print(f"+EV: {opp['selection']} at {opp['ev_percent']}%")
 
    elif event.event == 'ev:expired':
        print(f"EV expired: {len(data['expired'])} opportunities")
 
    elif event.event == 'arb:detected':
        for arb in data:
            print(f"Arb: {arb['profit_percent']}% profit")
 
    elif event.event == 'arb:expired':
        print(f"Arb expired: {len(data['expired'])} opportunities")
 
    elif event.event == 'middles:detected':
        for m in data:
            print(f"Middle: {m.get('event_name', '?')} — EV {m.get('expected_value', '?')}%")
 
    elif event.event == 'low_hold:detected':
        for h in data:
            print(f"Low hold: {h['hold_percentage']}%")
 
    elif event.event == 'heartbeat':
        pass  # silent keepalive