1. /**
  2. * Tracks execution of directories with fixed retry intervals.
  3. * @param {string[]} directories An array of directory paths to track.
  4. * @param {object} options Configuration options.
  5. * @param {number} options.retryIntervalMs The retry interval in milliseconds. Defaults to 5000.
  6. * @param {number} options.maxRetries The maximum number of retries. Defaults to 3.
  7. * @param {function} options.executeFunction A function to execute within each directory. Takes directory path as argument.
  8. * @returns {Promise<object>} A promise that resolves with an object containing the results of each directory execution.
  9. */
  10. async function trackDirectoryExecution(directories, options = {}) {
  11. const { retryIntervalMs = 5000, maxRetries = 3, executeFunction } = options;
  12. const results = {};
  14. for (const directory of directories) {
  15. let retryCount = 0;
  17. while (retryCount < maxRetries) {
  18. try {
  19. // Execute the function for the current directory
  20. console.log(`Executing directory: ${directory}`);
  21. const result = await executeFunction(directory);
  22. console.log(`Directory ${directory} executed successfully.`);
  23. results[directory] = result;
  24. break; // Exit the retry loop if successful
  25. } catch (error) {
  26. console.error(`Error executing directory ${directory}:`, error);
  27. retryCount++;
  29. if (retryCount < maxRetries) {
  30. console.log(`Retrying directory ${directory} in ${retryIntervalMs}ms...`);
  31. await new Promise(resolve => setTimeout(resolve, retryIntervalMs));
  32. } else {
  33. console.error(`Max retries reached for directory ${directory}.`);
  34. }
  35. }
  36. }
  37. }
  39. return results;
  40. }

Add your comment