Reply to new lead emails fast and get a Telegram ping

import base64
from email.mime.text import MIMEText
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, ai, report_fetched

CHAT_ID, LABEL_ID = "your-telegram-chat-id", "Label_LeadReplied"
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "summary": {"type": "string"}, "reply": {"type": "string"}}}

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    msgs = gmail.users().messages().list(userId="me", q="to:hello@northwind.example -label:LeadReplied newer_than:1d").execute().get("messages", [])
    report_fetched(len(msgs))
    if not msgs:
        return {"leads": 0}
    token = credentials.secret("TELEGRAM_BOT_TOKEN")
    for m in msgs:
        msg = gmail.users().messages().get(userId="me", id=m["id"], format="metadata").execute()
        hdr = {h["name"]: h["value"] for h in msg["payload"]["headers"]}
        out = ai.generate(f"Lead email:\n{msg['snippet']}\nScore 1-10 for fit, summarise in one line, write a friendly first reply.",
                          json_schema=SCHEMA, max_output_tokens=500).json
        mime = MIMEText(out["reply"]); mime["To"] = hdr["From"]; mime["Subject"] = "Re: " + hdr.get("Subject", "")
        gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(mime.as_bytes()).decode(), "threadId": msg["threadId"]}).execute()
        gmail.users().messages().modify(userId="me", id=m["id"], body={"addLabelIds": [LABEL_ID]}).execute()
        http.post(f"https://api.telegram.org/bot{token}/sendMessage",
                  json={"chat_id": CHAT_ID, "text": f"New lead ({out['score']}/10): {hdr['From']}\n{out['summary']}"})
    return {"leads": len(msgs)}