Get a monthly lead report from your monday.com board

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from collections import Counter
from clickruntime import on_trigger, credentials, http, state, ai

BOARD, ME = 1234567890, "me@example.com"
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"]

def send_email(to, subject, text):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = to, subject
    msg.set_content(text)
    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()

@on_trigger
def run(event):
    items = monday(ITEMS, board=[BOARD])["boards"][0]["items_page"]["items"]
    cols = [{c["id"]: c["text"] for c in i["column_values"]} for i in items]
    by_status, by_source = Counter(c.get("status") for c in cols), Counter(c.get("source") for c in cols)
    counts = f"By status: {dict(by_status)}\nBy source: {dict(by_source)}"
    notes = ai.generate(f"This month:\n{counts}\nLast month:\n{state.get('last') or 'none'}", max_output_tokens=300,
                        system="Write 3 short bullet points on what changed and what to look at.").text
    send_email(ME, f"Lead report: {len(items)} leads", f"{counts}\n\n{notes}")
    state.set("last", counts)
    return {"leads": len(items)}