Draft personal emails for new monday.com leads

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

BOARD = 1234567890
ITEMS = """query ($board: [ID!]) { boards(ids: $board) { items_page(limit: 200) { items {
  id name url column_values { id text } } } } }"""
def monday(query, **variables):
    resp = http.post("https://api.monday.com/v2", json={"query": query, "variables": variables},
                     headers={"Authorization": credentials.secret("MONDAY_API_TOKEN"), "API-Version": "2024-10"})
    resp.raise_for_status()
    return resp.json()["data"]

@on_trigger
def run(event):
    items = monday(ITEMS, board=[BOARD])["boards"][0]["items_page"]["items"]
    leads = [(i, {c["id"]: c["text"] for c in i["column_values"]}) for i in items]
    leads = [(i, c) for i, c in leads if c.get("status") == "New" and c.get("email")]
    report_fetched(len(leads))
    if not leads:
        return {"drafted": 0}
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for item, c in leads:
        body = ai.generate(f"Lead: {item['name']}, company {c.get('company')}, notes: {c.get('notes', '')[:800]}", max_output_tokens=300,
                           system="Write a friendly 80-word intro email from Northwind Studio suggesting a 15-minute call. No subject line.").text
        msg = EmailMessage()
        msg["To"], msg["Subject"] = c["email"], f"Quick idea for {c.get('company') or item['name']}"
        msg.set_content(body)
        gmail.users().drafts().create(userId="me", body={"message": {"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}}).execute()
        monday("mutation ($b: ID!, $i: ID!, $v: JSON!) { change_column_value(board_id: $b, item_id: $i, column_id: \"status\", value: $v) { id } }",
               b=BOARD, i=item["id"], v=json.dumps({"label": "Drafted"}))
    return {"drafted": len(leads)}