Liquid opportunities

import os
import requests

API = "https://api.routeur.app"
session = requests.Session()
session.headers["X-API-Key"] = os.environ["ROUTEUR_API_KEY"]
FLOORS = {"min_volume_usd": 1000, "max_spread_usd": 0.05}     # the API's defaults, made explicit


def get(path, **params):
    res = session.get(f"{API}{path}", params={**FLOORS, **params}, timeout=30)
    res.raise_for_status()
    return res.json()


def usd(x):
    return float(x) if x not in (None, "") else 0.0


rows = []

# 1. Leads: two legs that pay $1 in every outcome. Net edge is per pair; volume is the thinner leg's.
for lead in get("/v1/opportunities", limit=200)["data"]:
    depth = lead.get("depth") or {}
    if depth.get("limited_by") == "informational":
        continue                                            # the venues could settle it differently
    edge = usd(lead["net_edge_usd"])                        # per pair at the top of book, after estimated fees
    volume = min(usd(lead["left"]["volume_24h_usd"]), usd(lead["right"]["volume_24h_usd"]))
    rows.append({"kind": "lead", "edge": edge, "volume": volume, "executable": depth.get("executable", False),
                 "what": f"{lead['relation']} · {lead['left']['title']} ↔ {lead['right']['title']}",
                 "ids": [(lead["left"]["venue"], lead["left"]["id"]), (lead["right"]["venue"], lead["right"]["id"])]})

# 2. Venue gaps: the same contract priced apart on Kalshi and Polymarket. net_usd already pays both spreads and fees.
for gap in get("/v1/insights", limit=50)["data"]["spreads"]:
    volume = min(usd(gap["left"]["volume_24h_usd"]), usd(gap["right"]["volume_24h_usd"]))
    rows.append({"kind": "gap", "edge": usd(gap["net_usd"]), "volume": volume, "executable": None,
                 "what": f"{gap['left']['title']} · {gap['left']['venue']} {gap['left']['yes_ask_usd']} vs {gap['right']['venue']} {gap['right']['yes_ask_usd']}",
                 "ids": [(gap["left"]["venue"], gap["left"]["id"]), (gap["right"]["venue"], gap["right"]["id"])]})

# 3. Strategy matches: open markets fitting a rule settled history paid for. Edge is the rule's return per $1, before fees.
for rule in get("/v1/insights/strategies", limit=10)["data"]:
    if rule["open_matches"] == 0:
        continue
    for match in get(f"/v1/insights/strategies/{rule['id']}", limit=50)["data"]["matches"]:
        m = match["market"]
        rows.append({"kind": "strategy", "edge": usd(rule["return_per_100_usd"]) / 100, "volume": usd(m["volume_24h_usd"]), "executable": None,
                     "what": f"buy {rule['side']} at {usd(match['price_usd']) * 100:.0f}¢ · {m['title']} · {rule['id']}",
                     "ids": [(m["venue"], m["id"])]})

# 4. Rank by edge × volume within each kind: a small edge in a deep market beats a wide one nobody can trade.
#    The kinds are not comparable with each other: a lead's edge is proven, a gap's is net of fees, a strategy's is history.
print(f"{len(rows)} candidates above the floors (volume ≥ ${FLOORS['min_volume_usd']:,}, round trip ≤ {FLOORS['max_spread_usd'] * 100:.0f}¢)")
for kind in ("lead", "gap", "strategy"):
    ranked = sorted((r for r in rows if r["kind"] == kind), key=lambda r: r["edge"] * r["volume"], reverse=True)
    print(f"\n{kind} rows: {len(ranked)}")
    for r in ranked[:3]:
        flag = "" if r["executable"] is None else (" · executable" if r["executable"] else " · not fillable")
        print(f"  {r['edge'] * r['volume']:>+9.0f}  edge {r['edge'] * 100:+.1f}¢ × ${r['volume']:,.0f}{flag}")
        print(f"             {r['what']}")