Import new CSV files into an Excel table

GRAPH = "https://graph.microsoft.com/v1.0"
import csv, io
from clickruntime import on_trigger, credentials, http, state, report_fetched

FOLDER = "/me/drive/root:/Imports"
TABLE = "/me/drive/root:/Data/data.xlsx:/workbook/tables/Data/rows/add"
COLS = 5

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}
    url = state.get("delta") or f"{GRAPH}{FOLDER}:/delta"
    files, page = [], {}
    while url:
        page = http.get(url, headers=h).json()
        files += [f for f in page["value"] if f.get("file") and f["name"].lower().endswith(".csv") and not f.get("deleted")]
        url = page.get("@odata.nextLink")
    report_fetched(len(files))
    if not files:
        state.set("delta", page.get("@odata.deltaLink"))
        return {"summary": "Nothing new"}
    added = 0
    for f in files:
        text = http.get(f"{GRAPH}/me/drive/items/{f['id']}/content", headers=h).content.decode("utf-8-sig")
        rows = [(r + [""] * COLS)[:COLS] for r in list(csv.reader(io.StringIO(text)))[1:] if any(r)]
        if rows:
            http.post(f"{GRAPH}{TABLE}", headers=h, json={"values": rows}).raise_for_status()
            added += len(rows)
    state.set("delta", page.get("@odata.deltaLink"))
    return {"files": len(files), "rows": added}