Track Grocery Prices Across BlinkIt, Zepto & Swiggy with One API

const cron = require("node-cron");
const Database = require("better-sqlite3");
const fetch = require("node-fetch");

const API_KEY = process.env.QC_API_KEY;
const BASE_URL = "https://api.quickcommerceapi.com/api/v1";

// Products and platforms to track
const PRODUCTS = [
  "Aashirvaad Atta 5kg",
  "Amul Butter 500g",
  "Tata Salt 1kg",
  "Fortune Sunflower Oil 1L",
  "Maggi Noodles 12 Pack",
];
const PLATFORMS = ["blinkit", "zepto", "swiggy", "bigbasket", "dmart"];

// Initialize SQLite database
const db = new Database("prices.db");
db.exec(`
  CREATE TABLE IF NOT EXISTS price_history (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    product TEXT NOT NULL,
    platform TEXT NOT NULL,
    price REAL,
    mrp REAL,
    offer_price REAL,
    in_stock INTEGER,
    tracked_at DATETIME DEFAULT CURRENT_TIMESTAMP
  )
`);

const insertPrice = db.prepare(`
  INSERT INTO price_history (product, platform, price, mrp, offer_price, in_stock)
  VALUES (?, ?, ?, ?, ?, ?)
`);

async function trackProduct(query, platform) {
  try {
    const url = `${BASE_URL}/search?query=${encodeURIComponent(query)}&platform=${platform}`;
    const res = await fetch(url, {
      headers: {
        "X-API-Key": API_KEY,
        "x-geolocation-pincode": "560001", // Bangalore
      },
    });
    const data = await res.json();
    const product = data.products?.[0];
    if (product) {
      insertPrice.run(
        query,
        platform,
        product.price,
        product.mrp,
        product.offer_price || null,
        product.in_stock ? 1 : 0
      );
      console.log(`[OK] ${platform} | ${query} | Rs ${product.price}`);
    }
  } catch (err) {
    console.error(`[ERR] ${platform} | ${query}: ${err.message}`);
  }
}

async function runTrackingCycle() {
  console.log(`\n--- Price tracking run: ${new Date().toISOString()} ---`);
  for (const product of PRODUCTS) {
    for (const platform of PLATFORMS) {
      await trackProduct(product, platform);
      // Small delay to avoid rate limiting
      await new Promise((r) => setTimeout(r, 500));
    }
  }
  console.log("--- Tracking cycle complete ---\n");
}

// Run every 6 hours
cron.schedule("0 */6 * * *", runTrackingCycle);

// Also run immediately on start
runTrackingCycle();
console.log("Price tracker started. Running every 6 hours.");

import sqlite3
import smtplib
from email.mime.text import MIMEText
from datetime import datetime, timedelta

# Configuration
DB_PATH = "prices.db"
ALERT_EMAIL = "your-email@gmail.com"
SMTP_PASSWORD = "your-app-password"

# Products and their target prices
ALERTS = {
    "Aashirvaad Atta 5kg": 310,     # Alert if below Rs 310
    "Amul Butter 500g": 270,        # Alert if below Rs 270
    "Fortune Sunflower Oil 1L": 145, # Alert if below Rs 145
}

def check_price_drops():
    conn = sqlite3.connect(DB_PATH)
    cursor = conn.cursor()

    since = (datetime.now() - timedelta(hours=7)).isoformat()
    deals = []

    for product, target in ALERTS.items():
        cursor.execute("""
            SELECT platform, price, mrp
            FROM price_history
            WHERE product = ? AND price < ? AND tracked_at > ?
            ORDER BY price ASC
        """, (product, target, since))

        rows = cursor.fetchall()
        for platform, price, mrp in rows:
            savings = round((1 - price / mrp) * 100, 1)
            deals.append(f"{product} on {platform}: Rs {price} "
                        f"(MRP Rs {mrp}, {savings}% off)")

    conn.close()

    if deals:
        send_alert(deals)

def send_alert(deals):
    body = "Price drop alerts:\n\n" + "\n".join(deals)
    body += "\n\nPowered by QuickCommerce API"

    msg = MIMEText(body)
    msg["Subject"] = f"Price Drop Alert - {len(deals)} deals found"
    msg["From"] = ALERT_EMAIL
    msg["To"] = ALERT_EMAIL

    with smtplib.SMTP_SSL("smtp.gmail.com", 465) as server:
        server.login(ALERT_EMAIL, SMTP_PASSWORD)
        server.send_message(msg)

    print(f"Alert sent with {len(deals)} deals!")

if __name__ == "__main__":
    check_price_drops()