Draft support replies in Gmail from your Supabase knowledge base

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched
SUPABASE = "https://your-project.supabase.co/rest/v1"

def sb(method, path, **kw):
    key = credentials.secret("SUPABASE_KEY")
    r = http.request(method, f"{SUPABASE}/{path}", **kw, headers={"apikey": key, "Authorization": f"Bearer {key}", "Prefer": "return=representation,resolution=merge-duplicates"})
    return r.raise_for_status() or (r.json() if r.content else None)

@on_trigger
def run(event):
    gmail, done = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False), set(state.get("done") or [])
    msgs = [m for m in gmail.users().messages().list(userId="me", q="label:Support is:unread newer_than:1d").execute().get("messages", []) if m["id"] not in done]
    sent = [m for m in gmail.users().messages().list(userId="me", q="in:sent label:Support newer_than:1d").execute().get("messages", []) if m["id"] not in done]
    report_fetched(len(msgs) + len(sent))
    if not msgs and not sent:
        return {"summary": "Nothing new"}
    for m in msgs:
        full = gmail.users().messages().get(userId="me", id=m["id"]).execute()
        h = {x["name"]: x["value"] for x in full["payload"]["headers"]}
        docs = sb("POST", "rpc/match_documents", json={"query_text": full["snippet"], "match_count": 4})
        reply = ai.generate("Write a short, friendly support reply using only these notes:\n" + "\n".join(d["content"] for d in docs)
                            + f"\n\nCustomer wrote: {full['snippet']}", max_output_tokens=400).text
        msg = EmailMessage()
        msg["To"], msg["Subject"], msg["In-Reply-To"] = h["From"], "Re: " + h.get("Subject", ""), h.get("Message-ID", "")
        msg.set_content(reply)
        gmail.users().drafts().create(userId="me", body={"message": {"threadId": full["threadId"], "raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}}).execute()
        done.add(m["id"])
    for m in sent:
        sb("POST", "knowledge", json={"content": gmail.users().messages().get(userId="me", id=m["id"]).execute()["snippet"], "source": "sent reply"})
        done.add(m["id"])
    state.set("done", list(done)[-2000:])
    return {"drafts": len(msgs), "learned": len(sent)}