Sort your Outlook inbox and get urgent emails on Telegram

GRAPH = "https://graph.microsoft.com/v1.0"
TG = "https://api.telegram.org"
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched

MY_CHAT_ID = 123456789
SCHEMA = {"type": "object", "properties": {"category": {"type": "string"}, "urgent": {"type": "boolean"},
          "summary": {"type": "string"}}, "required": ["category", "urgent", "summary"]}

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}
    since = state.get("since") or "2026-01-01T00:00:00Z"
    msgs = http.get(f"{GRAPH}/me/mailFolders/inbox/messages", headers=h, params={"$filter": f"receivedDateTime gt {since}",
                    "$orderby": "receivedDateTime", "$select": "id,subject,from,bodyPreview,receivedDateTime"}).json()["value"]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    bot = f"{TG}/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}"
    for m in msgs:
        r = ai.generate(f"From: {m['from']['emailAddress']['address']}\n{m['subject']}\n{m['bodyPreview'][:1500]}",
                        system="Categorise as Clients, Suppliers, Finance, Newsletters or Other. Urgent = needs action today. Summary: one line.",
                        json_schema=SCHEMA, max_output_tokens=80).json
        http.patch(f"{GRAPH}/me/messages/{m['id']}", headers=h, json={"categories": [r["category"]]})
        if r["urgent"]:
            http.post(f"{bot}/sendMessage", json={"chat_id": MY_CHAT_ID, "text": f"❗ {m['from']['emailAddress']['address']}: {r['summary']}"})
    state.set("since", msgs[-1]["receivedDateTime"])
    return {"sorted": len(msgs)}