Post a weekly HubSpot leads and revenue summary in Slack

from datetime import datetime, timedelta, timezone
from clickruntime import on_trigger, credentials, http, ai, notify

API = "https://api.hubapi.com/crm/v3/objects"

def search(obj, prop, since, props):
    body = {"filterGroups": [{"filters": [{"propertyName": prop, "operator": "GTE", "value": since}]}], "properties": props, "limit": 100}
    return http.post(f"{API}/{obj}/search", json=body,
                     headers={"Authorization": f"Bearer {credentials.secret('HUBSPOT_API_KEY')}"}).json().get("results", [])

@on_trigger
def run(event):
    since = str(int((datetime.now(timezone.utc) - timedelta(days=7)).timestamp() * 1000))
    new = search("contacts", "createdate", since, ["email"])
    moved = search("contacts", "lastmodifieddate", since, ["lifecyclestage"])
    won = [d for d in search("deals", "closedate", since, ["dealname", "amount", "dealstage"]) if d["properties"].get("dealstage") == "closedwon"]
    total = sum(float(d["properties"].get("amount") or 0) for d in won)
    deals = "\n".join(f"- {d['properties']['dealname']}: {d['properties'].get('amount')}" for d in won)
    text = f"Last week: {len(new)} new contacts, {len(moved)} contacts updated, {len(won)} deals won ({total:,.0f}).\n{deals}"
    text += "\n" + ai.generate(f"In two short lines, comment on this sales week:\n{text}", max_output_tokens=120).text
    notify.slack(text, channel="#sales")
    return {"new": len(new), "won": len(won)}