Monitorea precios de competidores en marketplaces

import requests, os, json
from pathlib import Path

API_KEY = os.environ["SCAVIO_API_KEY"]
THRESHOLD = 0.05  # 5% price change triggers alert

def check_competitor(query: str, platform: str) -> dict:
    resp = requests.post(
        "https://api.scavio.dev/api/v1/search",
        headers={"x-api-key": API_KEY, "Content-Type": "application/json"},
        json={"query": query, "platform": platform},
        timeout=15,
    )
    data = resp.json()
    top = data.get("organic_results", [{}])[0] if data.get("organic_results") else {}
    return {"title": top.get("title", ""), "price": top.get("price"), "url": top.get("link", "")}

def run_monitor():
    competitors = json.loads(Path("competitors.json").read_text())
    baseline = json.loads(Path("baseline.json").read_text()) if Path("baseline.json").exists() else {}
    alerts = []
    for comp in competitors:
        for platform in comp.get("platforms", ["amazon"]):
            result = check_competitor(comp["query"], platform)
            key = f"{comp['slug']}_{platform}"
            current_price = result.get("price")
            previous_price = baseline.get(key)
            if current_price and previous_price:
                change = abs(current_price - previous_price) / previous_price
                if change >= THRESHOLD:
                    alerts.append({"product": comp["query"], "platform": platform, "old": previous_price, "new": current_price, "change_pct": round(change * 100, 1)})
            if current_price:
                baseline[key] = current_price
    Path("baseline.json").write_text(json.dumps(baseline, indent=2))
    if alerts:
        print(f"{len(alerts)} price alerts:")
        for a in alerts:
            print(f"  {a['product']} ({a['platform']}): {a['old']} -> {a['new']} ({a['change_pct']}%)")

run_monitor()

const fs = require('fs');
const H = {'x-api-key': process.env.SCAVIO_API_KEY, 'Content-Type': 'application/json'};
async function checkCompetitor(query, platform) {
  const r = await fetch('https://api.scavio.dev/api/v1/search', {method:'POST', headers:H, body:JSON.stringify({query, platform})});
  const d = await r.json();
  const top = (d.organic_results||[])[0]||{};
  return {title:top.title, price:top.price, url:top.link};
}
const competitors = JSON.parse(fs.readFileSync('competitors.json','utf8'));
const baseline = fs.existsSync('baseline.json') ? JSON.parse(fs.readFileSync('baseline.json','utf8')) : {};
for (const c of competitors) {
  for (const p of c.platforms||['amazon']) {
    const r = await checkCompetitor(c.query, p);
    const key = c.slug+'_'+p;
    if (r.price && baseline[key] && Math.abs(r.price-baseline[key])/baseline[key] > 0.05) console.log('ALERT: '+c.query+' '+p+': '+baseline[key]+'->'+r.price);
    if (r.price) baseline[key] = r.price;
  }
}
fs.writeFileSync('baseline.json', JSON.stringify(baseline,null,2));