1. /**
  2. * Flags anomalies in API payloads with retry logic.
  3. *
  4. * @param {function} apiCall - Function to make the API call. Should return a promise resolving to the payload.
  5. * @param {function} anomalyCheck - Function to check for anomalies in the payload. Should return true if anomalous, false otherwise.
  6. * @param {object} options - Configuration options.
  7. * @param {number} options.maxRetries - Maximum number of retry attempts.
  8. * @param {number} options.retryDelay - Delay in milliseconds between retries.
  9. * @returns {Promise<any>} - Promise resolving to the payload if successful, or rejecting with an error.
  10. */
  11. async function flagPayloadAnomalies(apiCall, anomalyCheck, options = {}) {
  12. const maxRetries = options.maxRetries || 3;
  13. const retryDelay = options.retryDelay || 1000;
  14. let retryCount = 0;
  16. while (retryCount < maxRetries) {
  17. try {
  18. const payload = await apiCall(); // Make the API call
  20. if (anomalyCheck(payload)) { // Check for anomalies
  21. console.warn("Anomaly detected in payload:", payload);
  22. return payload; // Return on anomaly detection
  23. }
  25. return payload; // No anomaly, return the payload
  27. } catch (error) {
  28. retryCount++;
  29. console.error(`API call failed (attempt ${retryCount}/${maxRetries}):`, error);
  31. if (retryCount < maxRetries) {
  32. await new Promise(resolve => setTimeout(resolve, retryDelay)); // Wait before retrying
  33. } else {
  34. throw error; // Re-throw if max retries reached
  35. }
  36. }
  37. }
  39. throw new Error("Max retries reached. API call failed."); //Re-throw if max retries reached
  41. }

Add your comment