Post big orders to Slack

from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, notify, report_fetched

API = "https://a.klaviyo.com/api"
PLACED_ORDER_METRIC_ID = "RESQ6t"
MIN_VALUE = 500

def klaviyo():
    return {"Authorization": f"Klaviyo-API-Key {credentials.secret('KLAVIYO_API_KEY')}",
            "revision": "2024-10-15", "accept": "application/vnd.api+json", "content-type": "application/vnd.api+json"}

@on_trigger
def run(event):
    since = state.get("since") or datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ")
    resp = http.get(f"{API}/events", headers=klaviyo(), params={
        "filter": f'equals(metric_id,"{PLACED_ORDER_METRIC_ID}"),greater-than(datetime,{since})',
        "include": "profile", "sort": "datetime"}).json()
    events = resp["data"]
    report_fetched(len(events))
    if not events:
        return {"summary": "Nothing new"}
    emails = {p["id"]: p["attributes"]["email"] for p in resp.get("included", [])}
    for e in events:
        value = e["attributes"]["event_properties"].get("$value", 0)
        if value > MIN_VALUE:
            who = emails.get(e["relationships"]["profile"]["data"]["id"], "unknown")
            notify.slack(f"Big order: ${value:,.2f} from {who}", channel="#sales")
    state.set("since", events[-1]["attributes"]["datetime"])
    return {"checked": len(events)}