Turn action emails in Outlook into Planner tasks with a Teams alert

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

PLAN_ID, BUCKET_ID, TEAM_ID, CHANNEL_ID = "your-plan-id", "your-bucket-id", "your-team-id", "your-channel-id"
GRAPH = "https://graph.microsoft.com/v1.0"

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}
    q = "flag/flagStatus eq 'flagged' or contains(subject,'action')"
    msgs = http.get(f"{GRAPH}/me/messages", headers=h, params={"$filter": q, "$top": 50, "$select": "id,subject,from,webLink"}).json()["value"]
    done = set(state.get("done") or [])
    new = [m for m in msgs if m["id"] not in done]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    for m in new:
        title = m["subject"]
        try:
            title = ai.generate(f"Rewrite as a short task title: {m['subject']}", max_output_tokens=30).text.strip()
        except ai.AIError:
            pass
        task = http.post(f"{GRAPH}/planner/tasks", headers=h, json={"planId": PLAN_ID, "bucketId": BUCKET_ID, "title": title}).json()
        sender = m["from"]["emailAddress"]["address"]
        http.post(f"{GRAPH}/teams/{TEAM_ID}/channels/{CHANNEL_ID}/messages", headers=h,
                  json={"body": {"contentType": "html", "content": f"New task: <b>{title}</b> from {sender} (<a href='{m['webLink']}'>email</a>)"}})
        done.add(m["id"])
    state.set("done", list(done)[-500:])
    return {"tasks": len(new)}