Reply to quote requests with prices from your Supabase products

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, notify, 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)

SCHEMA = {"type": "object", "properties": {"is_quote": {"type": "boolean"}, "items": {"type": "array", "items": {"type": "object",
          "properties": {"product": {"type": "string"}, "qty": {"type": "integer"}}}}}}

@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="to:sales@northwind.com newer_than:1d").execute().get("messages", []) if m["id"] not in done]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    prices = {p["name"].lower(): p["price"] for p in sb("GET", "products?select=name,price")}
    for m in msgs:
        full = gmail.users().messages().get(userId="me", id=m["id"]).execute()
        h, done = {x["name"]: x["value"] for x in full["payload"]["headers"]}, done | {m["id"]}
        req = ai.generate(f"Is this a quote request? List products and quantities.\n{full['snippet']}", json_schema=SCHEMA, max_output_tokens=200).json
        if not req["is_quote"]:
            continue
        lines = [(i["product"], i["qty"], prices.get(i["product"].lower())) for i in req["items"]]
        total = sum(q * p for _, q, p in lines if p)
        body = "\n".join(f"{n}: {q} x {p:.2f} = {q * p:,.2f}" if p else f"{n}: {q} – price on request" for n, q, p in lines)
        msg = EmailMessage()
        msg["To"], msg["Subject"] = h["From"], "Re: " + h.get("Subject", "Your quote")
        msg.set_content(f"Thanks for your request. Here's your quote:\n\n{body}\n\nTotal: {total:,.2f}")
        gmail.users().drafts().create(userId="me", body={"message": {"threadId": full["threadId"], "raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}}).execute()
        sb("POST", "quotes", json={"email": h["From"], "total": total, "lines": body, "message_id": m["id"]})
        if any(p is None for *_, p in lines):
            notify.slack(f"Quote for {h['From']} has unpriced items", channel="#sales")
    state.set("done", list(done)[-1000:])
    return {"emails": len(msgs)}