Email the team a daily summary of risky monday.com items

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

BOARD, TEAM = 1234567890, "team@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"]
    today, soon = date.today().isoformat(), (date.today() + timedelta(days=2)).isoformat()
    lines = []
    for i in items:
        c = {v["id"]: v["text"] for v in i["column_values"]}
        due, status = c.get("date") or "", c.get("status") or ""
        if status == "Done":
            continue
        flag = "Stuck" if status == "Stuck" else "Overdue" if due and due < today else "Due soon" if due and due <= soon else None
        if flag:
            lines.append(f"[{flag}] {i['name']} – {c.get('person') or 'no owner'} ({due or 'no date'})")
    if not lines:
        return {"flagged": 0}
    try:
        intro = ai.generate("\n".join(lines), system="Write a two-sentence overview for a team standup.", max_output_tokens=120).text
    except (ai.AINotIncluded, ai.AILimitReached):
        intro = ""
    send_email(TEAM, f"Standup: {len(lines)} items need attention", f"{intro}\n\n" + "\n".join(sorted(lines)))
    return {"flagged": len(lines)}