Score job alert emails against your CV

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

HOST, NS = "https://kb-abc123.svc.aped-1234.pinecone.io", "cv"  # your index host and namespace
def search(text, k=5):
    r = http.post(f"{HOST}/records/namespaces/{NS}/search", json={"query": {"inputs": {"text": text}, "top_k": k}}, headers={
        "Api-Key": credentials.secret("PINECONE_API_KEY"), "X-Pinecone-API-Version": "2025-04"}).json()
    return [h["fields"] for h in r["result"]["hits"]]

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()
    done = set(state.get("done") or [])
    new = [m for m in gmail.messages().list(userId="me", q="label:Job-alerts newer_than:2d").execute().get("messages", []) if m["id"] not in done]
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    good = []
    for m in new:
        job = gmail.messages().get(userId="me", id=m["id"], format="metadata", metadataHeaders=["Subject"]).execute()
        text = f"{job['payload']['headers'][0]['value']}: {job['snippet']}"
        cv = "\n".join(h["chunk_text"] for h in search(text, 4))
        fit = ai.generate(f"Score 1-10 how well this role fits the CV, then ' | ' and a one-line reason.\nROLE: {text}\nCV:\n{cv}",
                          max_output_tokens=60).text.strip()
        if fit.split("|")[0].strip().isdigit() and int(fit.split("|")[0]) >= 7:
            good.append(f"{fit}\n{text}\nhttps://mail.google.com/mail/u/0/#all/{m['id']}")
    if good:
        notify.email_me(f"{len(good)} roles worth a look", "\n\n".join(good))
    state.set("done", sorted(done | {m["id"] for m in new})[-2000:])