Post new VIP list members to Slack

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

API = "https://a.klaviyo.com/api"
VIP_LIST_ID = "Vp9Lst"

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")
    profiles = http.get(f"{API}/lists/{VIP_LIST_ID}/profiles", headers=klaviyo(), params={
        "filter": f"greater-than(joined_group_at,{since})", "fields[profile]": "email,first_name,last_name,joined_group_at"}
    ).json()["data"]
    report_fetched(len(profiles))
    if not profiles:
        return {"summary": "Nothing new"}
    for p in profiles:
        a = p["attributes"]
        notify.slack(f"New VIP: {a.get('first_name') or ''} {a.get('last_name') or ''} <{a['email']}>".replace("  ", " "),
                     channel="#vip")
    state.set("since", max(p["attributes"]["joined_group_at"] for p in profiles))
    return {"posted": len(profiles)}