Screen emailed CVs into a Supabase candidates table

import base64, io
from pypdf import PdfReader
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched

ROLE = "Customer success manager: 3+ years SaaS, B2B accounts, English and Spanish"
SUPABASE = "https://your-project.supabase.co/rest/v1"

def sb(method, path, **kw):
    key = credentials.secret("SUPABASE_KEY")
    r = http.request(method, f"{SUPABASE}/{path}", **kw, headers={"apikey": key, "Authorization": f"Bearer {key}", "Prefer": "return=representation,resolution=merge-duplicates"})
    return r.raise_for_status() or (r.json() if r.content else None)

SCHEMA = {"type": "object", "properties": {"name": {"type": "string"}, "email": {"type": "string"}, "summary": {"type": "string"}, "score": {"type": "integer"}}}

@on_trigger
def run(event):
    gmail, done = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False), set(state.get("done") or [])
    msgs = [m for m in gmail.users().messages().list(userId="me", q="to:jobs@northwind.com has:attachment filename:pdf newer_than:2d").execute().get("messages", []) if m["id"] not in done]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    for m in msgs:
        full = gmail.users().messages().get(userId="me", id=m["id"]).execute()
        part = next(p for p in full["payload"]["parts"] if p.get("filename", "").lower().endswith(".pdf"))
        data = gmail.users().messages().attachments().get(userId="me", messageId=m["id"], id=part["body"]["attachmentId"]).execute()["data"]
        text = " ".join(p.extract_text() or "" for p in PdfReader(io.BytesIO(base64.urlsafe_b64decode(data))).pages)[:8000]
        c = ai.generate(f"Role: {ROLE}\nExtract name, email, a 2-sentence summary and a 1-10 fit score from this CV:\n{text}", json_schema=SCHEMA, max_output_tokens=250).json
        sb("POST", "candidates", json={**c, "message_id": m["id"], "file": part["filename"]})
        done.add(m["id"])
    state.set("done", list(done)[-2000:])
    return {"candidates": len(msgs)}