Send a topic to Telegram and approve a LinkedIn draft

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

AUTHOR = "urn:li:person:abc123"

@on_event
def handle(event):
    body, token = event.json or {}, credentials.secret("TELEGRAM_BOT_TOKEN")
    tg = f"https://api.telegram.org/bot{token}"
    cb = body.get("callback_query")
    key = cb["data"].split(":")[1] if cb else event.event_id
    draft = state.get(f"draft:{key}") or {"topic": body.get("message", {}).get("text", ""), "chat": body.get("message", {}).get("chat", {}).get("id")}
    if cb:
        http.post(f"{tg}/answerCallbackQuery", json={"callback_query_id": cb["id"]})
    if cb and cb["data"].startswith("ok:"):
        r = http.post("https://api.linkedin.com/rest/posts", headers={"Authorization": f"Bearer {credentials.connection('linkedin', 'work')}", "LinkedIn-Version": "202409"},
                      json={"author": AUTHOR, "commentary": draft["text"], "visibility": "PUBLIC", "lifecycleState": "PUBLISHED", "distribution": {"feedDistribution": "MAIN_FEED"}})
        http.post(f"{tg}/sendMessage", json={"chat_id": draft["chat"], "text": f"Posted: https://www.linkedin.com/feed/update/{r.headers.get('x-restli-id')}"})
        state.delete(f"draft:{key}")
        return {"posted": True}
    draft["text"] = ai.generate(f"Write a thoughtful LinkedIn post with context and a clear point on: {draft['topic']}", max_output_tokens=600).text
    state.set(f"draft:{key}", draft)
    buttons = [[{"text": "Approve", "callback_data": f"ok:{key}"}, {"text": "Redo", "callback_data": f"redo:{key}"}]]
    http.post(f"{tg}/sendMessage", json={"chat_id": draft["chat"], "text": draft["text"], "reply_markup": {"inline_keyboard": buttons}})
    return {"drafted": key}