Pull key fields from emailed invoices and POs

import base64
from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, ai, notify, report_fetched

GRAPH = "https://graph.microsoft.com/v1.0"
DONE_FOLDER_ID = "AAMkAD...processed"

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}
    since = state.get("since") or datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ")
    msgs = http.get(f"{GRAPH}/me/messages", headers=h, params={
        "$filter": f"receivedDateTime gt {since} and hasAttachments eq true",
        "$select": "id,subject,from,receivedDateTime", "$orderby": "receivedDateTime asc"}).json()["value"]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    lines = []
    for m in msgs:
        for att in http.get(f"{GRAPH}/me/messages/{m['id']}/attachments", headers=h).json()["value"]:
            if att.get("contentType") != "application/pdf" and not att["name"].lower().endswith((".txt", ".csv")):
                continue
            text = base64.b64decode(att["contentBytes"]).decode("latin-1")[:12000]
            f = ai.generate(text, system="Extract fields from this purchase order, invoice or timesheet.", max_output_tokens=200,
                            json_schema={"type": "object", "properties": {"type": {"type": "string"}, "supplier": {"type": "string"},
                                         "total": {"type": "string"}, "due_date": {"type": "string"}}}).json
            lines.append(f"{f['type']}: {f['supplier']}, {f['total']}, due {f['due_date']} ({att['name']})")
        http.post(f"{GRAPH}/me/messages/{m['id']}/move", headers=h, json={"destinationId": DONE_FOLDER_ID})
    state.set("since", msgs[-1]["receivedDateTime"])
    notify.email_me(f"{len(lines)} documents read", "\n".join(lines))
    return {"documents": len(lines)}