Ask cancelling customers why, and get a weekly churn summary

import base64, stripe, time
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, on_trigger, credentials, verify, state, ai, notify, report_fetched

@on_event
def handle(event):
    if not verify.stripe(event.body, event.header("Stripe-Signature"), credentials.secret("STRIPE_WEBHOOK_SECRET")):
        return {"ignored": "bad signature"}
    email = stripe.Customer.retrieve(event.json["data"]["object"]["customer"], api_key=credentials.secret("STRIPE_API_KEY")).email
    msg = EmailMessage(); msg["To"], msg["Subject"] = email, "Quick question"
    msg.set_content("Sorry to see you go. What was the main reason you cancelled? A one-line reply is plenty.")
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(
        userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
    state.set("asked", (state.get("asked") or []) + [email])
    return {"asked": email}
@on_trigger
def check(event):
    g = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages()
    replies = [m for e in state.get("asked") or [] for m in g.list(userId="me", q=f"from:{e} newer_than:1d").execute().get("messages", [])[:1]]
    report_fetched(len(replies))
    if not replies:
        return {"replies": 0}
    reasons = (state.get("reasons") or []) + [ai.generate("Classify this cancellation reply as price, missing feature, switched tool, no longer needed, technical problems or other. "
        "Answer with the category only.\n" + g.get(userId="me", id=m["id"]).execute()["snippet"], max_output_tokens=10).text.strip() for m in replies]
    if time.gmtime().tm_wday == 0:
        notify.email_me("Weekly churn reasons", "\n".join(f"{r}: {reasons.count(r)}" for r in sorted(set(reasons)))); reasons = []
    state.set("reasons", reasons)
    return {"replies": len(replies)}