1. /**
  2. * Retries JSON payload validation operations with minimal configuration.
  3. *
  4. * @param {object} options Configuration options.
  5. * @param {Array<object>} options.payloads Array of JSON payloads to validate.
  6. * @param {number} options.maxRetries Maximum number of retries per payload. Defaults to 3.
  7. * @param {number} options.retryDelay Delay between retries in milliseconds. Defaults to 1000.
  8. * @param {function} options.validateFunction Function to validate the payload. Should return a boolean.
  9. * @returns {Promise<Array<object>>} A promise that resolves to an array of validation results.
  10. */
  11. async function retryJsonValidation(options) {
  12. const { payloads, maxRetries = 3, retryDelay = 1000, validateFunction } = options;
  14. if (!payloads || !Array.isArray(payloads) || payloads.length === 0) {
  15. return []; // Return empty array if no payloads are provided.
  16. }
  18. const results = [];
  20. for (const payload of payloads) {
  21. let attempts = 0;
  22. let isValid = false;
  24. while (attempts < maxRetries) {
  25. try {
  26. isValid = await validateFunction(payload); // Validate the payload
  27. if (isValid) {
  28. break; // Exit retry loop if valid
  29. }
  30. } catch (error) {
  31. attempts++;
  32. if (attempts < maxRetries) {
  33. await new Promise(resolve => setTimeout(resolve, retryDelay)); // Wait before retrying
  34. } else {
  35. console.error(`Validation failed after ${maxRetries} retries for payload:`, payload, error);
  36. }
  37. }
  38. }
  40. results.push({ payload, isValid });
  41. }
  43. return results;
  44. }

Add your comment