1. /**
  2. * Syncs resources of configuration files for data migration with fixed retry intervals.
  3. *
  4. * @param {Array<string>} configFiles An array of configuration file paths.
  5. * @param {object} options Configuration options.
  6. * @param {number} options.retryIntervalMs The retry interval in milliseconds.
  7. * @param {number} options.maxRetries The maximum number of retry attempts.
  8. * @returns {Promise<Array<object>>} A promise that resolves with an array of success/failure objects.
  9. */
  10. async function syncConfigs(configFiles, options = {}) {
  11. const retryIntervalMs = options.retryIntervalMs || 1000; // Default retry interval: 1 second
  12. const maxRetries = options.maxRetries || 3; // Default max retries: 3
  14. const results = [];
  16. for (const configFile of configFiles) {
  17. let success = false;
  18. let retryCount = 0;
  20. while (!success && retryCount < maxRetries) {
  21. try {
  22. const config = await syncConfigFile(configFile); // Helper function to sync a single config file
  23. results.push({ file: configFile, success: true, data: config });
  24. success = true;
  25. } catch (error) {
  26. console.error(`Failed to sync ${configFile}. Retry attempt ${retryCount + 1}/${maxRetries}.`, error);
  27. retryCount++;
  28. await new Promise(resolve => setTimeout(resolve, retryIntervalMs)); // Wait before retrying
  29. }
  30. }
  32. if (!success) {
  33. results.push({ file: configFile, success: false, error: "Failed after multiple retries" });
  34. }
  35. }
  37. return results;
  38. }
  40. /**
  41. * Helper function to sync a single configuration file.
  42. * @param {string} filePath The path to the configuration file.
  43. * @returns {Promise<object>} A promise that resolves with the parsed configuration object.
  44. * @throws {Error} If the file cannot be read or parsed.
  45. */
  46. async function syncConfigFile(filePath) {
  47. try {
  48. const fs = require('fs').promises; // Use promises-based fs API
  49. const fileContent = await fs.readFile(filePath, 'utf8');
  50. const config = JSON.parse(fileContent); // Assuming JSON format
  51. return config;
  52. } catch (error) {
  53. throw new Error(`Error syncing config file ${filePath}: ${error.message}`);
  54. }
  55. }
  57. module.exports = syncConfigs;

Add your comment