/check Command

bot.onText(/\/check/, async (msg) => {
  const chatId = msg.chat.id;
  const loading = await bot.sendMessage(chatId, "⏳ Revisando precios de todos los productos... (esto puede tardar)");
  try {
    await checkPrices();
    await bot.editMessageText("✅ Revisión completada. Si hubo cambios, los notifiqué.", {
      chat_id: chatId,
      message_id: loading.message_id
    });
  } catch (err) {
    console.error("❌ Error en /check:", err.message);
    await bot.editMessageText("❌ Ocurrió un error durante la revisión.", {
      chat_id: chatId,
      message_id: loading.message_id
    });
  }
});

async function checkPrices() {
  const keys = Object.keys(priceData);
  if (!keys.length) {
    console.log("ℹ️ No hay productos para revisar.");
    return;
  }

  console.log("⏳ Iniciando revisión de precios...");

  const browser = await chromium.launch({ headless: true, args: ["--no-sandbox", "--disable-dev-shm-usage"] });
  const context = await browser.newContext();
  const page = await context.newPage();

  const productsChanged = [];
  const errors = [];

  for (const key of keys) {
    const stored = priceData[key];
    if (!stored) continue;

    const sourceUrl = stored.url || key;
    const sanitized = sanitizeAmazonURL(sourceUrl);

    const scraped = await scrapeProduct(page, sanitized);
    if (scraped.error) {
      errors.push(`Error en ${stored.title || key}: ${scraped.error}`);
      stored.lastChecked = new Date().toISOString();
      priceData[key] = stored;
      await new Promise((r) => setTimeout(r, 800));
      continue;
    }

    const originalPrice = typeof stored.price === "number" ? stored.price : scraped.price;
    const originalLowest = typeof stored.lowestPrice === "number" ? stored.lowestPrice : scraped.price;

    const updated = {
      url: sanitized,
      title: scraped.title,
      price: scraped.price,
      imageUrl: scraped.imageUrl || stored.imageUrl || null,
      lastChecked: new Date().toISOString(),
      addedDate: stored.addedDate || new Date().toISOString(),
      addedBy: stored.addedBy || null,
      lowestPrice: Math.min(scraped.price, originalLowest),
      history: Array.isArray(stored.history) ? stored.history.slice() : []
    };

    // Always append history
    updated.history.push({ date: new Date().toISOString(), price: scraped.price });
    if (updated.history.length > HISTORY_LIMIT) updated.history = updated.history.slice(-HISTORY_LIMIT);

    // Detect price drop
    if (scraped.price < originalPrice) {
      const diff = (originalPrice - scraped.price).toFixed(2);
      const pct = (((originalPrice - scraped.price) / originalPrice) * 100).toFixed(1);

      const msg = `🚨 ¡Precio reducido!\n\n*${escapeMD(updated.title)}*\n\n💰 Precio anterior: $${originalPrice}\n🎯 Precio actual: $${scraped.price}\n💵 Ahorro: $${diff} (${pct}% menos)\n📉 Histórico más bajo: $${updated.lowestPrice}\n\n[Ver en Amazon](${sanitized})`;

      productsChanged.push({ url: sanitized, message: msg, imageUrl: updated.imageUrl });
    }

    priceData[finalKey] = updated;
    if (finalKey !== key) delete priceData[key];

    await new Promise((r) => setTimeout(r, 900));
  }

  await browser.close();
  saveData();

  // Notify chats about changes
  if (productsChanged.length) {
    console.log(`🎉 ${productsChanged.length} productos cambiados — notificando a ${chats.size} chats.`);
    for (const chatId of chats) {
      for (const p of productsChanged) {
        try {
          if (p.imageUrl) {
            await bot.sendPhoto(chatId, p.imageUrl, {
              caption: p.message,
              parse_mode: "Markdown",
              reply_markup: { inline_keyboard: [[{ text: "🛒 Ver en Amazon", url: p.url }]] }
            });
          } else {
            await bot.sendMessage(chatId, p.message, {
              parse_mode: "Markdown",
              reply_markup: { inline_keyboard: [[{ text: "🛒 Ver en Amazon", url: p.url }]] }
            });
          }
        } catch (err) {
          console.error(`❌ Error enviando notificación a ${chatId}:`, err.message);
        }
        await new Promise((r) => setTimeout(r, 500));
      }
    }
  } else {
    console.log("ℹ️ No se detectaron bajadas de precio en esta pasada.");
  }

  if (errors.length) console.warn("⚠️ Errores durante la revisión:", errors);
}

cron.schedule("0 */2 * * *", async () => {
  console.log("🔄 Cron: revisión automática de precios...");
  try {
    await checkPrices();
  } catch (err) {
    console.error("❌ Error en cron checkPrices:", err.message);
  }
});