Email a Monday pipeline summary

from collections import defaultdict
from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, notify

API = "https://northwind.myfreshworks.com/crm/sales/api"
VIEW_ID = 31000000125  # Open deals

@on_trigger
def run(event):
    resp = http.get(f"{API}/deals/view/{VIEW_ID}", params={"include": "deal_stage", "per_page": 100},
                    headers={"Authorization": f"Token token={credentials.secret('FRESHSALES_API_KEY')}"})
    resp.raise_for_status()
    body = resp.json()
    stages = {s["id"]: s["name"] for s in body.get("deal_stages", [])}
    totals, closing = defaultdict(float), []
    week_end = str(date.today() + timedelta(days=6))
    for d in body["deals"]:
        amount = float(d.get("amount") or 0)
        totals[stages.get(d["deal_stage_id"], "Unknown")] += amount
        if d.get("expected_close") and str(date.today()) <= d["expected_close"][:10] <= week_end:
            closing.append(f"  {d['name']}: ${amount:,.0f} on {d['expected_close'][:10]}")
    text = "By stage:\n" + "\n".join(f"  {s}: ${v:,.0f}" for s, v in totals.items())
    text += "\n\nExpected to close this week:\n" + ("\n".join(closing) or "  none")
    notify.email_me(f"Freshsales pipeline: ${sum(totals.values()):,.0f} open", text)
    return {"stages": len(totals), "closing": len(closing)}