Triage your Gmail and Outlook inboxes with one digest

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, report_fetched, http, credentials, ai, state, notify

api = lambda name, version: build(name, version, credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)

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)

LABELS = {"needs_reply": "Label_1", "fyi": "Label_2", "newsletter": "Label_3", "ignore": "Label_4"}  # your Gmail label ids

@on_trigger
def run(event):
    gmail, seen, since = api("gmail", "v1").users().messages(), set(state.get("seen") or []), state.get("since") or "2026-01-01T00:00:00Z"
    items = [("gmail", m["id"], gmail.get(userId="me", id=m["id"], format="metadata").execute()["snippet"])
             for m in gmail.list(userId="me", q="in:inbox newer_than:1d").execute().get("messages", []) if m["id"] not in seen]
    out = graph("GET", "/me/mailFolders/inbox/messages", params={"$filter": f"receivedDateTime gt {since}", "$select": "id,subject,bodyPreview,receivedDateTime"})["value"]
    items += [("outlook", m["id"], f"{m['subject']}: {m['bodyPreview']}") for m in out]
    report_fetched(len(items))
    if not items:
        return {"summary": "Nothing new"}
    labels = ai.generate("\n".join(f"{i}. {t[:300]}" for i, (_, _, t) in enumerate(items)), system="Label each line needs_reply, fyi, newsletter or ignore.",
                         json_schema={"type": "object", "properties": {"labels": {"type": "array", "items": {"enum": list(LABELS)}}}}, max_output_tokens=400).json["labels"]
    todo = []
    for (box, mid, text), label in zip(items, labels):
        if box == "gmail":
            gmail.modify(userId="me", id=mid, body={"addLabelIds": [LABELS[label]]}).execute()
            seen.add(mid)
        else:
            graph("PATCH", f"/me/messages/{mid}", json={"categories": [label.replace("_", " ").title()]})
        if label == "needs_reply":
            todo.append(f"[{box}] {text[:120]}")
    if todo:
        notify.email_me(f"{len(todo)} emails need a reply", "\n".join(todo))
    state.set("seen", sorted(seen)[-3000:])
    state.set("since", max([since] + [m["receivedDateTime"] for m in out]))
    return {"sorted": len(items), "needs_reply": len(todo)}