1. /**
  2. * Instruments list operations with rate limiting.
  3. *
  4. * @param {function} listOperation - The function to instrument (e.g., add, remove, get).
  5. * @param {number} maxRequestsPerSecond - The maximum number of requests allowed per second.
  6. * @returns {function} - A wrapped function that applies rate limiting.
  7. */
  8. function rateLimitListOperations(listOperation, maxRequestsPerSecond) {
  9. let queue = [];
  10. let lastExecutionTime = 0;
  12. async function executeWithRateLimit() {
  13. if (queue.length > 0) {
  14. const now = Date.now();
  15. const timeSinceLastExecution = now - lastExecutionTime;
  16. const delay = Math.max(0, 1000 / (maxRequestsPerSecond - Math.floor(timeSinceLastExecution / 1000))); // Calculate delay
  17. await new Promise(resolve => setTimeout(resolve, delay));
  19. const nextOperation = queue.shift();
  20. return nextOperation();
  21. }
  22. return Promise.resolve(listOperation()); // Execute if queue is empty
  23. }
  26. return async function (...args) {
  27. return executeWithRateLimit().then(result => {
  28. lastExecutionTime = Date.now();
  29. queue.push(() => result);
  30. return result;
  31. });
  32. };
  33. }

Add your comment