Get a researched LinkedIn draft in your inbox every Monday

import base64
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai

FIELD, ME = "B2B marketing", "me@example.com"

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 send(to, subject, body):
    raw = f"To: {to}\r\nSubject: {subject}\r\nContent-Type: text/plain; charset=utf-8\r\n\r\n{body}"
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users() \
        .messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(raw.encode()).decode()}).execute()

@on_trigger
def run(event):
    used = state.get("used") or []
    research, links = sonar(f"What is the most discussed topic in {FIELD} this week? Avoid these: {used[-10:]}. "
                            "Start with the topic on one line, then the key facts.")
    topic = research.splitlines()[0][:120]
    try:
        draft = ai.generate(f"Write a 180-word LinkedIn post with a clear opinion, from this research:\n{research[:3000]}",
                            max_output_tokens=450).text
    except (ai.AINotIncluded, ai.AILimitReached):
        draft = research  # AI unavailable: send the research only
    send(ME, f"Draft post: {topic}", draft + "\n\nSources:\n" + "\n".join(links))
    state.set("used", (used + [topic])[-50:])
    return {"topic": topic}