Get a morning newsletter digest on Telegram

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

CHAT_ID = "your-telegram-chat-id"

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()
    ids = gmail.messages().list(userId="me", q="label:newsletters newer_than:1d", maxResults=20).execute().get("messages", [])
    items = []
    for m in ids:
        msg = gmail.messages().get(userId="me", id=m["id"], format="metadata", metadataHeaders=["Subject", "From"]).execute()
        subject = next((h["value"] for h in msg["payload"]["headers"] if h["name"] == "Subject"), "")
        items.append(f"{subject}: {msg['snippet'][:400]}")
    bot = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}"
    if not items:
        http.post(f"{bot}/sendMessage", json={"chat_id": CHAT_ID, "text": "No newsletters yesterday."})
        return {"items": 0}
    digest = ai.generate("Write a short morning digest, one line per item:\n" + "\n".join(items), max_output_tokens=600).text
    http.post(f"{bot}/sendMessage", json={"chat_id": CHAT_ID, "text": digest})
    audio = http.post("https://api.openai.com/v1/audio/speech", headers={"Authorization": f"Bearer {credentials.secret('OPENAI_API_KEY')}"},
                      json={"model": "tts-1", "voice": "alloy", "input": digest}).content
    http.post(f"{bot}/sendAudio", data={"chat_id": CHAT_ID}, files={"audio": ("digest.mp3", audio)})
    return {"items": len(items)}