Approve trend-based Facebook posts from your inbox

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

PAGE_ID, LINK = "1234567890", "https://run.clickruntime.example/t/abc123"

@on_trigger
def run(event):
    used = state.get("used") or []
    topics = [e.title for e in feedparser.parse("https://www.reddit.com/r/weddingplanning/top/.rss?t=day").entries if e.title not in used][:2]
    lines = []
    for t in topics:
        state.set(f"draft:{len(used)}", ai.generate(f"Facebook post for a wedding venue about: {t}", max_output_tokens=200).text.strip())
        lines.append(f"{state.get(f'draft:{len(used)}')}\nApprove: {LINK}?approve={len(used)}")
        used.append(t)
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    raw = f"To: me\r\nSubject: {len(lines)} posts to approve\r\n\r\n" + "\n\n".join(lines)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(raw.encode()).decode()}).execute()
    state.set("used", used[-300:])
    return {"drafts": len(lines)}

@on_event
def approve(event):
    key = (event.json or {}).get("approve")
    if text := state.get(f"draft:{key}"):
        http.post(f"https://graph.facebook.com/v21.0/{PAGE_ID}/feed", data={"message": text, "access_token": credentials.connection("facebook", "work")})
        state.delete(f"draft:{key}")
    return {"approved": bool(text)}