Webhooks: Add/Update Product

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

  // Validate API key
  if (apiKey !== process.env.TALK2SYNC_KEY) {
    return res.status(401).json({
      success: false,
      code: 401,
      error: 'Unauthorized',
      reasons: [{ msg: 'Invalid or missing API key' }],
      warnings: []
    });
  }

  try {
    // Validate product data
    const validationErrors = validateProduct(productData);
    if (validationErrors.length > 0) {
      return res.status(400).json({
        success: false,
        code: 400,
        error: 'Validation failed',
        reasons: validationErrors.map(msg => ({ msg })),
        warnings: []
      });
    }

    // Perform upsert operation
    const savedProduct = upsertProduct(id, productData);

    // Return success response
    res.json({
      success: true,
      code: 200,
      warnings: [],
      product: savedProduct
    });

  } catch (error) {
    console.error('Error upserting product:', error);
    res.status(500).json({
      success: false,
      code: 500,
      error: 'Database operation failed',
      reasons: [{ msg: error.message }],
      warnings: []
    });
  }
});

// Validation function
function validateProduct(product) {
  const errors = [];

  // Check required fields
  if (!product.title || product.title.trim() === '') {
    errors.push('Title is required');
  }

  // Validate variations
  if (!product.variations || product.variations.length === 0) {
    errors.push('At least one variation is required');
  }

  // Validate prices
  product.variations?.forEach((variation, idx) => {
    variation.prices?.forEach((price, priceIdx) => {
      if (price.number <= 0) {
        errors.push(`Variation ${idx}: Price ${priceIdx} must be greater than zero`);
      }
    });
  });

  // Validate images
  product.variations?.forEach((variation, idx) => {
    variation.images?.forEach((image, imgIdx) => {
      if (!isValidUrl(image.url)) {
        errors.push(`Variation ${idx}: Image ${imgIdx} has invalid URL`);
      }
    });
  });

  return errors;
}

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

// Upsert function
function upsertProduct(id, productData) {
  // Check if product exists
  const existingProduct = findProductById(id);

  if (existingProduct) {
    // Update existing product
    return updateProductInDatabase(id, productData);
  } else {
    // Insert new product
    return insertProductInDatabase(productData);
  }
}