Post a weekly Shopify sales report in Slack

from datetime import date, timedelta
from collections import Counter
from clickruntime import on_trigger, credentials, http, notify, state, 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"]

Q = """query($q: String!, $after: String) { orders(first: 100, query: $q, after: $after) { pageInfo { hasNextPage endCursor }
  nodes { totalPriceSet { shopMoney { amount } } lineItems(first: 50) { nodes { title quantity } } } } }"""

@on_trigger
def run(event):
    end = date.today() - timedelta(days=date.today().weekday())
    q, after, revenue, count, items = f"created_at:>={end - timedelta(days=7)} created_at:<{end} -status:cancelled", None, 0.0, 0, Counter()
    while True:
        page = gql(Q, {"q": q, "after": after})["orders"]
        for o in page["nodes"]:
            count += 1
            revenue += float(o["totalPriceSet"]["shopMoney"]["amount"])
            items.update({li["title"]: li["quantity"] for li in o["lineItems"]["nodes"]})
        if not page["pageInfo"]["hasNextPage"]:
            break
        after = page["pageInfo"]["endCursor"]
    prev = state.get("last") or {}
    text = f"Last week: {count} orders, {revenue:,.2f} revenue, {revenue / max(count, 1):,.2f} average\nTop: " + ", ".join(f"{t} ({n})" for t, n in items.most_common(5))
    try:
        text += "\n" + ai.generate(f"This week {count} orders {revenue:.0f}; last week {prev}", system="One short sentence on the change.", max_output_tokens=60).text
    except (ai.AINotIncluded, ai.AILimitReached):
        pass
    notify.slack(text, channel="#team")
    state.set("last", {"orders": count, "revenue": round(revenue)})
    return {"orders": count}