Draft social posts into Airtable and approve them on Telegram

import feedparser
from clickruntime import on_trigger, credentials, http, ai, state

BASE_ID, CHAT_ID = "appXXXXXXXXXXXXXX", "123456789"
FEEDS = ["https://example.com/industry-news/rss"]

@on_trigger
def run(event):
    api = f"https://api.airtable.com/v0/{BASE_ID}/Posts"
    headers = {"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}
    tg = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage"
    seen = set(state.get("seen_links") or [])
    entries = [e for feed in FEEDS for e in feedparser.parse(feed).entries if e.link not in seen][:5]
    for e in entries:
        draft = ai.generate(f"Title: {e.title}\nSummary: {e.get('summary', '')[:1500]}",
                            system="Write a LinkedIn post under 80 words sharing this article with one practical takeaway.",
                            max_output_tokens=200).text
        http.post(api, headers=headers, json={"records": [{"fields": {"Article": e.link, "Draft": draft, "Status": "Draft"}}]}).raise_for_status()
        http.post(tg, json={"chat_id": CHAT_ID, "text": f"New draft:\n\n{draft}\n\n{e.link}"})
        seen.add(e.link)
    state.set("seen_links", sorted(seen)[-500:])
    approved = http.get(api, headers=headers, params={"filterByFormula": "{Status}='Approved'"}).json()["records"]
    for rec in approved:
        http.post(tg, json={"chat_id": CHAT_ID, "text": f"Ready to post:\n\n{rec['fields'].get('Draft', '')}"})
        http.patch(api, headers=headers, json={"records": [{"id": rec["id"], "fields": {"Status": "Ready to post"}}]}).raise_for_status()
    return {"drafted": len(entries), "approved": len(approved)}