Mark digital orders as fulfilled automatically

from clickruntime import on_trigger, credentials, http, report_fetched

STORE = "your-store.myshopify.com"

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

FIND = """{ orders(first: 50, query: "financial_status:paid fulfillment_status:unfulfilled") { nodes {
  id name lineItems(first: 50) { nodes { product { tags } } }
  fulfillmentOrders(first: 5) { nodes { id status } } } } }"""
FULFIL = """mutation($f: FulfillmentInput!) { fulfillmentCreate(fulfillment: $f) {
  fulfillment { id } userErrors { message } } }"""

@on_trigger
def run(event):
    orders = [o for o in gql(FIND)["orders"]["nodes"]
              if o["lineItems"]["nodes"] and all("digital" in ((li["product"] or {}).get("tags") or [])
                                                for li in o["lineItems"]["nodes"])]
    report_fetched(len(orders))
    if not orders:
        return {"fulfilled": 0}
    done = []
    for o in orders:
        open_fos = [{"fulfillmentOrderId": fo["id"]} for fo in o["fulfillmentOrders"]["nodes"] if fo["status"] == "OPEN"]
        if open_fos:
            gql(FULFIL, {"f": {"lineItemsByFulfillmentOrder": open_fos, "notifyCustomer": True}})
            done.append(o["name"])
    return {"fulfilled": done}