Detect smart-money entry into a market

import os, requests, time

BASE = "https://api.predexon.com"
H = {"x-api-key": os.environ["PREDEXON_API_KEY"]}

def top_smart_markets(window_hours=4, limit=20):
    return requests.get(
        f"{BASE}/v2/polymarket/markets/smart-activity",
        headers=H,
        params={"window_hours": window_hours, "limit": limit},
    ).json()["markets"]

def smart_money(condition_id):
    return requests.get(
        f"{BASE}/v2/polymarket/market/{condition_id}/smart-money",
        headers=H,
    ).json()

def evaluate(candidates):
    signals = []
    for m in candidates:
        sm = smart_money(m["condition_id"])
        pos = sm["positioning"]                       # SmartMoneyPositioning
        net_usd = pos["total_smart_buy_volume"] - pos["total_smart_sell_volume"]
        wallet_count = pos["smart_wallet_count"]
        if abs(net_usd) > 25_000 and wallet_count >= 5:
            signals.append({
                "market": m["title"],
                "condition_id": m["condition_id"],
                "market_slug": m["market_slug"],
                "side": "yes" if net_usd > 0 else "no",
                "flow_usd": net_usd,
                "wallets": wallet_count,
                "net_buyers_pct": pos["net_buyers_pct"],
                "avg_buy_price": pos["avg_smart_buy_price"],
            })
    return signals

import json
import urllib.request

DISCORD_WEBHOOK = os.environ["DISCORD_WEBHOOK"]

def alert(signal):
    msg = (
        f"**Smart money signal: {signal['side'].upper()}**\n"
        f"{signal['market']}\n"
        f"Net flow: ${signal['flow_usd']:+,.0f} from {signal['wallets']} smart wallets "
        f"({signal['net_buyers_pct']*100:.0f}% net buyers)\n"
        f"Avg smart-money buy price: ${signal['avg_buy_price']:.2f}\n"
        f"https://polymarket.com/market/{signal['market_slug']}"
    )
    req = urllib.request.Request(
        DISCORD_WEBHOOK,
        data=json.dumps({"content": msg}).encode(),
        headers={"Content-Type": "application/json"},
    )
    urllib.request.urlopen(req)

SIZE_USD = 100

def execute_on_venue(token_id, side, size):
    # your venue-native execution — e.g. Polymarket CLOB client
    raise NotImplementedError

def maybe_trade(signal):
    # look up the YES/NO token_ids for this market
    market = requests.get(
        f"{BASE}/v2/polymarket/markets",
        headers=H,
        params={"condition_id": signal["condition_id"], "limit": 1},
    ).json()["markets"][0]
    token_id = next(
        o["token_id"] for o in market["outcomes"]
        if o["label"].lower() == signal["side"]
    )
    current_price = next(
        o["price"] for o in market["outcomes"]
        if o["label"].lower() == signal["side"]
    )

    shares = SIZE_USD / current_price
    return execute_on_venue(
        token_id=token_id,
        side="buy",
        size=round(shares, 2),
    )

SEEN = set()  # don't re-alert on the same signal

while True:
    for s in evaluate(top_smart_markets()):
        key = (s["condition_id"], s["side"])
        if key in SEEN:
            continue
        SEEN.add(key)
        alert(s)
        # maybe_trade(s)  # uncomment to auto-execute via your venue client
    time.sleep(600)        # 10 min cadence