Post one researched LinkedIn post a day from your topic list

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

TOPICS = ["Chasing late invoices", "Lost receipts at year end", "Mixing personal and business spending"]

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):
    done = state.get("done") or 0
    if done >= len(TOPICS):
        notify.email_me("LinkedIn topic queue is empty", "Add more topics to keep posting.")
        return {"posted": False}
    topic = TOPICS[done]
    results = http.get("https://serpapi.com/search", params={"engine": "google", "q": topic + " small business", "api_key": credentials.secret("SERPAPI_API_KEY")}).json()
    facts = "\n".join(f"- {r['title']}: {r.get('snippet', '')}" for r in results.get("organic_results", [])[:6])
    text = ai.generate(f"Topic: {topic}\nFacts:\n{facts}\nWrite a LinkedIn post under 180 words for small business owners.", max_output_tokens=350).text.strip()
    post_to_linkedin(text)
    state.set("done", done + 1)
    return {"posted": topic, "left": len(TOPICS) - done - 1}