Log outages in Supabase and get a diagnosis

from clickruntime import on_trigger, credentials, http, notify, state, ai

SUPABASE_URL = "https://your-project.supabase.co"

def sb_headers(**extra):
    key = credentials.secret("SUPABASE_SECRET_KEY")
    return {"apikey": key, "Authorization": f"Bearer {key}", **extra}

URLS = ["https://example.com", "https://app.example.com", "https://api.example.com/health"]

@on_trigger
def run(event):
    down = state.get("down") or {}
    for url in URLS:
        try:
            resp = http.get(url, timeout=10)
            problem = None if resp.ok else f"HTTP {resp.status_code}: {resp.text[:300]}"
        except Exception as e:
            problem = f"{type(e).__name__}: {e}"
        if problem and url not in down:
            row = http.post(f"{SUPABASE_URL}/rest/v1/incidents", json={"url": url, "error": problem},
                            headers=sb_headers(Prefer="return=representation")).json()[0]
            cause = ai.generate(f"{url} failed with: {problem}", system="In two sentences, say what probably went wrong.",
                                max_output_tokens=120).text
            notify.email_me(f"DOWN: {url}", f"{problem}\n\n{cause}")
            down[url] = row["id"]
        elif not problem and url in down:
            http.patch(f"{SUPABASE_URL}/rest/v1/incidents", params={"id": f"eq.{down.pop(url)}"},
                       json={"resolved_at": "now()"}, headers=sb_headers())
            notify.email_me(f"RECOVERED: {url}", "The check is passing again.")
    state.set("down", down)
    return {"down": list(down)}