Catch Shopify pricing and discount mistakes

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

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"]

MIN_PRICE, MAX_CHANGE, MAX_DISCOUNT = 5.0, 0.30, 0.40

@on_trigger
def run(event):
    variants = gql("{ productVariants(first: 250) { nodes { id displayName price } } }")["productVariants"]["nodes"]
    before, problems = state.get("prices") or {}, []
    for v in variants:
        price, old = float(v["price"]), before.get(v["id"])
        if price < MIN_PRICE:
            problems.append(f"{v['displayName']} is {price:.2f}, below the {MIN_PRICE:.2f} floor")
        elif old and abs(price - old) / old > MAX_CHANGE:
            problems.append(f"{v['displayName']} changed from {old:.2f} to {price:.2f}")
    discounts = gql("""{ discountNodes(first: 100, query: "status:active") { nodes { discount { ... on DiscountCodeBasic { title
        customerGets { value { ... on DiscountPercentage { percentage } } } } } } } }""")["discountNodes"]["nodes"]
    for d in discounts:
        pct = ((d["discount"].get("customerGets") or {}).get("value") or {}).get("percentage")
        if pct and pct > MAX_DISCOUNT:
            problems.append(f"Discount {d['discount']['title']} is {pct:.0%}")
    if problems:
        notify.email_me(f"{len(problems)} Shopify pricing issues", "\n".join(problems))
    state.set("prices", {v["id"]: float(v["price"]) for v in variants})
    return {"problems": len(problems)}