Get AI follow-up suggestions for your deals on Telegram

import time
from clickruntime import on_trigger, credentials, http, ai, state
CHAT_ID = "123456789"
STAGE = "presentationscheduled"
def hs(method, path, **kw):
    r = http.request(method, f"https://api.hubapi.com{path}", headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}, **kw)
    return r.raise_for_status() or (r.json() if r.content else {})
def telegram(text, chat_id=CHAT_ID):
    http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage", json={"chat_id": chat_id, "text": text}).raise_for_status()

@on_trigger
def run(event):
    deals = hs("POST", "/crm/v3/objects/deals/search", json={"filterGroups": [{"filters": [{"propertyName": "dealstage", "operator": "EQ", "value": STAGE}]}],
               "properties": ["dealname", "amount", "hs_date_entered_" + STAGE], "limit": 30})["results"]
    sent = state.get("sent") or {}
    now = time.time()
    due = [d for d in deals if now - sent.get(d["id"], 0) > 3 * 86400]
    if not due:
        return {"suggested": 0}
    lines = []
    for d in due:
        p = d["properties"]
        entered = p.get("hs_date_entered_" + STAGE) or ""
        text = ai.generate(f"Write a friendly 2-sentence follow-up to a prospect about our proposal for {p['dealname']} "
                           f"(value {p.get('amount')}, proposal sent {entered[:10]}). No subject line.", max_output_tokens=120).text.strip()
        lines.append(f"{p['dealname']} ({p.get('amount') or 'no amount'}):\n{text}")
        sent[d["id"]] = now
    telegram("Follow-ups for today\n\n" + "\n\n".join(lines))
    state.set("sent", sent)
    return {"suggested": len(due)}