Post a weekly Airtable pipeline report in Slack

from collections import defaultdict
from clickruntime import on_trigger, credentials, http, notify

BASE_ID = "appXXXXXXXXXXXXXX"
TABLE = "Deals"

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.secret('AIRTABLE_API_KEY')}"}
    totals, offset = defaultdict(lambda: [0, 0.0]), None
    while True:
        params = {"fields[]": ["Stage", "Amount"], **({"offset": offset} if offset else {})}
        page = http.get(f"https://api.airtable.com/v0/{BASE_ID}/{TABLE}", headers=headers, params=params).json()
        for rec in page.get("records", []):
            stage = rec["fields"].get("Stage", "No stage")
            totals[stage][0] += 1
            totals[stage][1] += float(rec["fields"].get("Amount") or 0)
        offset = page.get("offset")
        if not offset:
            break
    lines = [f"• {stage}: {n} deals, ${v:,.0f}" for stage, (n, v) in sorted(totals.items())]
    notify.slack("Weekly pipeline\n" + "\n".join(lines), channel="#sales")
    return {"stages": len(lines)}