Diseñe la capa de recuperación para la arquitectura de su agente

import requests, os
from concurrent.futures import ThreadPoolExecutor

API_KEY = os.environ["SCAVIO_API_KEY"]
H = {"x-api-key": API_KEY, "Content-Type": "application/json"}

INTENT_ROUTES = {
    "product": ["amazon", "walmart"],
    "opinion": ["reddit", "google"],
    "tutorial": ["youtube", "google"],
    "trend": ["tiktok", "youtube"],
    "news": ["google"],
    "local": ["google_maps"],
}

def classify_intent(query: str) -> str:
    """Simple keyword-based intent classifier. Replace with LLM classifier for production."""
    q = query.lower()
    if any(w in q for w in ["price", "buy", "cost", "product"]):
        return "product"
    if any(w in q for w in ["opinion", "think", "review", "recommend"]):
        return "opinion"
    if any(w in q for w in ["how to", "tutorial", "guide", "setup"]):
        return "tutorial"
    if any(w in q for w in ["trending", "viral", "popular"]):
        return "trend"
    return "news"

def fetch_platform(query: str, platform: str) -> dict:
    resp = requests.post(
        "https://api.scavio.dev/api/v1/search",
        headers=H,
        json={"query": query, "platform": platform, "country_code": "us"},
        timeout=10,
    )
    results = resp.json().get("organic_results", [])[:5]
    return {
        "platform": platform,
        "results": [{"title": r["title"], "snippet": r.get("snippet", ""), "url": r["link"]} for r in results],
    }

def retrieval_layer(query: str) -> list[dict]:
    intent = classify_intent(query)
    platforms = INTENT_ROUTES.get(intent, ["google"])
    with ThreadPoolExecutor(max_workers=4) as pool:
        futures = [pool.submit(fetch_platform, query, p) for p in platforms]
        return [f.result() for f in futures]

# Agent retrieval: right platforms for the query
context = retrieval_layer("what do people think about the new MacBook Pro")
for source in context:
    print(f"--- {source['platform']} ({len(source['results'])} results) ---")
    for r in source["results"][:2]:
        print(f"  {r['title']}")

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

const INTENT_ROUTES = {
  product: ["amazon", "walmart"],
  opinion: ["reddit", "google"],
  tutorial: ["youtube", "google"],
  trend: ["tiktok", "youtube"],
  news: ["google"],
  local: ["google_maps"],
};

function classifyIntent(query) {
  const q = query.toLowerCase();
  if (["price", "buy", "cost", "product"].some(w => q.includes(w))) return "product";
  if (["opinion", "think", "review", "recommend"].some(w => q.includes(w))) return "opinion";
  if (["how to", "tutorial", "guide", "setup"].some(w => q.includes(w))) return "tutorial";
  if (["trending", "viral", "popular"].some(w => q.includes(w))) return "trend";
  return "news";
}

async function fetchPlatform(query, platform) {
  const res = await fetch("https://api.scavio.dev/api/v1/search", {
    method: "POST",
    headers: H,
    body: JSON.stringify({ query, platform, country_code: "us" }),
  });
  const results = (await res.json()).organic_results || [];
  return {
    platform,
    results: results.slice(0, 5).map(r => ({ title: r.title, snippet: r.snippet || "", url: r.link })),
  };
}

async function retrievalLayer(query) {
  const intent = classifyIntent(query);
  const platforms = INTENT_ROUTES[intent] || ["google"];
  return Promise.all(platforms.map(p => fetchPlatform(query, p)));
}

const context = await retrievalLayer("what do people think about the new MacBook Pro");
for (const source of context) {
  console.log(`--- ${source.platform} (${source.results.length} results) ---`);
  source.results.slice(0, 2).forEach(r => console.log(`  ${r.title}`));
}