uploader.js

// uploader.js — Puppeteer automation: open form, fill fields, upload image, save

import { sleep, applyTemplate, log } from './utils.js';

// Form selectors on the target admin page — change these to match your site
export const SELECTORS = {
  addButton:  'button[onclick="showAddForm()"]',
  price:      '#productGia',
  data:       '#dulieu',
  image:      '#productAvatar',
  code:       '#noibat',
  saveButton: 'button[onclick="saveProduct()"]',
};

async function waitFor(page, selector, timeout = 6000) {
  try {
    await page.waitForSelector(selector, { timeout });
    return await page.$(selector);
  } catch {
    throw new Error(`Timeout: không tìm thấy "${selector}" sau ${timeout}ms`);
  }
}

// Set a value and fire input/change so the page's JS sees the update
async function setField(page, selector, value) {
  if (!value && value !== 0) return false;
  const el = await page.$(selector);
  if (!el) return false;
  await page.$eval(selector, (el, val) => {
    el.value = String(val);
    el.dispatchEvent(new Event('input',  { bubbles: true }));
    el.dispatchEvent(new Event('change', { bubbles: true }));
  }, String(value));
  return true;
}

async function openAddForm(page) {
  const btn = await page.$(SELECTORS.addButton);
  if (btn) {
    await btn.click();
    await sleep(300);
  }
}

async function fillOneProduct(page, product, note, dataTemplate) {
  const resolvedNote = product.note || note || '';

  await waitFor(page, SELECTORS.price, 5000);
  await setField(page, SELECTORS.price, product.gia);

  if (!(await page.$(SELECTORS.data))) throw new Error(`Không tìm thấy ${SELECTORS.data}`);
  await setField(page, SELECTORS.data, applyTemplate(dataTemplate, product.maSP, product.gia, resolvedNote));

  if (product.filePath) {
    const avatarInput = await waitFor(page, SELECTORS.image, 5000);
    await avatarInput.uploadFile(product.filePath);
    await sleep(300);
  }

  await setField(page, SELECTORS.code, product.maSP);
}

async function clickSaveButton(page) {
  const btn = await page.$(SELECTORS.saveButton);
  if (!btn) throw new Error(`Không tìm thấy nút LƯU (${SELECTORS.saveButton})`);
  await btn.click();
  await sleep(300);
}

// Reload the admin page with a cache-busting param so each product starts clean
async function navigateClean(page, adminUrl) {
  try {
    const u = new URL(adminUrl);
    u.searchParams.set('_au', Date.now().toString());
    await page.goto(u.toString(), { waitUntil: 'domcontentloaded', timeout: 15000 });
  } catch {
    await page.goto(adminUrl, { waitUntil: 'domcontentloaded', timeout: 15000 });
  }
  await sleep(600);
}

// Upload one product, retrying up to 3 times on failure
export async function uploadOne(page, product, config, attempt = 1) {
  const MAX_RETRY = 3;
  const { note, dataTemplate, adminUrl, delay, dryRun } = config;

  try {
    await navigateClean(page, adminUrl);
    await openAddForm(page);
    await fillOneProduct(page, product, note, dataTemplate);

    if (delay > 0) await sleep(delay);

    if (dryRun) {
      log.dryrun(`[DRY RUN] Sẽ lưu: ${product.maSP}`);
    } else {
      await clickSaveButton(page);
      await Promise.race([
        page.waitForNavigation({ waitUntil: 'domcontentloaded', timeout: 5000 }).catch(() => {}),
        sleep(5000),
      ]);
    }
    return { status: 'success' };

  } catch (err) {
    if (attempt < MAX_RETRY) {
      log.warn(`Thử lại lần ${attempt}/${MAX_RETRY}: ${err.message}`);
      await sleep(1000);
      return uploadOne(page, product, config, attempt + 1);
    }
    throw new Error(`Lỗi sau ${MAX_RETRY} lần thử: ${err.message}`);
  }
}