1. /**
  2. * Configures API endpoints with rate limiting.
  3. *
  4. * @param {object} config - Configuration object containing API endpoint definitions and rate limits.
  5. * @returns {object} - An object containing functions to access API endpoints with rate limiting.
  6. */
  7. function configureAPIs(config) {
  8. const apiEndpoints = {}; // Store API endpoints with rate limits
  10. // Validate config
  11. if (!config || typeof config !== 'object') {
  12. console.error("Invalid config provided. Must be an object.");
  13. return { };
  14. }
  16. for (const endpointName in config) {
  17. if (config.hasOwnProperty(endpointName)) {
  18. const endpoint = config[endpointName];
  20. if (typeof endpoint !== 'object' || !endpoint.url || !endpoint.rateLimit) {
  21. console.warn(`Invalid endpoint configuration for ${endpointName}. Skipping.`);
  22. continue;
  23. }
  25. apiEndpoints[endpointName] = {
  26. url: endpoint.url,
  27. rateLimit: endpoint.rateLimit,
  28. tokens: endpoint.rateLimit.max, // Initialize tokens
  29. resetTime: null,
  30. lock: false, // prevent concurrent requests
  31. acquire: async () => {
  32. // Wait until tokens are available
  33. while (apiEndpoints[endpointName].lock) {
  34. await new Promise(resolve => setTimeout(resolve, 10)); // Small delay
  35. }
  37. if (apiEndpoints[endpointName].tokens <= 0) {
  38. const now = Date.now();
  39. const nextAvailable = apiEndpoints[endpointName].resetTime || now + (1000 / apiEndpoints[endpointName].rateLimit.refetchInterval);
  41. if (nextAvailable > now) {
  42. // Wait until tokens are refilled
  43. await new Promise(resolve => setTimeout(resolve, nextAvailable - now));
  44. }
  45. }
  47. apiEndpoints[endpointName].tokens--;
  48. apiEndpoints[endpointName].lock = true;
  49. return;
  50. },
  51. release: () => {
  52. apiEndpoints[endpointName].tokens++;
  53. apiEndpoints[endpointName].lock = false;
  54. },
  56. fetch: async (data = {}) => {
  57. await apiEndpoints[endpointName].acquire(); // Acquire a token before fetching
  59. try {
  60. const response = await fetch(apiEndpoints[endpointName].url, {
  61. method: 'POST', // or GET, PUT, DELETE, etc.
  62. headers: {
  63. 'Content-Type': 'application/json',
  64. // Add other headers as needed
  65. },
  66. body: JSON.stringify(data), // or other data format
  67. });
  69. if (!response.ok) {
  70. throw new Error(`HTTP error! status: ${response.status}`);
  71. }
  73. const json = await response.json();
  74. return json;
  76. } catch (error) {
  77. console.error(`Error fetching from ${endpointName}:`, error);
  78. throw error; // Re-throw the error
  79. } finally {
  80. apiEndpoints[endpointName].release(); // Release the token after fetching
  81. }
  82. },
  83. resetTokens: () => {
  84. apiEndpoints[endpointName].tokens = apiEndpoints[endpointName].rateLimit.max;
  85. apiEndpoints[endpointName].resetTime = null;
  86. }
  87. };
  88. }
  89. }
  91. return { apiEndpoints };
  92. }
  94. export default configureAPIs;

Add your comment