Archive email attachments to a SharePoint library

GRAPH = "https://graph.microsoft.com/v1.0"
SITE = "contoso.sharepoint.com:/sites/operations:"
import base64
from clickruntime import on_trigger, credentials, http, state, report_fetched

@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/messages", headers=h, params={"$filter": f"hasAttachments eq true and receivedDateTime gt {since}",
                    "$orderby": "receivedDateTime", "$select": "id,subject,from,receivedDateTime"}).json()["value"]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    saved = 0
    for m in msgs:
        for a in http.get(f"{GRAPH}/me/messages/{m['id']}/attachments", headers=h).json()["value"]:
            if a.get("isInline") or "contentBytes" not in a:
                continue
            path = f"{m['receivedDateTime'][:7]}/{a['name']}"
            http.put(f"{GRAPH}/sites/{SITE}/drive/root:/Inbox Files/{path}:/content", headers=h, data=base64.b64decode(a["contentBytes"]))
            log = {"fields": {"Title": a["name"], "Sender": m["from"]["emailAddress"]["address"], "Subject": m["subject"]}}
            http.post(f"{GRAPH}/sites/{SITE}/lists/Attachment Log/items", headers=h, json=log)
            saved += 1
    state.set("since", msgs[-1]["receivedDateTime"])
    return {"saved": saved}