Recetas

import json
import os
import pathlib
import requests

BASE = "https://api.turbodato.com/v1"
HEADERS = {"X-API-Key": os.environ["TURBODATO_API_KEY"]}
HUELLA = pathlib.Path(".turbodato_huella.json")


def get(path, **params):
    res = requests.get(f"{BASE}{path}", params=params, headers=HEADERS, timeout=120)
    res.raise_for_status()
    return res.json()


# 1. La huella: tres números, barata de pedir.
huella = get("/status")
if HUELLA.exists() and json.loads(HUELLA.read_text()) == huella:
    print("Sin novedades")
    raise SystemExit(0)

# 2. Hay novedad: recorrer el catálogo en páginas de 200, sin las cuentas caras.
productos, page = [], 1
while True:
    body = get("/data", page=page, limit=200, stats="false")
    productos += body["anchors"]
    if page >= body["pagination"]["totalPages"]:
        break
    page += 1

print(f"{len(productos)} productos del {body['referenceDate']}")
# ...guardalos donde los uses...

# 3. Recién al final, guardar la huella: si algo falló, la próxima corrida reintenta.
HUELLA.write_text(json.dumps(huella))

import os
import requests

res = requests.get(
    "https://api.turbodato.com/v1/price-control",
    params={"limit": 1000},
    headers={"X-API-Key": os.environ["TURBODATO_API_KEY"]},
    timeout=120,
)
res.raise_for_status()
r = res.json()

# Sólo las que rompen el PVP cargado, no las que se midieron contra tu propio precio.
contra_pvp = [b for b in r["breaches"] if b["referenceSource"] == "sheet"]

print(f"{r['date']}: {len(contra_pvp)} ofertas debajo del PVP")
for b in contra_pvp:
    seller = b["seller"] or "sin vendedor"
    pesos = f"$ {b['price']:,.0f}".replace(",", ".")
    print(f"  {b['deltaPercent']:>7.2f}%  {b['site']} · {seller} · {b['product']} a {pesos}")

2026-10-16: 3 ofertas debajo del PVP
   -12.50%  Mercado Libre · Electro del Sur · Smart TV Samsung 55" Crystal UHD 4K DU7000 a $ 787.499
    -5.56%  Mercado Libre · Hogar Total · Smart TV Samsung 55" Crystal UHD 4K DU7000 a $ 849.999
    -1.10%  Frávega · Frávega · Lavarropas Drean Next 11.14 Eco 11 kg a $ 1.087.899

import os
import requests

BASE = "https://api.turbodato.com/v1"
HEADERS = {"X-API-Key": os.environ["TURBODATO_API_KEY"]}


# True si tu tablero compara por pack: ahí el semáforo hace la cuenta por unidad.
POR_PACK = False


def unitario(m):
    if POR_PACK and m["quantity"]:
        return m["realPrice"] / m["quantity"]
    return m["realPrice"]


filas, page = [], 1
while True:
    res = requests.get(f"{BASE}/data", headers=HEADERS, timeout=120,
                       params={"semaphore": "red", "limit": 200, "page": page, "stats": "false"})
    res.raise_for_status()
    body = res.json()
    mio = body["mainSiteId"]
    for p in body["anchors"]:
        propias = [m for m in p["matches"] if m["siteId"] == mio and m["realPrice"]]
        ajenas = [m for m in p["matches"] if m["siteId"] != mio and m["realPrice"]]
        if not propias or not ajenas:
            continue
        yo = min(unitario(m) for m in propias)
        rival = min(ajenas, key=unitario)
        brecha = (yo - unitario(rival)) / unitario(rival) * 100
        filas.append((brecha, p["name"], yo, unitario(rival), rival["siteName"], rival["sellerName"]))
    if page >= body["pagination"]["totalPages"]:
        break
    page += 1

for brecha, nombre, yo, otro, sitio, seller in sorted(filas, reverse=True)[:20]:
    print(f"+{brecha:5.1f}%  {nombre}: vos {yo:,.0f}, {sitio} / {seller} {otro:,.0f}")

#!/usr/bin/env bash
set -euo pipefail
BASE="https://api.turbodato.com/v1"
AUTH=(-H "X-API-Key: $TURBODATO_API_KEY")

# Confirmar que el relevamiento de hoy ya cerró antes de exportar.
hoy=$(date +%F)
ultimo=$(curl -sf "${AUTH[@]}" "$BASE/status" | jq -r .lastMatchDate)
if [ "$ultimo" != "$hoy" ]; then
  echo "Todavía no hay datos de $hoy (último: $ultimo)" >&2
  exit 1
fi

curl -sf "${AUTH[@]}" \
  "$BASE/export?format=csv&date=$hoy\
&dataColumns=ean,sku,marca,producto,categoria\
&priceColumns=precioFinal,precioLista,seller,url" \
  > "turbodato_$hoy.csv"