Answer support emails from your FAQ and escalate the rest to Telegram

import base64
from email.message import EmailMessage
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched
G = "https://gmail.googleapis.com/gmail/v1/users/me"
FAQ = "Orders ship within 2 working days. Returns are free within 30 days. We ship to the UK, EU, US and Canada."
SCHEMA = {"type": "object", "properties": {"confident": {"type": "boolean"}, "reply": {"type": "string"}}, "required": ["confident", "reply"]}
@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    seen = set(state.get("seen") or [])
    msgs = [m for m in http.get(f"{G}/messages", headers=h, params={"q": "to:support@ newer_than:1d -from:me"}).json().get("messages", []) if m["id"] not in seen]
    report_fetched(len(msgs))
    if not msgs:
        return {"new": 0}
    for m in msgs:
        msg = http.get(f"{G}/messages/{m['id']}", headers=h, params={"format": "metadata", "metadataHeaders": ["From", "Subject", "Message-ID"]}).json()
        hdr = {x["name"]: x["value"] for x in msg["payload"]["headers"]}
        r = ai.generate([f"FAQ:\n{FAQ}", f"Customer email:\n{msg['snippet']}", "Answer only from the FAQ. confident=false if it is not covered or the customer is upset."],
                        json_schema=SCHEMA, max_output_tokens=300).json
        if r["confident"]:
            e = EmailMessage(); e["To"] = hdr["From"]; e["Subject"] = "Re: " + hdr.get("Subject", ""); e["In-Reply-To"] = hdr.get("Message-ID", ""); e.set_content(r["reply"])
            http.post(f"{G}/messages/send", headers=h, json={"raw": base64.urlsafe_b64encode(e.as_bytes()).decode(), "threadId": msg["threadId"]})
        else:
            bot = credentials.secret("TELEGRAM_BOT_TOKEN")
            http.post(f"https://api.telegram.org/bot{bot}/sendMessage", json={"chat_id": credentials.secret("TELEGRAM_CHAT_ID"),
                      "text": f"Needs you: {hdr['From']}\n{hdr.get('Subject')}\n{msg['snippet']}"})
        seen.add(m["id"])
    state.set("seen", list(seen)[-1000:])
    return {"handled": len(msgs)}