Know when a cadence email gets a reply or bounces

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

API = "https://api.salesloft.com/v2"

@state_initializer
def init():
    state.set("since", datetime.now(timezone.utc).isoformat())

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesloft', 'work')}"}
    since = state.get("since")
    now = datetime.now(timezone.utc).isoformat()
    emails = http.get(f"{API}/activities/emails", headers=headers,
                      params={"updated_at[gt]": since, "per_page": 100}).json()["data"]
    hits = [e for e in emails if e.get("status") == "bounced" or (e.get("counts") or {}).get("replies")]
    report_fetched(len(hits))
    if not hits:
        return {"alerts": 0}
    for e in hits:
        cadence_id = (e.get("cadence") or {}).get("id")
        cadence = http.get(f"{API}/cadences/{cadence_id}", headers=headers).json()["data"]["name"] if cadence_id else "no cadence"
        kind = "Bounce" if e.get("status") == "bounced" else "Reply"
        notify.slack(f"{kind}: {e['recipient_email_address']} on \"{e['subject']}\" ({cadence})",
                     channel="#sales-replies")
    state.set("since", now)
    return {"alerts": len(hits)}