Turn a document into a blog post you approve by email

import base64, io
from email.mime.text import MIMEText
from pypdf import PdfReader
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, on_trigger, credentials, http, state, ai

APPROVER = "director@example.org"
SCHEMA = {"type": "object", "properties": {k: {"type": "string"} for k in ["title", "excerpt", "body_html"]}, "required": ["title", "excerpt", "body_html"]}
WP = "https://blog.example.com/wp-json/wp/v2"

def wp(method, path, **kw):
    r = http.request(method, f"{WP}/{path}", auth=(credentials.secret("WP_USER"), credentials.secret("WP_APP_PASSWORD")), **kw)
    r.raise_for_status()
    return r.json()
def send_email(to, subject, text, thread_id=None, reply_to=None):
    mime = MIMEText(text)
    mime["to"], mime["subject"] = to, subject
    if reply_to:
        mime["In-Reply-To"] = reply_to
    body = {"raw": base64.urlsafe_b64encode(mime.as_bytes()).decode(), **({"threadId": thread_id} if thread_id else {})}
    return build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(userId="me", body=body).execute()

@on_event
def handle(event):
    text = " ".join(p.extract_text() or "" for p in PdfReader(io.BytesIO(event.body.encode("latin-1"))).pages)[:20000]
    art = ai.generate(f"Turn this report into a 900-word blog post for supporters (HTML body):\n{text}", json_schema=SCHEMA, max_output_tokens=2048).json
    post = wp("POST", "posts", json={"title": art["title"], "excerpt": art["excerpt"], "content": art["body_html"], "status": "draft"})
    sent = send_email(APPROVER, f"Approve post: {art['title']}", f"Preview: {post['link']}&preview=true\n\nReply 'approve' to publish.")
    state.set("waiting", (state.get("waiting") or []) + [{"thread": sent["threadId"], "post": post["id"]}])
    return {"draft": post["id"]}

@on_trigger
def check_replies(event):
    gmail, waiting = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users(), state.get("waiting") or []
    for w in list(waiting):
        msgs = gmail.threads().get(userId="me", id=w["thread"], format="full").execute()["messages"][1:]
        if any(m.get("snippet", "").lower().startswith("approve") for m in msgs):
            link = wp("POST", f"posts/{w['post']}", json={"status": "publish"})["link"]
            send_email(APPROVER, "Published", link, thread_id=w["thread"])
            waiting.remove(w)
    state.set("waiting", waiting)
    return {"waiting": len(waiting)}