Add new contacts at target companies to a Hunter list

from clickruntime import on_trigger, credentials, http, notify, state

DOMAINS = ["acme.com", "globex.com", "initech.io"]
DEPARTMENTS = "sales,marketing"
LIST_ID = 123456  # Hunter leads list "Target accounts"
MIN_CONFIDENCE = 80

@on_trigger
def run(event):
    key = credentials.secret("HUNTER_API_KEY")
    saved = set(state.get("saved") or [])
    report = []
    for domain in DOMAINS:
        data = http.get("https://api.hunter.io/v2/domain-search",
                        params={"domain": domain, "department": DEPARTMENTS, "limit": 25, "api_key": key}).json()["data"]
        added = []
        for e in data.get("emails", []):
            if e["value"] in saved or (e.get("confidence") or 0) < MIN_CONFIDENCE:
                continue
            http.post("https://api.hunter.io/v2/leads", params={"api_key": key},
                      json={"email": e["value"], "first_name": e.get("first_name"), "last_name": e.get("last_name"),
                            "position": e.get("position"), "company": data.get("organization"),
                            "website": domain, "leads_list_id": LIST_ID})
            saved.add(e["value"])
            added.append(f"- {e.get('first_name') or ''} {e.get('last_name') or ''}, {e.get('position') or 'no title'}"
                         f" · {e['value']} ({e['confidence']})")
        if added:
            report.append(domain + "\n" + "\n".join(added))
    state.set("saved", sorted(saved))
    count = sum(len(r.splitlines()) - 1 for r in report)
    if report:
        notify.email_me(f"{count} new contacts added to Target accounts", "\n\n".join(report))
    return {"added": count}