1. /**
  2. * Wraps a function that processes a JSON payload with retry logic.
  3. *
  4. * @param {function} fn The function to execute with retry. Should accept a JSON payload as input.
  5. * @param {number} maxRetries The maximum number of retry attempts.
  6. * @param {number} delayMs The delay in milliseconds between retries.
  7. * @returns {function} A function that takes a JSON payload and executes the wrapped function with retry.
  8. */
  9. function retryWithDelay(fn, maxRetries, delayMs) {
  10. let retryCount = 0;
  12. /**
  13. * Executes the wrapped function with retry logic.
  14. * @param {object} payload The JSON payload to process.
  15. * @returns {Promise<any>} A promise that resolves with the result of the function or rejects if all retries fail.
  16. */
  17. return async function (payload) {
  18. return new Promise((resolve, reject) => {
  19. function attempt() {
  20. fn(payload) // Execute the original function
  21. .then(resolve)
  22. .catch(err => {
  23. retryCount++;
  24. if (retryCount >= maxRetries) {
  25. reject(err); // Reject the promise if max retries reached
  26. return;
  27. }
  29. setTimeout(() => {
  30. attempt(); // Retry after the specified delay
  31. }, delayMs);
  32. });
  33. }
  35. attempt(); // Start the first attempt
  36. });
  37. };
  38. }

Add your comment