Chase overdue invoices every Monday

from collections import defaultdict
from datetime import date
from clickruntime import on_trigger, credentials, http, ai, notify

REALM_ID = "1234567890"
API = f"https://quickbooks.api.intuit.com/v3/company/{REALM_ID}"

def qb(method, path, **kw):
    headers = {"Authorization": f"Bearer {credentials.connection('quickbooks', 'company')}", "Accept": "application/json"}
    resp = http.request(method, f"{API}{path}", headers=headers, params={"minorversion": 73, **kw.pop("params", {})}, **kw)
    resp.raise_for_status()
    return resp.json()

def query(sql):
    return qb("GET", "/query", params={"query": sql})["QueryResponse"]

@on_trigger
def run(event):
    today = date.today().isoformat()
    invoices = query(f"select * from Invoice where Balance > '0' and DueDate < '{today}'").get("Invoice", [])
    by_customer = defaultdict(list)
    for inv in invoices:
        name = inv["CustomerRef"]["name"]
        note = ai.generate(f"Write a two-sentence polite payment reminder to {name} for invoice {inv['DocNumber']}, "
                           f"balance ${inv['Balance']:,.2f}, due {inv['DueDate']}.", max_output_tokens=120).text
        qb("POST", "/invoice", json={"Id": inv["Id"], "SyncToken": inv["SyncToken"], "sparse": True,
                                     "CustomerMemo": {"value": note[:1000]}})
        qb("POST", f"/invoice/{inv['Id']}/send")
        by_customer[name].append(f"  - #{inv['DocNumber']}: ${inv['Balance']:,.2f}, due {inv['DueDate']}")
    if by_customer:
        notify.email_me(f"Resent {len(invoices)} overdue invoices",
                        "\n".join(f"{c}\n" + "\n".join(lines) for c, lines in sorted(by_customer.items())))
    return {"resent": len(invoices)}