Add ring-hunt sweep (hunt.py) over news-driven event markets

Sweeps a list of insider-prone markets, scores each market's top traders with
insider.analyze, and runs funding-cluster ring detection. First real hunt
flagged DREAMBIG. (z=8.9, p~2e-19) and qcp14 (z=5.3, p~4e-8) on the Iran
ceasefire-extension market — insider-grade improbability — with no operator
rings (all independently/exchange-funded; exchange-funded wallets aren't
linkable, a known limit).

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
jaxperro
2026-06-13 13:15:09 -04:00
parent 34d02956d8
commit c1265c5461
2 changed files with 65 additions and 0 deletions
+1
View File
@@ -18,3 +18,4 @@ lp_paper_state.json
# cross-venue scanner output
xarb_hits.csv
hunt.log
+64
View File
@@ -0,0 +1,64 @@
#!/usr/bin/env python3
"""Ring hunt — sweep news-driven event markets, score traders, detect funding
clusters (operator rings). Uses insider.py's machinery across many markets."""
import sys
import time
from concurrent.futures import ThreadPoolExecutor, as_completed
import insider
KEY = insider.sm_load_key()
TOP = 30 # top traders by notional per market
def hunt_market(cond, title):
cands, _ = insider.market_traders(cond, top=TOP)
if not cands:
return
name = {c["wallet"]: c["username"] for c in cands}
rows = []
with ThreadPoolExecutor(max_workers=10) as ex:
futs = [ex.submit(insider.analyze, c) for c in cands]
for f in as_completed(futs):
try:
r = f.result()
except Exception:
r = None
if r:
rows.append(r)
rows.sort(key=lambda r: r["score"], reverse=True)
print(f"\n{'='*78}\n{title[:60]} ({len(cands)} traders scored)\n{'='*78}", flush=True)
print("top by improbability:")
for r in rows[:4]:
print(f" susp {r['score']:>4} z {r['z']:>5} p {insider.fmt_p(r['pval']):>8} "
f"{r['wins']}/{r['n']} pre24 {r['pre24_pct']:>3}% trades {r['trades']:>6} "
f"{r['username'][:20]}", flush=True)
# funding-cluster ring detection
if KEY:
groups, links = insider.cluster([c["wallet"] for c in cands], KEY)
if groups:
print(f" ** RING: {len(groups)} operator cluster(s) via shared personal hub:", flush=True)
for g in sorted(groups, key=len, reverse=True):
print(" " + " + ".join(name.get(w, w[:10]) for w in g), flush=True)
else:
print(" no operator rings (traders independently / exchange-funded)", flush=True)
# news-driven, unscheduled-resolution markets (insider-prone)
MARKETS = [
("0x9352c559e9648ab4cab236087b64ca85c5b7123a4c7d9d7d4efde4a39c18056f", "Iranian regime fall by June 30?"),
("0x6114a8a3f9ac214f48a7e20d169f1c7a5c84082cb6f7058ed9fe1137b11fd0e7", "US x Iran permanent peace deal by June 30?"),
("0x68fbeb8d823552abf9d35f3ebdb8619a1a1d51b650da9101be62f09308fd18d2", "US announces Iran agreement/ceasefire extension"),
("0xdfd4d487d004c266493bdf32551d7f018c7eb4b9325f42ac368dd5075eec36a9", "Trump restart Project Freedom by June 30?"),
]
if __name__ == "__main__":
print(f"RING HUNT · {len(MARKETS)} markets · top {TOP} traders each · "
f"clustering {'ON' if KEY else 'OFF (no key)'}", flush=True)
for cond, title in MARKETS:
try:
hunt_market(cond, title)
except Exception as e:
print(f"\n{title[:40]}: error {e}", flush=True)
print("\nhunt complete.", flush=True)