Turn new Shopify products into blog drafts

from clickruntime import on_trigger, credentials, http, notify, state, ai, report_fetched

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"]

BLOG_ID = "gid://shopify/Blog/123456789"
SCHEMA = {"type": "object", "properties": {"title": {"type": "string"}, "html": {"type": "string"}}}

@on_trigger
def run(event):
    since = state.get("since") or "2026-01-01T00:00:00Z"
    products = gql(f'{{ products(first: 20, sortKey: CREATED_AT, query: "status:active created_at:>{since}") {{ nodes {{ title description createdAt }} }} }}')["products"]["nodes"]
    report_fetched(len(products))
    if not products:
        return {"drafts": 0}
    for p in products:
        post = ai.generate(f"Product: {p['title']}\n{p['description'][:2000]}", json_schema=SCHEMA, max_output_tokens=1500,
                           system="Write a warm 500-word blog post introducing this new product. Return a title and an HTML body.").json
        gql("mutation($a: ArticleCreateInput!) { articleCreate(article: $a) { article { id } } }",
            {"a": {"blogId": BLOG_ID, "title": post["title"], "body": post["html"], "isPublished": False, "author": {"name": "Store team"}}})
        notify.email_me(f"Blog draft ready: {post['title']}", f"A draft about {p['title']} is in Online Store > Blog posts.")
    state.set("since", products[-1]["createdAt"])
    return {"drafts": len(products)}