Get a daily email about low Shopify stock

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

STORE = "your-store.myshopify.com"

def gql(query, variables=None):
    resp = http.post(f"https://{STORE}/admin/api/2025-07/graphql.json", json={"query": query, "variables": variables or {}},
                     headers={"X-Shopify-Access-Token": credentials.connection("shopify", "store")})
    return resp.raise_for_status() or resp.json()["data"]

@on_trigger
def run(event):
    orders = gql('query($q: String!) { orders(first: 250, query: $q) { nodes { lineItems(first: 50) { nodes { quantity variant { id } } } } } }',
                 {"q": f"created_at:>={date.today() - timedelta(days=30)}"})["orders"]["nodes"]
    sold = Counter()
    for o in orders:
        sold.update({li["variant"]["id"]: li["quantity"] for li in o["lineItems"]["nodes"] if li["variant"]})
    low, idle = [], []
    for v in gql("{ productVariants(first: 250) { nodes { id displayName inventoryQuantity } } }")["productVariants"]["nodes"]:
        if sold[v["id"]]:
            days = v["inventoryQuantity"] / (sold[v["id"]] / 30)
            if days < 14:
                low.append(f"{v['displayName']}: {v['inventoryQuantity']} left, about {days:.0f} days")
        elif v["inventoryQuantity"] > 0:
            idle.append(f"{v['displayName']}: {v['inventoryQuantity']} in stock, no sales in 30 days")
    if not low and not idle:
        return {"low": 0}
    text = "Running low:\n" + "\n".join(low or ["none"]) + "\n\nNot selling:\n" + "\n".join(idle or ["none"])
    try:
        if low:
            text += "\n\nDraft to supplier:\n" + ai.generate("\n".join(low), system="Write a short, polite reorder request for these items.", max_output_tokens=250).text
    except (ai.AINotIncluded, ai.AILimitReached):
        pass
    notify.email_me(f"Stock check: {len(low)} low, {len(idle)} not selling", text)
    return {"low": len(low), "idle": len(idle)}