Get a ready-to-post LinkedIn draft in Telegram each weekday

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

NICHE, CHAT_ID = "e-commerce", 123456789

def sonar(prompt):
    r = http.post("https://api.perplexity.ai/chat/completions", headers={"Authorization": f"Bearer {credentials.secret('PERPLEXITY_API_KEY')}"},
                  json={"model": "sonar", "messages": [{"role": "user", "content": prompt}]}, timeout=90).json()
    return r["choices"][0]["message"]["content"], [s["url"] for s in r.get("search_results", [])]
def telegram(text):
    http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage",
              json={"chat_id": CHAT_ID, "text": text[:4000], "disable_web_page_preview": True}).raise_for_status()

@on_trigger
def run(event):
    used = state.get("used") or []
    research, links = sonar(f"What is one topic people in {NICHE} are discussing this week? Not any of: {used[-10:]}. "
                            "Topic on the first line, then key facts.")
    topic = research.splitlines()[0][:100]
    try:
        draft = ai.generate(f"Write a 150-word LinkedIn post with a clear opinion from this research:\n{research[:3000]}",
                            max_output_tokens=400).text
    except (ai.AINotIncluded, ai.AILimitReached):
        draft = research  # AI unavailable: send the research only
    telegram(f"✍️ {topic}\n\n{draft}\n\nSources:\n" + "\n".join(links[:5]))
    state.set("used", (used + [topic])[-50:])
    return {"topic": topic}