Turn website inquiries into Salesforce leads

from clickruntime import on_event, credentials, http, notify

INSTANCE = "https://yourcompany.my.salesforce.com"
API = f"{INSTANCE}/services/data/v61.0"

@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"]
    fields = {"Email": email, "LastName": form.get("name") or email, "Company": form.get("company") or "Unknown",
              "Phone": form.get("phone"), "LeadSource": "Web"}
    if found:
        lead_id = found[0]["Id"]
        http.patch(f"{API}/sobjects/Lead/{lead_id}", headers=headers, json=fields).raise_for_status()
    else:
        lead_id = http.post(f"{API}/sobjects/Lead", headers=headers, json=fields).json()["id"]
        notify.email_me(f"New lead: {fields['LastName']} ({fields['Company']})",
                        f"{email}\n\n{form.get('message', '')}\n\n{INSTANCE}/{lead_id}")
    http.post(f"{API}/sobjects/Task", headers=headers, json={
        "WhoId": lead_id, "Subject": "Website inquiry", "Description": form.get("message", ""), "Status": "Not Started"}).raise_for_status()
    return {"lead": lead_id, "new": not found}