Turn form leads into Salesforce leads and alert sales

from clickruntime import on_event, credentials, http, ai, notify

INSTANCE = "https://yourcompany.my.salesforce.com"
API = f"{INSTANCE}/services/data/v61.0"
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"}},
          "required": ["score", "reason"]}

@on_event
def handle(event):
    form = event.json or {}
    email = form["email"].replace("'", "")
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    found = http.get(f"{API}/query", headers=headers, params={
        "q": f"SELECT Id FROM Lead WHERE Email = '{email}' AND IsConverted = false LIMIT 1"}).json()["records"]
    if found:
        return {"lead": found[0]["Id"], "new": False}
    r = ai.generate(f"Score this lead 1-10 for fit and buying intent.\nCompany: {form.get('company')}\n"
                    f"Message: {str(form.get('message', ''))[:1500]}", json_schema=SCHEMA, max_output_tokens=100).json
    lead_id = http.post(f"{API}/sobjects/Lead", headers=headers, json={
        "Email": email, "FirstName": form.get("first_name"), "LastName": form.get("last_name") or email,
        "Company": form.get("company") or "Unknown", "LeadSource": "Web", "Rating": "Hot" if r["score"] >= 8 else "Warm",
        "Description": f"{form.get('message', '')}\n\nAI score {r['score']}/10: {r['reason']}"}).json()["id"]
    if r["score"] >= 8:
        notify.slack(f"Hot lead ({r['score']}/10): <{INSTANCE}/{lead_id}|{form.get('first_name')} {form.get('last_name')}> "
                     f"at {form.get('company')}\n{r['reason']}", channel="#sales")
    return {"lead": lead_id, "new": True, "score": r["score"]}