Get Telegram nudges for stale leads in your Notion CRM

from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, ai

DB_ID, CHAT_ID = "your-notion-crm-database-id", "your-telegram-chat-id"

@on_trigger
def run(event):
    cutoff = str(date.today() - timedelta(days=7))
    leads = http.post(f"https://api.notion.com/v1/databases/{DB_ID}/query",
                      headers={"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"},
                      json={"filter": {"and": [{"property": "Last contacted", "date": {"before": cutoff}},
                                               {"property": "Status", "select": {"does_not_equal": "Closed"}}]}}).json()["results"]
    token = credentials.secret("TELEGRAM_BOT_TOKEN") if leads else None
    for lead in leads[:15]:
        p = lead["properties"]
        name = "".join(t["plain_text"] for t in p["Name"]["title"])
        notes = "".join(t["plain_text"] for t in p["Notes"]["rich_text"])[:1000]
        days = (date.today() - date.fromisoformat(p["Last contacted"]["date"]["start"][:10])).days
        try:
            draft = ai.generate(f"Lead: {name}\nNotes: {notes}", system="Write a short, friendly follow-up message (2-3 sentences).", max_output_tokens=150).text
        except ai.AIError:
            draft = f"Hi {name}, just checking in on our last conversation. Is now a good time to pick it up?"
        http.post(f"https://api.telegram.org/bot{token}/sendMessage",
                  json={"chat_id": CHAT_ID, "text": f"{name}: {days} days since last contact\n{lead['url']}\n\n{draft}"})
    return {"stale": len(leads)}