Turn emailed orders into purchase orders in Airtable

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

BASE, TABLE = "appXXXXXXXX", "Purchase orders"
SCHEMA = {"type": "object", "properties": {"is_order": {"type": "boolean"}, "delivery_date": {"type": "string"},
          "items": {"type": "array", "items": {"type": "object", "properties": {"item": {"type": "string"}, "qty": {"type": "number"}}}}}}

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()
    seen = set(state.get("seen") or [])
    msgs = [m for m in gmail.messages().list(userId="me", q="subject:order newer_than:2d").execute().get("messages", []) if m["id"] not in seen]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    for m in msgs:
        msg = gmail.messages().get(userId="me", id=m["id"]).execute()
        sender = next(h["value"] for h in msg["payload"]["headers"] if h["name"] == "From")
        po = ai.generate(f"Extract the order lines from this email:\n{msg['snippet']}", json_schema=SCHEMA, max_output_tokens=400).json
        if po.get("is_order"):
            lines = "\n".join(f"{i['qty']} x {i['item']}" for i in po.get("items", []))
            http.post(f"https://api.airtable.com/v0/{BASE}/{TABLE}", headers={"Authorization": f"Bearer {credentials.secret('AIRTABLE_API_KEY')}"},
                      json={"fields": {"From": sender, "Items": lines, "Delivery date": po.get("delivery_date"), "Email ID": m["id"]}})
        seen.add(m["id"])
    state.set("seen", list(seen)[-1000:])
    return {"checked": len(msgs)}