n8n Multi-Source Company Enrichment Workflow

import requests, os, json

H = {'x-api-key': os.environ['SCAVIO_API_KEY']}

def enrich_company(name):
    # Google for canonical data
    g = requests.post('https://api.scavio.dev/api/v1/search', headers=H,
        json={'platform': 'google', 'query': name}, timeout=10).json()
    # Reddit for community signals
    r = requests.post('https://api.scavio.dev/api/v1/search', headers=H,
        json={'platform': 'reddit', 'query': name}, timeout=10).json()
    kg = g.get('knowledge_graph', {})
    reddit_posts = r.get('organic', [])[:3]
    return {
        'input_name': name,
        'canonical_name': kg.get('title', ''),
        'website': kg.get('website', ''),
        'description': kg.get('description', ''),
        'type': kg.get('type', ''),
        'reddit_mentions': len(r.get('organic', [])),
        'reddit_topics': [p.get('title', '')[:80] for p in reddit_posts],
        'enrichment_score': sum([
            bool(kg.get('title')),
            bool(kg.get('website')),
            bool(kg.get('description')),
            len(r.get('organic', [])) > 0,
        ]),
    }

companies = ['Vercel', 'Supabase', 'PlanetScale']
for name in companies:
    data = enrich_company(name)
    print(f"{name} -> {data['canonical_name']} | {data['website']} | Score: {data['enrichment_score']}/4")
    if data['reddit_topics']:
        print(f"  Reddit: {data['reddit_topics'][0]}")

const H = {"x-api-key": process.env.SCAVIO_API_KEY, "Content-Type": "application/json"};

async function enrichCompany(name) {
  const [g, r] = await Promise.all([
    fetch("https://api.scavio.dev/api/v1/search", {
      method: "POST", headers: H,
      body: JSON.stringify({platform: "google", query: name})
    }).then(r => r.json()),
    fetch("https://api.scavio.dev/api/v1/search", {
      method: "POST", headers: H,
      body: JSON.stringify({platform: "reddit", query: name})
    }).then(r => r.json()),
  ]);
  const kg = g.knowledge_graph || {};
  const redditPosts = (r.organic || []).slice(0, 3);
  return {
    inputName: name,
    canonicalName: kg.title || "",
    website: kg.website || "",
    description: kg.description || "",
    type: kg.type || "",
    redditMentions: (r.organic || []).length,
    redditTopics: redditPosts.map(p => (p.title || "").slice(0, 80)),
    enrichmentScore: [kg.title, kg.website, kg.description, (r.organic || []).length > 0]
      .filter(Boolean).length,
  };
}

(async () => {
  const companies = ["Vercel", "Supabase", "PlanetScale"];
  for (const name of companies) {
    const data = await enrichCompany(name);
    console.log(`${name} -> ${data.canonicalName} | ${data.website} | Score: ${data.enrichmentScore}/4`);
    if (data.redditTopics.length) console.log(`  Reddit: ${data.redditTopics[0]}`);
  }
})();