Email suppliers a reorder when stock runs low

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

STORE = "https://shop.example.com/wp-json/wc/v3"

@on_trigger
def run(event):
    auth = (credentials.secret("WOO_KEY"), credentials.secret("WOO_SECRET"))
    products = http.get(f"{STORE}/products", auth=auth, params={"per_page": 100, "stock_status": "instock"}).json()
    low = [p for p in products if p.get("manage_stock") and (p.get("stock_quantity") or 0) < 10]
    sent = set(state.get("sent") or [])
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    ordered = []
    for p in low:
        meta = {m["key"]: m["value"] for m in p["meta_data"]}
        if p["sku"] in sent or not meta.get("supplier_email"):
            continue
        msg = EmailMessage()
        msg["To"], msg["Subject"] = meta["supplier_email"], f"Reorder: {p['sku']} {p['name']}"
        msg.set_content(f"Hello,\n\nPlease send {meta.get('reorder_qty', 50)} units of {p['name']} (SKU {p['sku']}).\n\nThanks")
        gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
        ordered.append(f"{p['name']} ({p['stock_quantity']} left)")
        sent.add(p["sku"])
    if ordered:
        notify.slack("Reorders sent: " + ", ".join(ordered), channel="#inventory")
    state.set("sent", [s for s in sent if s in {p["sku"] for p in low}])
    return {"reordered": len(ordered)}