Flag and summarise emails from your VIP list

from clickruntime import on_trigger, report_fetched, http, credentials, ai, state, notify

def graph(method, path, **kw):
    r = http.request(method, "https://graph.microsoft.com/v1.0" + path, headers={"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}, **kw)
    return r.raise_for_status() or (r.json() if r.content else None)

BOOK = "/me/drive/items/your-workbook-id/workbook"

@on_trigger
def run(event):
    since = state.get("since") or "2026-01-01T00:00:00Z"
    msgs = graph("GET", "/me/mailFolders/inbox/messages", params={"$filter": f"receivedDateTime gt {since}", "$orderby": "receivedDateTime",
                 "$select": "id,subject,from,bodyPreview,receivedDateTime", "$top": 50})["value"]
    if msgs:
        state.set("since", msgs[-1]["receivedDateTime"])
    vips = [str(r["values"][0][0]).lower() for r in graph("GET", f"{BOOK}/tables/VIPs/rows")["value"]] if msgs else []
    hits = [m for m in msgs if any(v and m["from"]["emailAddress"]["address"].lower().endswith(v) for v in vips)]
    report_fetched(len(hits))
    if not hits:
        return {"summary": "No VIP emails"}
    lines = []
    for m in hits:
        graph("PATCH", f"/me/messages/{m['id']}", json={"flag": {"flagStatus": "flagged"}})
        need = ai.generate(f"{m['subject']}\n{m['bodyPreview']}", system="In one line, say what this person needs.", max_output_tokens=60).text.strip()
        lines.append(f"{m['from']['emailAddress']['name']}: {need}")
    notify.email_me(f"{len(hits)} VIP emails", "\n".join(lines))
    return {"vip": len(hits)}