1. const fs = require('fs');
  2. const path = require('path');
  4. /**
  5. * Sorts records in a file with retry logic.
  6. * @param {string} filePath - The path to the file.
  7. * @param {function} parseRecord - Function to parse each line into a record. Returns null if parsing fails.
  8. * @param {function} compareRecords - Function to compare two records.
  9. * @param {object} options - Optional configuration.
  10. * @param {number} options.maxRetries - Maximum number of retry attempts.
  11. * @param {number} options.retryDelay - Delay in milliseconds between retries.
  12. * @returns {Promise<Array<any>>} - A promise that resolves to the sorted array of records, or rejects on error.
  13. */
  14. async function sortFileRecords(filePath, parseRecord, compareRecords, options = {}) {
  15. const { maxRetries = 3, retryDelay = 1000 } = options;
  16. let retries = 0;
  18. while (retries < maxRetries) {
  19. try {
  20. const fileContent = fs.readFileSync(filePath, 'utf8'); // Read file content
  21. const records = fileContent.split('\n').map(line => {
  22. if (line.trim() === '') return null; // Skip empty lines
  23. return parseRecord(line.trim()); // Parse each line into a record
  24. }).filter(record => record !== null); //Remove null entries (failed parsing)
  26. if (!records || records.length === 0) {
  27. throw new Error("No records found in file or parsing failed.");
  28. }
  30. const sortedRecords = [...records].sort(compareRecords); // Create a copy to avoid modifying the original array
  31. return sortedRecords;
  33. } catch (error) {
  34. retries++;
  35. console.warn(`Error sorting file (attempt ${retries}/${maxRetries}): ${error.message}`);
  36. if (retries < maxRetries) {
  37. await new Promise(resolve => setTimeout(resolve, retryDelay)); // Wait before retrying
  38. } else {
  39. throw error; // Re-throw the error after all retries have failed
  40. }
  41. }
  42. }
  43. }
  46. module.exports = sortFileRecords;

Add your comment