Dropping odds API: Pinnacle drops, pushed to your code.

data: {"type": "connected", "id": "5f0c1a92-7e3d-..."}

data: [{"home": "Hammarby", "away": "Djurgarden",
        "league": "Sweden - Allsvenskan",
        "from_price": 2.41, "to_price": 2.26,
        "outcome": "Home", "period": 0, "sect": "Moneyline",
        "id": 1632907731, "sport": "Soccer", "sport_id": 1,
        "nvp": 2.33, "home_score": 1, "away_score": 1, ...,
        "live": {"status": "2nd Half - 22'", "minute": 22,
                 "score": {"home": 1, "away": 1},
                 "red_cards": {"home": 0, "away": 1},
                 "favorite": "home", ...}}]

import json, os, time
import requests

BASE = "https://pinnradar.com"
KEY = os.environ["PINNRADAR_KEY"]

def drops(path="/odds-drop", **params):
    params["key"] = KEY
    wait = 1
    while True:
        try:
            with requests.get(BASE + path, params=params,
                              stream=True, timeout=(5, None)) as r:
                r.raise_for_status()
                wait = 1
                for line in r.iter_lines(decode_unicode=True):
                    if not line or not line.startswith("data:"):
                        continue
                    frame = json.loads(line[5:])
                    if isinstance(frame, list):
                        yield from frame
                    elif frame.get("error") == "plan_lacks_sse":
                        raise SystemExit("this plan has no SSE")
                    elif frame.get("error") == "rate_limited":
                        wait = 60
                        break
        except requests.RequestException:
            pass
        time.sleep(wait)
        wait = min(wait * 2, 60)

for d in drops(min_drop=7):
    if d["sport_id"] != 1:          # soccer only
        continue
    edge = d["to_price"] / d["nvp"] - 1 if d.get("nvp") else None
    status = (d.get("live") or {}).get("status")
    print(d["home"], "v", d["away"], d["sect"], d["outcome"],
          d["from_price"], "->", d["to_price"], edge, status)

const BASE = "https://pinnradar.com";
const KEY = process.env.PINNRADAR_KEY;

async function follow(path, onDrop) {
  const resp = await fetch(`${BASE}${path}&key=${KEY}`, {
    headers: { accept: "text/event-stream" },
  });
  if (!resp.ok) throw new Error(`HTTP ${resp.status}`);
  const decoder = new TextDecoder();
  let pending = "";
  for await (const chunk of resp.body) {
    pending += decoder.decode(chunk, { stream: true });
    let cut;
    while ((cut = pending.indexOf("\n\n")) !== -1) {
      const block = pending.slice(0, cut);
      pending = pending.slice(cut + 2);
      const data = block.split("\n")
        .filter((l) => l.startsWith("data:"))
        .map((l) => l.slice(5).trim()).join("");
      if (!data) continue;
      const frame = JSON.parse(data);
      if (Array.isArray(frame)) frame.forEach(onDrop);
      else if (frame.type === "error") throw new Error(frame.error);
    }
  }
}

await follow("/odds-drop-prematch?min_drop=5&recheck=30", (d) => {
  console.log(d.sport, d.home, "v", d.away, d.sect, d.outcome,
    d.from_price, "->", d.to_price, `held ${d.rechecked_ms} ms`);
});

curl -N "https://pinnradar.com/odds-drop?key=$PINNRADAR_KEY&min_drop=3"

curl -sG https://pinnradar.com/api/drops \
  -H "x-portal-apikey: $PINNRADAR_KEY" \
  -d mode=prematch -d min_drop_pct=2 \
  -d max_age_sec=3600 -d markets=total