Daily n8n Search Enrichment Pipeline

import requests
import json

API_KEY = "your_scavio_api_key"

def enrich_leads(leads: list[dict]) -> list[dict]:
    """Simulates the n8n pipeline in Python.
    n8n equivalent: Schedule -> Airtable Read -> HTTP Request (Scavio) -> Code -> Airtable Update
    """
    enriched = []
    for lead in leads:
        res = requests.post(
            "https://api.scavio.dev/api/v1/search",
            headers={"x-api-key": API_KEY},
            json={"platform": "google", "query": lead["company"], "ai_overview": True},
            timeout=15,
        )
        if not res.ok:
            continue
        data = res.json()
        ai_text = data.get("ai_overview", {}).get("text", "")
        snippets = [r.get("snippet", "") for r in data.get("organic", [])[:3]]
        lead["enrichment"] = {
            "ai_overview": ai_text[:300],
            "top_snippets": snippets,
            "enriched_at": "2026-05-21",
        }
        enriched.append(lead)

    print(f"Enriched {len(enriched)}/{len(leads)} leads")
    return enriched

leads = [
    {"id": 1, "company": "Acme Corp"},
    {"id": 2, "company": "Widget Inc"},
]
enrich_leads(leads)

const API_KEY = "your_scavio_api_key";

async function enrichLeads(leads) {
  for (const lead of leads) {
    const res = await fetch("https://api.scavio.dev/api/v1/search", {
      method: "POST",
      headers: { "x-api-key": API_KEY, "content-type": "application/json" },
      body: JSON.stringify({ platform: "google", query: lead.company, ai_overview: true }),
    });
    if (!res.ok) continue;
    const data = await res.json();
    lead.enrichment = {
      aiOverview: (data.ai_overview?.text ?? "").slice(0, 300),
      snippets: (data.organic ?? []).slice(0, 3).map((r) => r.snippet ?? ""),
    };
  }
  console.log(`Enriched ${leads.length} leads`);
  return leads;
}

await enrichLeads([{ company: "Acme Corp" }]);