Fill in missing company details across HubSpot and Salesforce

from urllib.parse import urlparse
from clickruntime import on_trigger, credentials, http, notify
HS, API = "https://api.hubapi.com/crm/v3/objects/companies", "https://yourcompany.my.salesforce.com/services/data/v61.0"
FIELDS = [("industry", "Industry"), ("numberofemployees", "NumberOfEmployees"), ("phone", "Phone")]
domain = lambda url: (urlparse(url if "//" in url else f"//{url}").netloc or url).lower().removeprefix("www.")
@on_trigger
def run(event):
    hs, sf = {"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}, {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    companies, params = {}, {"limit": 100, "properties": "domain,name,industry,numberofemployees,phone"}
    while params.get("after", True):
        page = http.get(HS, headers=hs, params=params).json()
        companies.update({domain(c["properties"]["domain"]): c for c in page["results"] if c["properties"].get("domain")})
        params["after"] = page.get("paging", {}).get("next", {}).get("after")
    accounts = http.get(f"{API}/query", headers=sf, params={"q": "SELECT Id, Name, Website, Industry, NumberOfEmployees, "
                        "Phone FROM Account WHERE Website != null LIMIT 2000"}).json()["records"]
    changes = []
    for a in accounts:
        c = companies.get(domain(a["Website"]))
        p = c["properties"] if c else {}
        to_sf = {sk: int(p[hk]) if sk == "NumberOfEmployees" else p[hk] for hk, sk in FIELDS if p.get(hk) and not a[sk]}
        to_hs = {hk: str(a[sk]) for hk, sk in FIELDS if c and a[sk] and not p.get(hk) and hk != "industry"}  # HubSpot industry is a fixed list
        if to_sf:
            http.patch(f"{API}/sobjects/Account/{a['Id']}", headers=sf, json=to_sf).raise_for_status()
            changes.append(f"Salesforce {a['Name']}: {to_sf}")
        if to_hs:
            http.patch(f"{HS}/{c['id']}", headers=hs, json={"properties": to_hs}).raise_for_status()
            changes.append(f"HubSpot {p['name']}: {to_hs}")
    if changes:
        notify.email_me(f"CRM sync: {len(changes)} records filled in", "\n".join(changes))
    return {"matched_accounts": len(accounts), "changes": len(changes)}