Compare stock counts in Notion with Airtable every day

from clickruntime import on_trigger, credentials, http, notify, ai

NOTION_DB, AIRTABLE_BASE, TABLE = "your-database-id", "appXXXXXXXX", "Inventory"

@on_trigger
def run(event):
    nh = {"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"}
    pages = http.post(f"https://api.notion.com/v1/databases/{NOTION_DB}/query", headers=nh, json={"page_size": 100}).json()["results"]
    counted = {p["properties"]["SKU"]["rich_text"][0]["plain_text"]: p["properties"]["Count"]["number"] for p in pages if p["properties"]["SKU"]["rich_text"]}
    recs = http.get(f"https://api.airtable.com/v0/{AIRTABLE_BASE}/{TABLE}", headers={"Authorization": f"Bearer {credentials.secret('AIRTABLE_TOKEN')}"}).json()["records"]
    inv = {r["fields"]["SKU"]: r["fields"] for r in recs if "SKU" in r["fields"]}
    lines = [f"{s}: Notion {counted.get(s)} vs Airtable {inv.get(s, {}).get('Quantity')}" for s in sorted(set(counted) | set(inv))
             if counted.get(s) != inv.get(s, {}).get("Quantity")]
    low = [f"{s}: {f.get('Quantity')} left (reorder at {f['Reorder level']})" for s, f in inv.items()
           if "Reorder level" in f and (f.get("Quantity") or 0) < f["Reorder level"]]
    text = "Mismatches:\n" + ("\n".join(lines) or "None") + "\n\nBelow reorder level:\n" + ("\n".join(low) or "None")
    if low:
        try:
            text += "\n\nSuggestions:\n" + ai.generate("Suggest reorder priorities briefly:\n" + "\n".join(low), max_output_tokens=200).text
        except ai.AIError:
            pass
    notify.email_me(f"Stock check: {len(lines)} mismatches, {len(low)} low", text)
    return {"mismatches": len(lines), "low": len(low)}