Get a sourced news digest on your topics every morning

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

TOPICS, ME = ["AI", "logistics and freight"], "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):
    seen, sections = set(state.get("seen") or []), []
    for topic in TOPICS:
        text, links = sonar(f"Top news about {topic} from the last 24 hours. Up to five short bullets.")
        new = [l for l in links if l not in seen]
        sections += [f"## {topic}\n{text}\nSources:\n" + "\n".join(new)] if new else []
        seen |= set(new)
    if not sections:
        return {"sent": False}
    send(ME, "Your morning briefing", "\n\n".join(sections))
    state.set("seen", sorted(seen)[-2000:])
    return {"sections": len(sections)}