Get new job listings by email every morning

import base64
from email.mime.text import MIMEText
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai, log

QUERY, ME = "product designer remote", "you@example.com"
PROFILE = "Product designer, 6 years in B2B SaaS, strong in design systems and research."

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    jobs = http.get("https://serpapi.com/search", params={"engine": "google_jobs", "q": QUERY, "api_key": credentials.secret("SERPAPI_API_KEY")}).json().get("jobs_results", [])
    new = [j for j in jobs if j["job_id"] not in seen]
    if not new:
        return {"new": 0}
    parts = []
    for j in new[:10]:
        entry = f"{j['title']} at {j['company_name']} ({j.get('location', '')})\n{j.get('share_link', '')}"
        try:
            entry += "\n" + ai.generate(f"Profile: {PROFILE}\nJob: {j['title']} at {j['company_name']}\n{j.get('description', '')[:2000]}\nGive a fit score 1-10 with a reason, then a 120-word cover letter.", max_output_tokens=350).text
        except (ai.AINotIncluded, ai.AILimitReached) as e:
            log.warning("AI unavailable, sending list only", {"code": e.code})
        parts.append(entry)
    mime = MIMEText("\n\n---\n\n".join(parts))
    mime["to"], mime["subject"] = ME, f"{len(new)} new jobs: {QUERY}"
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(
        userId="me", body={"raw": base64.urlsafe_b64encode(mime.as_bytes()).decode()}).execute()
    state.set("seen", list(seen | {j["job_id"] for j in new})[-1000:])
    return {"new": len(new)}