1. const fs = require('fs');
  3. /**
  4. * Aggregates values from multiple API endpoints based on a configuration file.
  5. * @param {string} configPath Path to the configuration file.
  6. * @returns {Promise<object>} A promise that resolves with the aggregated data.
  7. * @throws {Error} If the configuration file is invalid or an API call fails.
  8. */
  9. async function aggregateData(configPath) {
  10. try {
  11. const config = require(configPath); // Load configuration from file
  13. const aggregatedData = {};
  15. for (const endpointName in config.endpoints) {
  16. if (config.endpoints.hasOwnProperty(endpointName)) {
  17. const endpoint = config.endpoints[endpointName];
  18. const apiUrl = endpoint.apiUrl;
  19. const method = endpoint.method || 'GET'; // Default to GET
  20. const params = endpoint.params || {};
  22. try {
  23. const response = await fetch(apiUrl, {
  24. method: method,
  25. headers: {
  26. 'Content-Type': 'application/json',
  27. ...endpoint.headers // Add any custom headers
  28. },
  29. body: JSON.stringify(params) // Convert params to JSON if needed
  30. });
  32. if (!response.ok) {
  33. throw new Error(`API request failed with status ${response.status}: ${response.statusText}`);
  34. }
  36. const data = await response.json();
  38. // Aggregate data based on endpoint structure. Adapt as needed.
  39. if (Array.isArray(data)) {
  40. aggregatedData[endpointName] = data; //Store as an array
  41. } else {
  42. aggregatedData[endpointName] = data; //Store as object
  43. }
  45. } catch (error) {
  46. console.error(`Error fetching data from ${apiUrl}:`, error);
  47. throw error; // Re-throw the error to stop the process
  48. }
  49. }
  50. }
  52. return aggregatedData;
  54. } catch (error) {
  55. console.error("Error reading configuration:", error);
  56. throw error;
  57. }
  58. }
  61. module.exports = aggregateData;

Add your comment