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
        seen[signal["id"]] = signal["last_detected_at"]
        market, metrics = signal["market"], signal["metrics"]
        print(f"[{signal['kind']}] score {signal['score']:.1f} · {market['title']} ({market['venue']})")
        if "notional_usd" in metrics:
            print(f"    ${metrics['notional_usd']:,.0f} traded in the window")
    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 signal of data) {
    if (seen.get(signal.id) === signal.last_detected_at) continue;
    seen.set(signal.id, signal.last_detected_at);
    console.log(`[${signal.kind}] score ${signal.score.toFixed(1)} · ${signal.market.title} (${signal.market.venue})`);
    if (signal.metrics.notional_usd) console.log(`    $${Math.round(signal.metrics.notional_usd).toLocaleString()} traded in the window`);
  }
}

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