AI Sales Prospecting Pipeline: Complete Stack

import os, requests, json

SCAVIO_KEY = os.environ["SCAVIO_API_KEY"]
HEADERS = {"x-api-key": SCAVIO_KEY}
BASE = "https://api.scavio.dev/api/v1/search"

def discover_leads(icp_queries: list) -> list:
    """Find businesses matching ICP. Cost: 1 credit per query."""
    leads = []
    for query in icp_queries:
        resp = requests.post(BASE, headers=HEADERS, json={
            "query": query, "search_type": "maps", "num_results": 20
        })
        for biz in resp.json().get("local_results", []):
            if biz.get("website"):
                leads.append({
                    "company": biz["title"],
                    "website": biz["website"],
                    "phone": biz.get("phone", ""),
                    "address": biz.get("address", ""),
                    "rating": biz.get("rating", 0),
                    "reviews": biz.get("reviews", 0),
                })
    return leads

# 10 ICP queries = 10 credits = $0.05
leads = discover_leads([
    "marketing agency Austin TX",
    "marketing agency Denver CO",
    "web design agency Portland OR",
    "digital marketing company Nashville TN",
])

def enrich_lead(lead: dict) -> dict:
    """Add context for qualification. Cost: 2 credits per lead."""
    # Company info search
    info_resp = requests.post(BASE, headers=HEADERS, json={
        "query": f"{lead['company']} {lead['website']}", "num_results": 5
    })
    info = info_resp.json().get("organic_results", [])

    # Tech/tools search
    tech_resp = requests.post(BASE, headers=HEADERS, json={
        "query": f"site:{lead['website']} OR {lead['company']} tools technology",
        "num_results": 5
    })
    tech = tech_resp.json().get("organic_results", [])

    lead["context"] = " ".join(r.get("snippet", "") for r in info[:3])
    lead["tech_signals"] = " ".join(r.get("snippet", "") for r in tech[:3])
    lead["enriched"] = True
    return lead

# Enrich top 50 leads = 100 credits = $0.50
enriched = [enrich_lead(l) for l in leads[:50]]

from anthropic import Anthropic

client = Anthropic()

def qualify_lead(lead: dict) -> dict:
    """AI scores lead based on enrichment data."""
    prompt = f"""Score this lead 1-10 for a search API product.
Company: {lead['company']}
Website: {lead['website']}
Context: {lead['context'][:300]}
Tech signals: {lead['tech_signals'][:300]}
Rating: {lead['rating']}, Reviews: {lead['reviews']}

Return JSON: {{"score": N, "reason": "one sentence", "personalization_hook": "specific detail"}}"""

    response = client.messages.create(
        model="claude-haiku-4-20250414",
        max_tokens=200,
        messages=[{"role": "user", "content": prompt}],
    )
    try:
        result = json.loads(response.content[0].text)
        lead["score"] = result.get("score", 0)
        lead["reason"] = result.get("reason", "")
        lead["hook"] = result.get("personalization_hook", "")
    except (json.JSONDecodeError, IndexError):
        lead["score"] = 0
    return lead

# Qualify 50 leads with Haiku (~$0.02 total)
qualified = [qualify_lead(l) for l in enriched]
hot_leads = [l for l in qualified if l.get("score", 0) >= 7]
print(f"Hot leads: {len(hot_leads)} / {len(qualified)}")

def generate_outreach(lead: dict) -> str:
    """Generate personalized cold email using lead context."""
    prompt = f"""Write a 3-sentence cold email for a search API product.
Use this specific detail as the hook: {lead.get('hook', '')}
Company: {lead['company']}
Keep it under 75 words. No fake compliments. Be direct about value."""

    response = client.messages.create(
        model="claude-haiku-4-20250414",
        max_tokens=150,
        messages=[{"role": "user", "content": prompt}],
    )
    return response.content[0].text

for lead in hot_leads[:3]:
    email = generate_outreach(lead)
    print(f"To: {lead['company']}")
    print(email)
    print("---")