Get daily LinkedIn drafts on trending topics

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

FEEDS = ["https://news.example.org/rss", "https://trade.example.com/feed"]
ME, APPROVE_URL = "me@example.com", "https://your-trigger-link"

@on_trigger
def draft(event):
    seen = set(state.get("seen") or [])
    items = [e for url in FEEDS for e in feedparser.parse(url).entries[:15] if e.link not in seen]
    if not items:
        return {"drafted": False}
    lines = "\n".join(f"{n}. {e.title} {e.link}" for n, e in enumerate(items[:20]))
    text = ai.generate("Pick the most relevant story for a B2B SaaS audience and write a 120-word LinkedIn post "
                       f"with a clear opinion, ending with its link:\n{lines}", max_output_tokens=350).text.strip()
    key = uuid.uuid4().hex
    state.set(f"draft:{key}", text)
    state.set("seen", (list(seen) + [e.link for e in items])[-500:])
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, "Today's LinkedIn draft"
    msg.set_content(f"{text}\n\nApprove and publish: {APPROVE_URL}?draft={key}")
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
    return {"drafted": True}

@on_event
def approve(event):
    key = (event.json or {}).get("draft", "")
    text = state.get(f"draft:{key}")
    if not text:
        return {"published": False}
    headers = {"Authorization": "Bearer " + credentials.connection("linkedin", "main"), "LinkedIn-Version": "202405"}
    me = http.get("https://api.linkedin.com/v2/userinfo", headers=headers).json()["sub"]
    http.post("https://api.linkedin.com/rest/posts", headers=headers, json={
        "author": f"urn:li:person:{me}", "commentary": text, "visibility": "PUBLIC", "lifecycleState": "PUBLISHED",
        "distribution": {"feedDistribution": "MAIN_FEED", "targetEntities": [], "thirdPartyDistributionChannels": []}}).raise_for_status()
    state.delete(f"draft:{key}")
    return {"published": True}