Post about the day's news in your niche on LinkedIn

from clickruntime import on_trigger, credentials, http, state, ai

TOPIC, AUDIENCE = "restaurant tax rules", "independent restaurant owners"

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"]
    r = 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": []}})
    r.raise_for_status()
    return r.headers.get("x-restli-id", "")

@on_trigger
def run(event):
    used = set(state.get("used") or [])
    news = http.get("https://serpapi.com/search", params={"engine": "google_news", "q": TOPIC, "api_key": credentials.secret("SERPAPI_API_KEY")}).json().get("news_results", [])
    fresh = [n for n in news if n.get("link") and n["link"] not in used][:8]
    if not fresh:
        return {"posted": False}
    listing = "\n".join(f"{i}. {n['title']} - {n.get('source', {}).get('name', '')}" for i, n in enumerate(fresh))
    pick = fresh[int(ai.generate(f"Which article matters most to {AUDIENCE}? Reply with the number only.\n{listing}", max_output_tokens=5).text.strip() or 0)]
    text = ai.generate(f"Article: {pick['title']}\n{pick.get('snippet', '')}\nWrite a LinkedIn post (under 150 words) on why this matters to {AUDIENCE}.", max_output_tokens=300).text.strip()
    post_to_linkedin(f"{text}\n\n{pick['link']}")
    state.set("used", list(used | {pick["link"]})[-300:])
    return {"posted": pick["title"]}