Share each new WordPress post on LinkedIn

from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched

VOICE = "Clear, practical, first person, no hashtags."
WP = "https://blog.example.com/wp-json/wp/v2"

def wp(method, path, **kw):
    r = http.request(method, f"{WP}/{path}", auth=(credentials.secret("WP_USER"), credentials.secret("WP_APP_PASSWORD")), **kw)
    r.raise_for_status()
    return r.json()
def post_to_linkedin(text):
    token = credentials.connection("linkedin", "work")
    me = http.get("https://api.linkedin.com/v2/userinfo", headers={"Authorization": f"Bearer {token}"}).json()["sub"]
    http.post("https://api.linkedin.com/rest/posts", headers={"Authorization": f"Bearer {token}", "LinkedIn-Version": "202409", "X-Restli-Protocol-Version": "2.0.0"},
              json={"author": f"urn:li:person:{me}", "commentary": text, "visibility": "PUBLIC", "lifecycleState": "PUBLISHED",
                    "distribution": {"feedDistribution": "MAIN_FEED", "targetEntities": [], "thirdPartyDistributionChannels": []}}).raise_for_status()

@on_trigger
def run(event):
    after = state.get("after") or datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%S")
    posts = wp("GET", "posts", params={"after": after, "status": "publish", "orderby": "date", "order": "asc", "_fields": "date,link,title,excerpt"})
    report_fetched(len(posts))
    if not posts:
        return {"shared": 0}
    for p in posts:
        text = ai.generate(f"Title: {p['title']['rendered']}\nExcerpt: {p['excerpt']['rendered'][:800]}\nWrite a LinkedIn post under 120 words about this article.",
                           system=VOICE, max_output_tokens=250).text.strip()
        post_to_linkedin(f"{text}\n\n{p['link']}")
    state.set("after", posts[-1]["date"])
    return {"shared": len(posts)}