Draft replies to Page questions for your approval

from datetime import datetime, timezone
from clickruntime import on_trigger, on_event, credentials, http, state, ai, notify

G = "https://graph.facebook.com/v21.0"
PAGE_ID = "104857600000000"

def page_token():
    user = credentials.connection("facebook", "work")
    return http.get(f"{G}/{PAGE_ID}", params={"fields": "access_token", "access_token": user}).json()["access_token"]

NOTES = "Northwind mugs are dishwasher safe, ship in 2-3 days, and come in 4 colours."

@on_trigger
def draft(event):
    token = page_token()
    since = state.get("since") or int(datetime.now(timezone.utc).timestamp()) - 900
    posts = http.get(f"{G}/{PAGE_ID}/posts", params={"limit": 10, "access_token": token}).json()["data"]
    drafts = state.get("drafts") or {}
    for p in posts:
        for c in http.get(f"{G}/{p['id']}/comments", params={"since": since, "fields": "message,permalink_url",
                                                              "access_token": token}).json()["data"]:
            if "?" not in c["message"]:
                continue
            reply = ai.generate(f"Product notes: {NOTES}\nWrite a short friendly reply to: {c['message'][:500]}",
                                max_output_tokens=120).text.strip()
            drafts[c["id"]] = reply
            notify.email_me("Reply draft to approve", f"{c['message']}\n{c['permalink_url']}\n\nDraft: {reply}\n\n"
                            f'Approve by posting {{"approve": "{c["id"]}"}} to this automation\'s link.')
    state.set("drafts", drafts)
    state.set("since", int(datetime.now(timezone.utc).timestamp()))
    return {"drafts": len(drafts)}

@on_event
def approve(event):
    drafts = state.get("drafts") or {}
    cid = event.json.get("approve")
    if cid not in drafts:
        return {"error": "unknown comment"}
    http.post(f"{G}/{cid}/comments", data={"message": drafts.pop(cid), "access_token": page_token()}).raise_for_status()
    state.set("drafts", drafts)
    return {"replied": cid}