1. const fs = require('fs').promises;
  2. const path = require('path');
  4. /**
  5. * Aggregates values from multiple files with a timeout.
  6. * @param {string[]} filePaths Array of file paths.
  7. * @param {number} timeout Timeout in milliseconds.
  8. * @returns {Promise<object>} A promise that resolves to an object containing the aggregated values, or rejects with an error.
  9. */
  10. async function aggregateFiles(filePaths, timeout) {
  11. const startTime = Date.now();
  12. const results = {};
  13. const promises = [];
  15. for (const filePath of filePaths) {
  16. promises.push(
  17. fs.readFile(filePath, 'utf8')
  18. .then(content => {
  19. try {
  20. // Parse the file content and extract values. Adapt this part based on your file format.
  21. const parsedData = parseFileContent(content);
  22. return parsedData;
  23. } catch (error) {
  24. console.error(`Error parsing file ${filePath}:`, error);
  25. return null; // or handle the error differently
  26. }
  27. })
  28. .catch(error => {
  29. console.error(`Error reading file ${filePath}:`, error);
  30. return null; // or handle the error differently
  31. })
  32. .finally(() => {
  33. // Remove the promise from the list
  34. promises.splice(promises.indexOf(this), 1);
  35. })
  36. );
  37. }
  39. try {
  40. const aggregatedResults = await Promise.all(promises);
  42. for (const result of aggregatedResults) {
  43. if(result) {
  44. for (const key in result) {
  45. if (result.hasOwnProperty(key)) {
  46. if (!results[key]) {
  47. results[key] = result[key];
  48. } else {
  49. results[key] += result[key]; // or perform other aggregation logic
  50. }
  51. }
  52. }
  53. }
  54. }
  55. return results;
  57. } catch (error) {
  58. console.error("AggregateFiles timed out:", error);
  59. return { error: "Timeout" };
  60. }
  61. }
  64. /**
  65. * Placeholder function to parse file content. Replace with your actual parsing logic.
  66. * @param {string} content The content of the file.
  67. * @returns {object} The parsed data.
  68. */
  69. function parseFileContent(content) {
  70. //Example: Assuming each line contains "key=value"
  71. const lines = content.split('\n');
  72. const data = {};
  73. for(const line of lines) {
  74. const [key, value] = line.split('=');
  75. data[key.trim()] = value.trim();
  76. }
  77. return data;
  78. }
  81. module.exports = aggregateFiles;

Add your comment