Post an AI summary of each Gong call to Slack

from datetime import datetime, timezone
from clickruntime import on_trigger, state_initializer, credentials, notify, http, state, ai, report_fetched

@state_initializer
def init():
    state.set("since", datetime.now(timezone.utc).isoformat())

@on_trigger
def run(event):
    auth = (credentials.secret("GONG_ACCESS_KEY"), credentials.secret("GONG_ACCESS_SECRET"))
    since = state.get("since")
    now = datetime.now(timezone.utc).isoformat()
    resp = http.get("https://api.gong.io/v2/calls", auth=auth, params={"fromDateTime": since})
    calls = resp.json().get("calls", []) if resp.status_code != 404 else []
    report_fetched(len(calls))
    if not calls:
        return {"posted": 0}
    for call in calls:
        tr = http.post("https://api.gong.io/v2/calls/transcript", auth=auth,
                       json={"filter": {"callIds": [call["id"]]}}).json()["callTranscripts"][0]
        text = " ".join(s["text"] for part in tr["transcript"] for s in part["sentences"])
        summary = ai.generate(f"Summarise this sales call in 5 bullets, then list next steps with owners.\n\n{text[:60000]}",
                              max_output_tokens=600).text
        notify.slack(f"*{call['title']}*\n{summary}\n{call['url']}", channel="#sales-calls")
    state.set("since", now)
    return {"posted": len(calls)}