Draft a weekly blog post about one of your products

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

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

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

@on_trigger
def run(event):
    done = set(state.get("featured") or [])
    products = gql("{ products(first: 100, query: \"status:active\") { nodes { id title handle description } } }")["products"]["nodes"]
    product = next((p for p in products if p["id"] not in done), None)
    if not product:
        return {"written": None}
    post = ai.generate(f"Product: {product['title']}\n{product['description'][:2000]}",
                       system="Write a friendly, useful 600-word blog post featuring this product. Return a title and HTML body.",
                       json_schema=SCHEMA, max_output_tokens=1500).json
    gql("""mutation($a: ArticleCreateInput!) { articleCreate(article: $a) { article { id } userErrors { message } } }""",
        {"a": {"blogId": BLOG_ID, "title": post["title"], "body": post["html"], "isPublished": False,
               "author": {"name": "Store team"}}})
    state.set("featured", sorted(done | {product["id"]}))
    return {"written": product["title"]}