Get an evening summary of WhatsApp conversations

from collections import defaultdict
from clickruntime import on_event, on_trigger, state, ai, notify

@on_event
def store(event):
    value = event.json["entry"][0]["changes"][0]["value"]
    log = state.get("today") or []
    for m in value.get("messages", []):
        log.append({"who": m["from"], "dir": "in", "text": m.get("text", {}).get("body", f"[{m['type']}]"), "ts": m["timestamp"]})
    for s in value.get("statuses", []):
        if s["status"] == "sent":
            log.append({"who": s["recipient_id"], "dir": "out", "text": "", "ts": s["timestamp"]})
    state.set("today", log)
    return {"stored": len(log)}

@on_trigger
def digest(event):
    convos = defaultdict(list)
    for e in sorted(state.get("today") or [], key=lambda e: e["ts"]):
        convos[e["who"]].append(e)
    if not convos:
        return {"conversations": 0}
    waiting = [who for who, es in convos.items() if es[-1]["dir"] == "in"]
    text = "\n\n".join(f"+{who}:\n" + "\n".join(f"{e['dir']}: {e['text']}" for e in es if e["text"]) for who, es in convos.items())
    summary = ai.generate(text[:20000], system="Summarise each conversation in one line.", max_output_tokens=600).text
    notify.email_me(f"WhatsApp today: {len(convos)} conversations",
                    summary + "\n\nStill waiting for a reply:\n" + ("\n".join(f"+{w}" for w in waiting) or "nobody"))
    state.set("today", [])
    return {"conversations": len(convos), "waiting": len(waiting)}