Get emailed when Shopify orders stop or run late

from datetime import datetime, timedelta, timezone
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"]

QUIET_HOURS, SLA_HOURS = 4, 48

@on_trigger
def run(event):
    now = datetime.now(timezone.utc)
    last = gql("{ orders(first: 1, sortKey: CREATED_AT, reverse: true) { nodes { name createdAt } } }")["orders"]["nodes"][0]
    gap = (now - datetime.fromisoformat(last["createdAt"].replace("Z", "+00:00"))).total_seconds() / 3600
    if gap > QUIET_HOURS and state.get("quiet_after") != last["name"]:
        notify.email_me("No Shopify orders lately", f"No orders for {gap:.1f} hours. The last was {last['name']}. Check that checkout is working.")
        state.set("quiet_after", last["name"])
    cutoff = (now - timedelta(hours=SLA_HOURS)).strftime("%Y-%m-%dT%H:%M:%SZ")
    late = gql(f'{{ orders(first: 50, query: "financial_status:paid fulfillment_status:unfulfilled created_at:<{cutoff}") {{ nodes {{ name }} }} }}')["orders"]["nodes"]
    told = set(state.get("late") or [])
    new = [o["name"] for o in late if o["name"] not in told]
    if new:
        notify.email_me(f"{len(new)} orders late to ship", "Waiting over 2 days: " + ", ".join(new))
    state.set("late", sorted(told | set(new))[-500:])
    return {"gap_hours": round(gap, 1), "late": len(new)}