Score inbound leads and create Asana tasks for the good ones

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, credentials, http, ai

PROJECT_ID = "your-asana-project-id"
IDEAL = "B2B companies with 20-500 staff, a clear project and a budget."
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "summary": {"type": "string"}}, "required": ["score", "summary"]}

@on_event
def handle(event):
    lead = event.json or {}
    try:
        r = ai.generate(f"Ideal client: {IDEAL}\nLead: {lead.get('name')} {lead.get('company', '')}\n{str(lead.get('message', ''))[:2000]}",
                        system="Score this lead 1-10 and summarise in one line.", json_schema=SCHEMA, max_output_tokens=100).json
    except ai.AIError:
        r = {"score": 5, "summary": "Not scored"}
    hot = r["score"] >= 7
    if hot:
        http.post("https://app.asana.com/api/1.0/tasks", headers={"Authorization": f"Bearer {credentials.secret('ASANA_TOKEN')}"},
                  json={"data": {"name": f"Follow up: {lead['name']} ({r['score']}/10)", "notes": r["summary"], "projects": [PROJECT_ID]}})
    msg = EmailMessage()
    msg["To"], msg["Subject"] = lead["email"], "Thanks for getting in touch"
    msg.set_content(f"Hi {lead['name']},\n\nThanks for reaching out. " + ("We'd love to talk. Reply with a time that suits you." if hot else "We'll get back to you shortly."))
    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()
    return {"score": r["score"], "hot": hot}