n8n Automation Development

# Webhook → enrich → CRM → notify
import httpx, json

@n8n_webhook(path="/leads/inbound", method="POST")
async def process_inbound_lead(payload: dict) -> dict:
    email = payload.get("email", "").lower()

    # Step 1: Enrich with Clearbit (optional, skips on 404)
    try:
        enriched = await clearbit.enrich_person(email=email)
        company   = enriched.get("company", {}).get("name", "")
        role      = enriched.get("employment", {}).get("role", "")
    except httpx.HTTPStatusError:
        company, role = "", ""

    # Step 2: Score the lead
    score = score_lead(
        company_size=enriched.get("company", {}).get("metrics", {}).get("employees", 0),
        role=role,
        source=payload.get("utm_source", ""),
    )

    # Step 3: Upsert CRM record
    contact = await ghl_client.upsert_contact(
        email=email,
        name=payload.get("name", ""),
        custom_fields={"lead_score": score, "company": company, "role": role},
        tags=["inbound", payload.get("utm_source", "organic")],
    )

    # Step 4: Route by score
    if score >= 70:
        await monday.create_item(board=SALES_BOARD, name=email, status="Hot")
        await slack.post(channel="#sales-alerts", text=f"Hot lead: {email} (score: {score})")
    elif score >= 40:
        await ghl_client.start_workflow(contact.id, workflow="nurture-sequence")

    return {"contact_id": contact.id, "score": score, "status": "processed"}