Copy new Shopify customers to Google Sheets

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, report_fetched

STORE = "your-store.myshopify.com"
SHEET_ID = "your-spreadsheet-id"
QUERY = """query($q: String!) { customers(first: 100, query: $q, sortKey: CREATED_AT) { nodes {
  createdAt displayName defaultEmailAddress { emailAddress marketingState } defaultAddress { country }
  numberOfOrders amountSpent { amount currencyCode } } } }"""

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")})
    resp.raise_for_status()
    return resp.json()["data"]

@on_trigger
def run(event):
    since = state.get("since") or "2026-01-01T00:00:00Z"
    customers = gql(QUERY, {"q": f"created_at:>'{since}'"})["customers"]["nodes"]
    report_fetched(len(customers))
    if not customers:
        return {"new": 0}
    rows = []
    for c in customers:
        email = c.get("defaultEmailAddress") or {}
        rows.append([c["createdAt"][:10], c["displayName"], email.get("emailAddress") or "",
                     (email.get("marketingState") or "").lower().replace("_", " "), (c.get("defaultAddress") or {}).get("country") or "",
                     int(c["numberOfOrders"]), c["amountSpent"]["amount"], c["amountSpent"]["currencyCode"]])
    build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False) \
        .spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Customers!A:H", valueInputOption="USER_ENTERED",
                                        body={"values": rows}).execute()
    state.set("since", max(c["createdAt"] for c in customers))
    return {"new": len(rows)}