Webhooks: Agregar/Actualizar Producto

app.post('/api/products', (req, res) => {
  const { jobid, id } = req.query;
  const apiKey = req.headers['t2skey'];
  const productData = req.body;

  // Validar clave de API
  if (apiKey !== process.env.TALK2SYNC_KEY) {
    return res.status(401).json({
      success: false,
      code: 401,
      error: 'No autorizado',
      reasons: [{ msg: 'Clave de API inválida o faltante' }],
      warnings: []
    });
  }

  try {
    // Validar datos del producto
    const validationErrors = validateProduct(productData);
    if (validationErrors.length > 0) {
      return res.status(400).json({
        success: false,
        code: 400,
        error: 'La validación falló',
        reasons: validationErrors.map(msg => ({ msg })),
        warnings: []
      });
    }

    // Realizar operación upsert
    const savedProduct = upsertProduct(id, productData);

    // Devolver respuesta de éxito
    res.json({
      success: true,
      code: 200,
      warnings: [],
      product: savedProduct
    });

  } catch (error) {
    console.error('Error al crear/actualizar producto:', error);
    res.status(500).json({
      success: false,
      code: 500,
      error: 'La operación de base de datos falló',
      reasons: [{ msg: error.message }],
      warnings: []
    });
  }
});

// Función de validación
function validateProduct(product) {
  const errors = [];

  // Verificar campos obligatorios
  if (!product.title || product.title.trim() === '') {
    errors.push('El título es obligatorio');
  }

  // Validar variaciones
  if (!product.variations || product.variations.length === 0) {
    errors.push('Se requiere al menos una variación');
  }

  // Validar precios
  product.variations?.forEach((variation, idx) => {
    variation.prices?.forEach((price, priceIdx) => {
      if (price.number <= 0) {
        errors.push(`Variación ${idx}: El precio ${priceIdx} debe ser mayor a cero`);
      }
    });
  });

  // Validar imágenes
  product.variations?.forEach((variation, idx) => {
    variation.images?.forEach((image, imgIdx) => {
      if (!isValidUrl(image.url)) {
        errors.push(`Variación ${idx}: La imagen ${imgIdx} tiene URL inválida`);
      }
    });
  });

  return errors;
}

function isValidUrl(string) {
  try {
    new URL(string);
    return true;
  } catch (_) {
    return false;
  }
}

// Función upsert
function upsertProduct(id, productData) {
  // Verificar si el producto existe
  const existingProduct = findProductById(id);

  if (existingProduct) {
    // Actualizar producto existente
    return updateProductInDatabase(id, productData);
  } else {
    // Insertar nuevo producto
    return insertProductInDatabase(productData);
  }
}