Draft on-brand social posts and approve them in Telegram

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, on_event, credentials, http, ai, state

DOC_ID, CHAT_ID = "your-guidelines-doc-id", "your-telegram-chat-id"

def tg(method, **body):
    return http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/{method}", json=body)

@on_trigger
def run(event):
    doc = build("docs", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    body = doc.documents().get(documentId=DOC_ID).execute()["body"]["content"]
    guide = "".join(r.get("textRun", {}).get("content", "") for b in body for r in b.get("paragraph", {}).get("elements", []))
    schema = {"type": "object", "properties": {"posts": {"type": "array", "items": {"type": "string"}}}}
    posts = ai.generate(f"Brand guidelines:\n{guide[:6000]}\n\nWrite 3 social posts for today.", json_schema=schema, max_output_tokens=600).json["posts"]
    for i, p in enumerate(posts):
        key = f"{event.scheduled_time or 'manual'}-{i}"
        state.set(f"post:{key}", {"text": p, "status": "pending"})
        tg("sendMessage", chat_id=CHAT_ID, text=p, reply_markup={"inline_keyboard": [[
            {"text": "Approve", "callback_data": f"ok|{key}"}, {"text": "Reject", "callback_data": f"no|{key}"}]]})
    return {"drafts": len(posts)}

@on_event
def decide(event):
    cb = (event.json or {}).get("callback_query") or {}
    action, _, key = cb.get("data", "").partition("|")
    post = state.get(f"post:{key}")
    if not post or post["status"] != "pending":
        return {"skipped": True}
    post["status"] = "approved" if action == "ok" else "rejected"
    state.set(f"post:{key}", post)
    tg("answerCallbackQuery", callback_query_id=cb["id"], text=post["status"])
    tg("editMessageText", chat_id=cb["message"]["chat"]["id"], message_id=cb["message"]["message_id"], text=f"[{post['status']}] {post['text']}")
    return {"post": key, "status": post["status"]}