Draft replies to customer emails using your Airtable orders

import base64
from email.message import EmailMessage
from googleapiclient.discovery import build
from google.oauth2.credentials import Credentials
from clickruntime import on_trigger, credentials, ai, report_fetched, http

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()
    msgs = gmail.messages().list(userId="me", q="label:support is:unread -label:drafted").execute().get("messages", [])
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "No new emails"}
    for m in msgs:
        msg = gmail.messages().get(userId="me", id=m["id"], format="metadata", metadataHeaders=["From", "Subject"]).execute()
        h = {x["name"]: x["value"] for x in msg["payload"]["headers"]}
        sender = h["From"].split("<")[-1].strip(">")
        orders = http.get("https://api.airtable.com/v0/appXXXXXXXX/Orders", headers={"Authorization": f"Bearer {credentials.secret('AIRTABLE_API_KEY')}"},
                          params={"filterByFormula": f"{{Email}}='{sender}'", "maxRecords": 3}).json()["records"]
        reply = ai.generate(f"Customer wrote: {msg['snippet']}\nTheir orders: {[o['fields'] for o in orders]}\nWrite a friendly, short reply.", max_output_tokens=300).text
        draft = EmailMessage()
        draft["To"], draft["Subject"] = sender, "Re: " + h.get("Subject", "")
        draft.set_content(reply)
        gmail.drafts().create(userId="me", body={"message": {"threadId": msg["threadId"], "raw": base64.urlsafe_b64encode(draft.as_bytes()).decode()}}).execute()
    return {"drafted": len(msgs)}