1. /**
  2. * Initializes log file components for scheduled runs with fixed retry intervals.
  3. *
  4. * @param {object} config Configuration object containing log file details and retry settings.
  5. * config.logFilePath: Path to the log file.
  6. * config.retryIntervalMs: Retry interval in milliseconds.
  7. * config.maxRetries: Maximum number of retry attempts.
  8. */
  9. function initializeLogFileComponents(config) {
  10. const logFilePath = config.logFilePath;
  11. const retryIntervalMs = config.retryIntervalMs;
  12. const maxRetries = config.maxRetries;
  14. // Initialize retry counter
  15. let retryCount = 0;
  17. // Function to attempt to read the log file
  18. async function attemptReadLogFile() {
  19. try {
  20. const data = await readLogFile(logFilePath);
  21. return data; // Return data if successful
  22. } catch (error) {
  23. retryCount++;
  24. if (retryCount <= maxRetries) {
  25. console.log(`Attempt ${retryCount} failed. Retrying in ${retryIntervalMs}ms...`);
  26. await delay(retryIntervalMs); // Wait before retrying
  27. return attemptReadLogFile(); // Recursively retry
  28. } else {
  29. console.error(`Failed to read log file after ${maxRetries} attempts.`);
  30. throw error; // Re-throw the error if all retries fail
  31. }
  32. }
  33. }
  35. // Function to read the log file (implementation depends on your environment)
  36. async function readLogFile(filePath) {
  37. // Replace with your actual file reading logic (e.g., using fs, axios, etc.)
  38. // This is a placeholder implementation.
  39. console.log(`Reading log file: ${filePath}`);
  40. await delay(500); // Simulate file reading time
  41. return `Log data from ${filePath}`;
  42. }
  44. // Function to delay execution
  45. function delay(ms) {
  46. return new Promise(resolve => setTimeout(resolve, ms));
  47. }
  49. // Return the retryCount (can be used by other components)
  50. return {
  51. retryCount: retryCount,
  52. attemptReadLogFile: attemptReadLogFile
  53. };
  54. }

Add your comment