Forward WhatsApp Business messages to Gmail

import base64
from email.message import EmailMessage
from datetime import datetime
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, credentials, state

TO = "support@mycompany.com"
gmail = lambda: build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()

def incoming(event):
    for e in (event.json or {}).get("entry", []):
        for c in e.get("changes", []):
            v = c["value"]
            names = {x["wa_id"]: x["profile"]["name"] for x in v.get("contacts", [])}
            for m in v.get("messages", []):
                yield m, names.get(m["from"], "")

@on_event
def handle(event):
    sent = 0
    for m, name in incoming(event):
        t = m["type"]
        text = m["text"]["body"] if t == "text" else f"[{t}] " + (m.get(t, {}).get("caption") or "(no caption, open WhatsApp to view)")
        subject = f"WhatsApp from {name or 'customer'} (+{m['from']})"
        msg = EmailMessage()
        msg["To"], msg["Subject"] = TO, subject
        msg.set_content(f"{text}\n\nReceived on WhatsApp at {datetime.fromtimestamp(int(m['timestamp'])):%H:%M}.")
        body = {"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}
        thread = state.get(f"thread:{m['from']}")
        if thread:
            body["threadId"] = thread
        res = gmail().messages().send(userId="me", body=body).execute()
        state.set(f"thread:{m['from']}", res["threadId"])
        sent += 1
    return {"forwarded": sent}