Get Slack alerts for deals that are stalling in Zoho CRM

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

ZOHO = "https://www.zohoapis.com/crm/v6"

@on_trigger
def run(event):
    zh = {"Authorization": f"Zoho-oauthtoken {credentials.connection('zoho', 'work')}"}
    cutoff = (date.today() - timedelta(days=14)).isoformat()
    query = ("select Deal_Name, Stage, Amount, Last_Activity_Time from Deals "
             f"where Stage not in ('Closed Won', 'Closed Lost') and Last_Activity_Time < '{cutoff}T00:00:00+00:00' limit 50")
    deals = http.post(f"{ZOHO}/coql", headers=zh, json={"select_query": query}).json().get("data", [])
    flagged = state.get("flagged") or {}
    recent = (date.today() - timedelta(days=3)).isoformat()
    deals = [d for d in deals if flagged.get(d["id"], "") < recent]
    if not deals:
        return {"stalled": 0}
    lines = "\n".join(f"{d['Deal_Name']} | {d['Stage']} | {d.get('Amount')} | last activity {d['Last_Activity_Time'][:10]}" for d in deals)
    tips = ai.generate(f"For each stalled deal, one short next step, one per line:\n{lines}", max_output_tokens=600).text
    notify.slack(f"*Stalled deals ({len(deals)})*\n{tips}", channel="#sales")
    for d in deals:
        flagged[d["id"]] = date.today().isoformat()
    state.set("flagged", flagged)
    return {"stalled": len(deals)}