Watch for unusual flow

import os
import time
import requests

API = "https://api.routeur.app"
session = requests.Session()
session.headers["X-API-Key"] = os.environ["ROUTEUR_API_KEY"]
seen = {}

while True:
    res = session.get(f"{API}/v1/flow", params={"hours": 1, "limit": 100}, timeout=20)
    res.raise_for_status()
    for signal in res.json()["data"]:
        if seen.get(signal["id"]) == signal["last_detected_at"]:
            continue                                    # same signal, nothing new since we printed it
        extended = signal["id"] in seen
        seen[signal["id"]] = signal["last_detected_at"]
        market, m = signal["market"], signal["metrics"]
        tag = "extended" if extended else "new"
        print(f"[{signal['kind']}] {tag} · score {signal['score']:.1f} · {market['title']} ({market['venue']})")
        line = f"    {m.get('trades', 0):.0f} trades, ${m.get('notional_usd', 0):,.0f} in the window"
        if "baseline_trades_per_window" in m:
            line += f" · normally {m['baseline_trades_per_window']:.1f} trades"
        if signal["kind"] == "one_sided":
            line += f" · Yes {m['yes_price_start'] * 100:.0f}¢ → {m['yes_price_end'] * 100:.0f}¢, imbalance {m['imbalance']:+.2f}"
        if signal["kind"] == "large_fill":
            line += f" · largest fill ${m['max_fill_usd']:,.0f}"
        print(line)
    time.sleep(300)

const API = 'https://api.routeur.app';
const headers = { 'X-API-Key': process.env.ROUTEUR_API_KEY! };
const seen = new Map<number, string>();

type Signal = {
  id: number; kind: 'burst' | 'large_fill' | 'one_sided'; score: number; last_detected_at: string;
  market: { venue: string; id: string; title: string }; metrics: Record<string, number>;
};

async function poll() {
  const res = await fetch(`${API}/v1/flow?hours=1&limit=100`, { headers });
  if (!res.ok) throw new Error(`flow: ${res.status}`);
  const { data } = (await res.json()) as { data: Signal[] };
  for (const s of data) {
    if (seen.get(s.id) === s.last_detected_at) continue;
    const tag = seen.has(s.id) ? 'extended' : 'new';
    seen.set(s.id, s.last_detected_at);
    const m = s.metrics;
    console.log(`[${s.kind}] ${tag} · score ${s.score.toFixed(1)} · ${s.market.title} (${s.market.venue})`);
    let line = `    ${m.trades ?? 0} trades, $${Math.round(m.notional_usd ?? 0).toLocaleString()} in the window`;
    if ('baseline_trades_per_window' in m) line += ` · normally ${m.baseline_trades_per_window.toFixed(1)} trades`;
    if (s.kind === 'one_sided') line += ` · Yes ${Math.round(m.yes_price_start * 100)}¢ → ${Math.round(m.yes_price_end * 100)}¢, imbalance ${m.imbalance.toFixed(2)}`;
    if (s.kind === 'large_fill') line += ` · largest fill $${Math.round(m.max_fill_usd).toLocaleString()}`;
    console.log(line);
  }
}

await poll();
setInterval(poll, 5 * 60_000);