Draft a weekly blog post about one of your products

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

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

@on_trigger
def run(event):
    done = set(state.get("covered") or [])
    products = gql('{ products(first: 100, query: "status:active") { nodes { id title 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]}", json_schema=SCHEMA, max_output_tokens=1500,
                       system="Write a friendly, useful 600-word blog post about this product. Return a title and an HTML body.").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"}}})
    notify.slack(f"New blog draft ready to review: {post['title']} (about {product['title']})", channel="#marketing")
    state.set("covered", sorted(done | {product["id"]}))
    return {"written": product["title"]}