Get a Slack alert when orders stop or ship 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 = 3, 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"))
    if gap > timedelta(hours=QUIET_HOURS) and state.get("quiet_after") != last["name"]:
        notify.slack(f"No Shopify orders for {gap.total_seconds() / 3600:.1f} hours (last was {last['name']}). Is checkout working?", channel="#ops")
        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 createdAt }} }} }}')["orders"]["nodes"]
    alerted = set(state.get("late") or [])
    new = [o for o in late if o["name"] not in alerted]
    if new:
        notify.slack(f"{len(new)} paid orders waiting over {SLA_HOURS}h to ship: " + ", ".join(o["name"] for o in new), channel="#ops")
    state.set("late", sorted(alerted | {o["name"] for o in new})[-500:])
    return {"gap_hours": round(gap.total_seconds() / 3600, 1), "late": len(new)}