Get urgent Teams messages flagged to you

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

GRAPH = "https://graph.microsoft.com/v1.0"
TEAM_ID, CHANNEL_ID = "your-team-id", "19:helpdesk-channel-id@thread.tacv2"

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}
    url = state.get("delta_link") or f"{GRAPH}/teams/{TEAM_ID}/channels/{CHANNEL_ID}/messages/delta"
    msgs = []
    while url:
        page = http.get(url, headers=headers).json()
        msgs += page.get("value", [])
        url = page.get("@odata.nextLink")
    first_run = state.get("delta_link") is None
    new = [] if first_run else [m for m in msgs if m.get("messageType") == "message" and not m.get("deletedDateTime")]
    report_fetched(len(new))
    state.set("delta_link", page["@odata.deltaLink"])
    if not new:
        return {"summary": "Nothing new"}
    urgent = []
    for m in new:
        text = re.sub("<[^>]+>", "", m["body"]["content"])[:1000]
        label = ai.generate(f"Is this helpdesk message urgent? Answer urgent or normal.\n{text}", max_output_tokens=5).text
        if "urgent" in label.lower():
            urgent.append(f"{m['from']['user']['displayName']}: {text[:300]}\n{m['webUrl']}")
    if urgent:
        notify.email_me(f"{len(urgent)} urgent Helpdesk messages", "\n\n".join(urgent))
    return {"new": len(new), "urgent": len(urgent)}