Post new order emails to your fulfilment team

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

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    seen = set(state.get("seen") or [])
    msgs = gmail.users().messages().list(userId="me", q='subject:"Order #" newer_than:1d', maxResults=25).execute().get("messages", [])
    new = [m for m in msgs if m["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    for m in new:
        msg = gmail.users().messages().get(userId="me", id=m["id"], format="metadata", metadataHeaders=["Subject"]).execute()
        subject, snippet = msg["payload"]["headers"][0]["value"], msg["snippet"]
        number = (re.search(r"#(\d+)", subject) or [None, "?"])[1]
        customer = (re.search(r"(?:Customer|Ship to|Name):\s*([A-Z][\w'-]+(?: [A-Z][\w'-]+)*)", snippet) or [None, "unknown"])[1]
        items = re.findall(r"(\d+)\s*[x×]\s*([^,.\n]+)", snippet)
        notify.slack(f"📦 Order #{number} for {customer}\n" + "\n".join(f"• {q} × {n.strip()}" for q, n in items),
                     channel="#fulfilment")
    state.set("seen", [m["id"] for m in msgs])
    return {"orders": len(new)}