Get a Pipedrive brief by email before each sales meeting

import base64
from datetime import date
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, ai

API = "https://api.pipedrive.com"
ME = "me@example.com"

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('pipedrive', 'work')}"}
    today = date.today().isoformat()
    meetings = [a for a in http.get(f"{API}/v1/activities", headers=headers, params={"type": "meeting", "start_date": today, "end_date": today, "done": 0}).json()["data"] or [] if a.get("deal_id")]
    if not meetings:
        return {"meetings": 0}
    parts = []
    for m in meetings:
        deal = http.get(f"{API}/api/v2/deals/{m['deal_id']}", headers=headers).json()["data"]
        notes = http.get(f"{API}/v1/notes", headers=headers, params={"deal_id": m["deal_id"], "limit": 5, "sort": "add_time DESC"}).json()["data"] or []
        parts.append(f"{m.get('due_time')} {m['subject']} | deal {deal['title']} {deal['value']} {deal['currency']} stage {deal['stage_id']}\n" + "\n".join(n["content"][:400] for n in notes))
    brief = ai.generate("Write a short pre-meeting brief for each meeting: who, deal, where it stands, open points.\n\n" + "\n\n".join(parts), max_output_tokens=1200).text
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, f"Today's meetings: {len(meetings)}"
    msg.set_content(brief)
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
    return {"meetings": len(meetings)}