Find questions you haven't answered

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, ai, notify

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    threads = gmail.users().threads().list(userId="me", q="in:inbox newer_than:7d -from:me", maxResults=100).execute().get("threads", [])
    candidates = []
    for t in threads:
        thread = gmail.users().threads().get(userId="me", id=t["id"], format="metadata",
                                             metadataHeaders=["From", "Subject"]).execute()
        last = thread["messages"][-1]
        if "SENT" in last["labelIds"] or "?" not in last["snippet"]:
            continue
        h = {x["name"]: x["value"] for x in last["payload"]["headers"]}
        candidates.append((t["id"], f"{h.get('From')} | {h.get('Subject')} | {last['snippet'][:300]}"))
    if not candidates:
        return {"open": 0}
    numbered = "\n".join(f"{i}. {text}" for i, (_, text) in enumerate(candidates, 1))
    picks = ai.generate("Which of these ask me a direct question? Reply with the numbers, comma separated.\n" + numbered,
                        max_output_tokens=60).text
    chosen = [candidates[int(n) - 1] for n in picks.replace(" ", "").split(",") if n.isdigit() and 0 < int(n) <= len(candidates)]
    body = "\n\n".join(f"{text}\nhttps://mail.google.com/mail/u/0/#all/{tid}" for tid, text in chosen)
    notify.email_me(f"{len(chosen)} questions waiting for you", body or "None this week.")
    return {"open": len(chosen)}