Send marketing-qualified HubSpot contacts to Salesforce

from clickruntime import on_trigger, report_fetched, credentials, http, notify
HS = "https://api.hubapi.com/crm/v3/objects/contacts"
INSTANCE = "https://yourcompany.my.salesforce.com"
API = f"{INSTANCE}/services/data/v61.0"

@on_trigger
def run(event):
    hs = {"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}
    contacts = http.post(f"{HS}/search", headers=hs, json={"limit": 50, "properties": ["email", "firstname", "lastname",
        "company", "phone"], "filterGroups": [{"filters": [
            {"propertyName": "lifecyclestage", "operator": "EQ", "value": "marketingqualifiedlead"},
            {"propertyName": "salesforce_lead_id", "operator": "NOT_HAS_PROPERTY"}]}]}).json()["results"]
    report_fetched(len(contacts))
    if not contacts:
        return {"summary": "No new MQLs"}
    sf = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    created = []
    for c in contacts:
        p = c["properties"]
        email = (p.get("email") or "").replace("'", "")
        found = http.get(f"{API}/query", headers=sf, params={"q": f"SELECT Id FROM Lead WHERE Email = '{email}' LIMIT 1"}).json()["records"]
        lead_id = found[0]["Id"] if found else http.post(f"{API}/sobjects/Lead", headers=sf, json={
            "FirstName": p.get("firstname"), "LastName": p.get("lastname") or email, "Email": email,
            "Company": p.get("company") or "Unknown", "Phone": p.get("phone"), "LeadSource": "HubSpot"}).json()["id"]
        if not found:
            created.append(f"{p.get('firstname')} {p.get('lastname')} ({p.get('company')})")
        http.patch(f"{HS}/{c['id']}", headers=hs, json={"properties": {"salesforce_lead_id": lead_id}}).raise_for_status()
    if created:
        notify.slack(f"{len(created)} new MQLs from HubSpot are now Salesforce leads:\n" + "\n".join(created), channel="#sales")
    return {"contacts": len(contacts), "created": len(created)}