Get a morning list of deals that have gone quiet

from collections import defaultdict
from clickruntime import on_trigger, credentials, http, ai, notify

INSTANCE = "https://yourcompany.my.salesforce.com"
API = f"{INSTANCE}/services/data/v61.0"

def soql(headers, q):
    return http.get(f"{API}/query", headers=headers, params={"q": q}).json()["records"]

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    opps = soql(headers, "SELECT Id, Name, StageName, Amount, Owner.Name, LastActivityDate FROM Opportunity "
                         "WHERE IsClosed = false AND (LastActivityDate < LAST_N_DAYS:14 OR LastActivityDate = null) LIMIT 60")
    if not opps:
        return {"stale": 0}
    listing = "\n".join(f"{i + 1}. {o['Name']} | {o['StageName']} | last activity {o['LastActivityDate'] or 'never'}"
                        for i, o in enumerate(opps))
    tips = ai.generate("Suggest one short follow-up for each numbered deal. One line per deal, same numbering.\n" + listing,
                       max_output_tokens=1500).text.splitlines()
    tips = [t.split(".", 1)[-1].strip() for t in tips if t.strip()]
    by_owner = defaultdict(list)
    for i, o in enumerate(opps):
        tip = tips[i] if i < len(tips) else ""
        by_owner[o["Owner"]["Name"]].append(f"- <{INSTANCE}/{o['Id']}|{o['Name']}> ({o['StageName']}): {tip}")
    for owner, lines in by_owner.items():
        notify.slack(f"*{owner}*: {len(lines)} deals with no activity in 14 days\n" + "\n".join(lines), channel="#sales")
    return {"stale": len(opps), "owners": len(by_owner)}