Build your own storm alerts.

import csv, json, os, sys, requests

BASE = os.environ.get("TRUEFIXR_URL", "https://data.truefixr.com")
KEY = os.environ["TRUEFIXR_KEY"]
WEBHOOK = os.environ["ALERT_WEBHOOK_URL"]  # placeholder: your Slack-style incoming webhook
SEEN = os.environ.get("SEEN_FILE", "seen.json")  # remembers what we already sent


def load(path):
    with open(path, newline="") as f:
        return [{"label": r["label"], "lat": float(r["lat"]), "lon": float(r["lon"])}
                for r in csv.DictReader(f)]


def batches(items, n=500):  # the route takes up to 500 locations per call
    for i in range(0, len(items), n):
        yield items[i:i + n]


def active(sites, results):
    """Pair each result with its site and keep the ones with at least one alert."""
    out = []
    for site, res in zip(sites, results):  # results come back in request order
        alerts = res.get("alerts") or []
        if alerts:
            out.append((res.get("label") or site["label"], alerts))
    return out


def name(alert):
    return alert.get("event", str(alert)) if isinstance(alert, dict) else str(alert)


def main(path):
    sites = load(path)
    try:
        seen = set(json.load(open(SEEN)))
    except FileNotFoundError:
        seen = set()
    lines = []
    for chunk in batches(sites):
        r = requests.post(f"{BASE}/v1/weather/batch", json={"locations": chunk},
                          headers={"Authorization": f"Bearer {KEY}"}, timeout=60)
        r.raise_for_status()
        for label, alerts in active(chunk, r.json()["results"]):
            for a in alerts:
                k = f"{label}|{name(a)}"
                if k not in seen:
                    seen.add(k)
                    lines.append(f"{label}: {name(a)}")
    if lines:
        requests.post(WEBHOOK, json={"text": "Active alerts\n" + "\n".join(lines)}, timeout=30)
    json.dump(sorted(seen), open(SEEN, "w"))
    print(f"{len(sites)} sites checked, {len(lines)} new alerts sent")


if __name__ == "__main__":
    main(sys.argv[1] if len(sys.argv) > 1 else "locations.csv")

import { readFileSync, writeFileSync, existsSync } from "node:fs";

const BASE = process.env.TRUEFIXR_URL ?? "https://data.truefixr.com";
const KEY = process.env.TRUEFIXR_KEY;
const WEBHOOK = process.env.ALERT_WEBHOOK_URL; // placeholder: your Slack-style incoming webhook
const SEEN = process.env.SEEN_FILE ?? "seen.json"; // remembers what we already sent

const load = (path) =>
  readFileSync(path, "utf8").trim().split("\n").slice(1).map((line) => {
    const [label, lat, lon] = line.split(",");
    return { label, lat: Number(lat), lon: Number(lon) };
  });

const name = (a) => (typeof a === "object" && a !== null ? a.event ?? JSON.stringify(a) : String(a));

// Pair each result with its site (results come back in request order), keep those with alerts.
export const active = (sites, results) =>
  results.flatMap((res, i) =>
    (res.alerts ?? []).length ? [[res.label ?? sites[i].label, res.alerts]] : []);

async function main(path) {
  const sites = load(path);
  const seen = new Set(existsSync(SEEN) ? JSON.parse(readFileSync(SEEN, "utf8")) : []);
  const lines = [];
  for (let i = 0; i < sites.length; i += 500) { // up to 500 locations per call
    const chunk = sites.slice(i, i + 500);
    const r = await fetch(`${BASE}/v1/weather/batch`, {
      method: "POST",
      headers: { "Content-Type": "application/json", Authorization: `Bearer ${KEY}` },
      body: JSON.stringify({ locations: chunk }),
    });
    if (!r.ok) throw new Error(`HTTP ${r.status}`);
    for (const [label, alerts] of active(chunk, (await r.json()).results))
      for (const a of alerts) {
        const k = `${label}|${name(a)}`;
        if (!seen.has(k)) { seen.add(k); lines.push(`${label}: ${name(a)}`); }
      }
  }
  if (lines.length)
    await fetch(WEBHOOK, { method: "POST", headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ text: "Active alerts\n" + lines.join("\n") }) });
  writeFileSync(SEEN, JSON.stringify([...seen].sort()));
  console.log(`${sites.length} sites checked, ${lines.length} new alerts sent`);
}

if (process.argv[1] === new URL(import.meta.url).pathname) await main(process.argv[2] ?? "locations.csv");