Clean out subscribers who stopped opening

import hashlib
from datetime import datetime, timedelta, timezone
from clickruntime import on_event, on_trigger, http, credentials, notify, state

LIST_ID = "AUDIENCE_ID"

def mailchimp(method, path, **kw):
    key = credentials.secret("MAILCHIMP_API_KEY")
    r = http.request(method, f"https://{key.split('-')[-1]}.api.mailchimp.com/3.0{path}", auth=("clickruntime", key), **kw)
    r.raise_for_status()
    return r.json() if r.content else None

@on_trigger
def find_inactive(event):
    cutoff = (datetime.now(timezone.utc) - timedelta(days=180)).isoformat()
    members = mailchimp("GET", f"/lists/{LIST_ID}/members", params={"status": "subscribed", "count": 1000,
                        "fields": "members.email_address,members.last_changed,members.stats"})["members"]
    inactive = [m["email_address"] for m in members if m["last_changed"] < cutoff and m["stats"]["avg_open_rate"] == 0]
    state.set("pending", inactive)
    notify.email_me(f"{len(inactive)} subscribers with no opens in 180 days",
                    "\n".join(inactive) + "\n\nReply yes in ClickRuntime (send {\"confirm\": \"yes\"} to the trigger link) to archive them.")
    return {"inactive": len(inactive)}

@on_event
def confirm(event):
    if (event.json or {}).get("confirm") != "yes":
        return {"archived": 0}
    pending = state.get("pending") or []
    for email in pending:
        mailchimp("DELETE", f"/lists/{LIST_ID}/members/{hashlib.md5(email.lower().encode()).hexdigest()}")
    state.delete("pending")
    return {"archived": len(pending)}