Deploy Rankora API (clean bundle)

app/routers/products.py

@@ -127,7 +127,7 @@ def get_product(
 @router.get("/{asin}/buy-box/history")
 def get_buy_box_history(
     asin: str,
-    days: int = Query(90, ge=7, le=365, description="30 / 90 / 180 / 365 — Keepa backfill when key set"),
+    days: int = Query(90, ge=7, le=365, description="30 / 90 / 180 / 365 — Rankora scrape history"),
     db: Session = Depends(get_db),
     current_user: User = Depends(get_current_user),
 ):
@@ -136,7 +136,7 @@ def get_buy_box_history(
     if not product:
         raise HTTPException(status_code=404, detail="Product not found")
 
-    # Enough Rankora price points for yearly charts (Keepa fills gaps)
+    # Enough Rankora price points for long-range charts
     hist_limit = 2000 if days >= 180 else 500
     latest = (
         db.query(PriceHistory)

app/services/analytics/buy_box_history.py

@@ -1,8 +1,7 @@
 """Persist and analyze Buy Box winner history over time.
 
-Sources:
-- Rankora `buy_box_snapshots` (live scrapes going forward)
-- Keepa Product API (optional backfill for 6–12 months when KEEPA_API_KEY is set)
+Primary source: Rankora `buy_box_snapshots` + `price_history` (forward scrapes).
+Keepa Product API remains optional/paid and dormant unless KEEPA_API_KEY is set.
 """
 from __future__ import annotations
 
@@ -151,10 +150,10 @@ def merge_snapshots(
     keepa_dicts: Optional[List[dict]] = None,
     range_days: int = 365,
 ) -> List[SnapshotLike]:
-    """Merge Keepa backfill + Rankora live snapshots.
+    """Merge optional Keepa rows + Rankora live snapshots.
 
-    Rule: Rankora wins for any day it has data (more accurate live scrape).
-    Keepa fills older gaps for 6–12 month charts.
+    Default FYP path: keepa_dicts empty → Rankora-only.
+    If Keepa is ever enabled: Rankora wins on overlapping days.
     """
     cutoff = datetime.now(timezone.utc) - timedelta(days=max(range_days, 1))
     local = [orm_to_snapshot_like(s) for s in rankora]
@@ -283,7 +282,7 @@ def rotation_from_snapshots(
             "total_sellers": 0,
             "source": "insufficient_data",
             "snapshot_count": len(snapshots),
-            "disclaimer": "Refresh this product a few times to build Buy Box history, or set KEEPA_API_KEY for backfill.",
+            "disclaimer": "Refresh this product a few times (or wait for the 6h tracker) to build Buy Box history from Rankora scrapes.",
         }
 
     now = datetime.now(timezone.utc)
@@ -373,8 +372,9 @@ def rotation_from_snapshots(
         "source": hist_source,
         "snapshot_count": len(snapshots),
         "disclaimer": (
-            f"Buy Box share from {len(snapshots)} snapshots over {range_days} days "
-            f"(source: {hist_source}). Keepa fills past months; Rankora scrapes keep live data accurate."
+            f"Buy Box share from {len(snapshots)} Rankora snapshots over {range_days} days "
+            f"(source: {hist_source}). History starts when Rankora first tracked this ASIN — "
+            "keep Refreshing / tracking for fuller 180d–365d charts."
         ),
     }
 
@@ -524,16 +524,34 @@ def build_market_history_summary(
     bb_prices = [float(s.price) for s in snapshots if s.price is not None]
     hist_prices = [float(r["price"]) for r in price_history if r.get("price") is not None]
     all_prices = bb_prices or hist_prices
+    first_snap = _ensure_utc(snapshots[0].recorded_at) if snapshots else None
+    last_snap = _ensure_utc(snapshots[-1].recorded_at) if snapshots else None
+    span_days = 0
+    if first_snap and last_snap:
+        span_days = max(1, (last_snap - first_snap).days + 1)
+    elif price_history:
+        try:
+            first_p = datetime.fromisoformat(str(price_history[0]["recorded_at"]).replace("Z", "+00:00"))
+            last_p = datetime.fromisoformat(str(price_history[-1]["recorded_at"]).replace("Z", "+00:00"))
+            if first_p.tzinfo is None:
+                first_p = first_p.replace(tzinfo=timezone.utc)
+            if last_p.tzinfo is None:
+                last_p = last_p.replace(tzinfo=timezone.utc)
+            span_days = max(1, (last_p - first_p).days + 1)
+        except Exception:
+            span_days = 0
     return {
         "range_days": range_days,
         "buy_box_snapshots": len(snapshots),
         "price_points": len(price_history),
+        "history_span_days": span_days,
+        "partial_range": bool(span_days and span_days < range_days),
         "price_current": round(all_prices[-1], 2) if all_prices else None,
         "price_avg": round(sum(all_prices) / len(all_prices), 2) if all_prices else None,
         "price_min": round(min(all_prices), 2) if all_prices else None,
         "price_max": round(max(all_prices), 2) if all_prices else None,
-        "first_snapshot": _ensure_utc(snapshots[0].recorded_at).isoformat() if snapshots else None,
-        "last_snapshot": _ensure_utc(snapshots[-1].recorded_at).isoformat() if snapshots else None,
+        "first_snapshot": first_snap.isoformat() if first_snap else None,
+        "last_snapshot": last_snap.isoformat() if last_snap else None,
         "first_price_record": price_history[0]["recorded_at"] if price_history else None,
         "last_price_record": price_history[-1]["recorded_at"] if price_history else None,
         "buy_box_price_min": round(min(bb_prices), 2) if bb_prices else None,
@@ -693,11 +711,11 @@ def build_historical_charts_payload(
         "bsr_yearly": build_yearly_aggregates(price_history, "bsr"),
         "range_options": [30, 90, 180, 365],
         "how_it_works": [
-            "Rankora scrapes Amazon every ~6 hours and saves Buy Box winner + price (live forward history).",
-            "Keepa API (optional) backfills 6–12 months of price + Buy Box ownership before you tracked the ASIN.",
-            "Charts merge both: Keepa for the past, Rankora for recent/live accuracy.",
-            "Buy Box % = hours each seller held the box between snapshots (time-weighted).",
-            "Set KEEPA_API_KEY in Hugging Face / .env secrets to enable multi-month backfill.",
+            "Rankora scrapes Amazon every ~6 hours (or on Refresh) and saves Buy Box winner + price.",
+            "History is forward-only: the timeline starts when Rankora first tracked this ASIN.",
+            "30d / 90d charts fill quickly; 180d / 365d grow as you keep the ASIN tracked.",
+            "Buy Box % = hours each seller held the box between Rankora snapshots (time-weighted).",
+            "No paid history API is required — Keepa remains optional/paid and unused when unset.",
         ],
     }
 

app/services/external/__init__.py

@@ -1 +1 @@
-"""Third-party data providers (Keepa, etc.)."""
+"""Optional third-party providers (Keepa is paid-only; Rankora scrapes are default)."""

app/services/external/keepa_client.py

@@ -1,9 +1,9 @@
-"""Keepa Product API — historical price + Buy Box ownership (US marketplace).
+"""Keepa Product API — optional PAID backfill (dormant without KEEPA_API_KEY).
+
+Rankora FYP default is Rankora-only scrape history. Keepa has no free API tier.
+This module is unused unless a paid key is configured.
 
 Docs: https://keepa.com/#!discuss/t/product-object/116
-- Keepa time = minutes since 2011-01-01 UTC
-- Prices in cents (−1 = out of stock / no offer)
-- buybox=1 adds BUY_BOX_SHIPPING csv + buyBoxSellerIdHistory
 """
 from __future__ import annotations
 

app/services/product_service.py

@@ -378,7 +378,7 @@ def build_response(db: Session, product: Product, data_source: str = "cached") -
     reviews = latest.review_count if latest else 0
 
     bb_data = _buy_box_data_from_product(product)
-    # Local Rankora history for product page (Keepa backfill loads on History tab via /buy-box/history)
+    # Rankora-only history for product page (longer ranges via /buy-box/history)
     snapshots = get_buy_box_snapshots(db, str(product.id), days=180, limit=2000)
     rotation = rotation_from_snapshots(snapshots, range_days=90, fallback_data={**bb_data, "price": price})
     history_timeline = build_buy_box_timeline(snapshots, range_days=90)