1. /**
  2. * Sanitizes metadata input for scheduled runs with retry logic.
  3. * @param {object} metadata - The input metadata object.
  4. * @returns {object} - The sanitized metadata object. Returns null if sanitization fails.
  5. */
  6. function sanitizeMetadata(metadata) {
  7. if (!metadata || typeof metadata !== 'object') {
  8. console.error("Invalid metadata input. Must be an object.");
  9. return null;
  10. }
  12. const sanitizedMetadata = {};
  14. for (const key in metadata) {
  15. if (metadata.hasOwnProperty(key)) {
  16. let value = metadata[key];
  18. // Sanitize string values
  19. if (typeof value === 'string') {
  20. value = value.trim(); // Remove leading/trailing whitespace
  21. if (value === '') {
  22. console.warn(`Skipping key "${key}" due to empty string value.`);
  23. continue; // Skip empty string
  24. }
  25. }
  27. // Sanitize numeric values
  28. if (typeof value === 'number') {
  29. value = Number(value); // Ensure it's a number. Handle possible NaN
  30. if (isNaN(value)) {
  31. console.warn(`Skipping key "${key}" due to invalid numeric value.`);
  32. continue;
  33. }
  34. }
  37. // Sanitize boolean values
  38. if (typeof value === 'boolean') {
  39. value = value.toLowerCase() === 'true'; //normalize boolean to lowercase true/false
  40. }
  42. sanitizedMetadata[key] = value;
  43. }
  44. }
  46. return sanitizedMetadata;
  47. }
  50. /**
  51. * Executes a task with retry logic.
  52. * @param {function} task - The task to execute.
  53. * @param {number} maxRetries - The maximum number of retries.
  54. * @param {number} delay - The delay between retries in milliseconds.
  55. * @returns {Promise<any>} - A promise that resolves with the task result or rejects after maxRetries.
  56. */
  57. async function executeWithRetry(task, maxRetries, delay) {
  58. let retries = 0;
  60. while (retries < maxRetries) {
  61. try {
  62. return await task(); // Execute the task
  63. } catch (error) {
  64. retries++;
  65. if (retries >= maxRetries) {
  66. console.error(`Task failed after ${maxRetries} retries:`, error);
  67. throw error; // Re-throw the error after max retries
  68. }
  69. console.warn(`Task failed. Retry attempt ${retries} in ${delay}ms.`);
  70. await new Promise(resolve => setTimeout(resolve, delay)); // Wait before retrying
  71. }
  72. }
  73. }
  75. export { sanitizeMetadata, executeWithRetry };

Add your comment