Get a one-page brief on every new lead

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

ME = "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_event
def handle(event):
    lead = event.json or {}
    company = lead.get("company") or lead.get("website")
    if not company:
        return {"skipped": "no company"}
    brief, links = sonar(f"Write a one-page brief on {company} for a sales call with {lead.get('name', 'a contact')} "
                         f"({lead.get('title', 'role unknown')}): what they do, size and market, news from the last six months, "
                         "and three talking points. Use short headed sections.")
    send(ME, f"Lead brief: {company}", f"{brief}\n\nLead: {lead.get('name', '')} <{lead.get('email', '')}>\n\nSources:\n"
         + "\n".join(links))
    return {"company": company, "sources": len(links)}