Draft RFP answers in a Google Doc when one arrives by email

import base64
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, state, ai, notify, report_fetched

@on_trigger
def run(event):
    creds = Credentials(credentials.connection("google", "work"))
    gmail = build("gmail", "v1", credentials=creds, cache_discovery=False).users()
    seen = set(state.get("seen") or [])
    msgs = [m for m in gmail.messages().list(userId="me", q="subject:RFP has:attachment newer_than:2d").execute().get("messages", []) if m["id"] not in seen]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    docs = build("docs", "v1", credentials=creds, cache_discovery=False).documents()
    for m in msgs:
        full = gmail.messages().get(userId="me", id=m["id"]).execute()
        part = next(p for p in full["payload"].get("parts", []) if p.get("filename"))
        data = gmail.messages().attachments().get(userId="me", messageId=m["id"], id=part["body"]["attachmentId"]).execute()["data"]
        text = base64.urlsafe_b64decode(data).decode("utf-8", "ignore")[:20000]
        draft = ai.generate(text, system="List every question in this RFP and draft a concise answer under each.", max_output_tokens=2048).text
        doc = docs.create(body={"title": f"RFP answers: {part['filename']}"}).execute()
        docs.batchUpdate(documentId=doc["documentId"], body={"requests": [{"insertText": {"location": {"index": 1}, "text": draft}}]}).execute()
        notify.email_me(f"RFP draft ready: {part['filename']}", f"https://docs.google.com/document/d/{doc['documentId']}")
        seen.add(m["id"])
    state.set("seen", list(seen)[-200:])
    return {"drafted": len(msgs)}