Approve X posts by replying to an email

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

ME = "me@example.com"

def gmail():
    return build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()

@on_event
def topic(event):
    text = ai.generate(f"Write one X post under 260 characters about: {(event.json or {}).get('topic', '')}", max_output_tokens=100).text.strip()
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, "X post for approval"
    msg.set_content(f"{text}\n\nReply 'approve' to publish.")
    sent = gmail().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
    state.set("drafts", {**(state.get("drafts") or {}), sent["threadId"]: text})
    return {"thread": sent["threadId"]}

@on_trigger
def check(event):
    drafts = state.get("drafts") or {}
    if not drafts:
        return {"published": 0}
    for thread_id, text in list(drafts.items()):
        replies = gmail().threads().get(userId="me", id=thread_id, format="minimal").execute()["messages"][1:]
        if any("approve" in m.get("snippet", "").lower() for m in replies):
            http.post("https://api.x.com/2/tweets", headers={"Authorization": "Bearer " + credentials.connection("x", "main")},
                      json={"text": text}).raise_for_status()
            del drafts[thread_id]
    state.set("drafts", drafts)
    return {"waiting": len(drafts)}