1. /**
  2. * Flags anomalies in a collection based on rate limiting.
  3. *
  4. * @param {Array<Object>} collection - The collection of data to analyze.
  5. * @param {number} rateLimit - The maximum number of items allowed within a time window (in milliseconds).
  6. * @param {number} windowSize - The size of the time window in milliseconds.
  7. * @returns {Array<Object>} - The original collection with anomaly flags added.
  8. */
  9. function flagAnomalies(collection, rateLimit, windowSize) {
  10. const anomalyFlags = [];
  11. const requestTimestamps = [];
  13. collection.forEach(item => {
  14. const timestamp = Date.now();
  16. // Remove outdated timestamps
  17. while (requestTimestamps.length > 0 && requestTimestamps[0] <= timestamp - windowSize) {
  18. requestTimestamps.shift(); // Remove the oldest timestamp
  19. }
  21. // Check if the rate limit is exceeded
  22. if (requestTimestamps.length >= rateLimit) {
  23. anomalyFlags.push({ item: item, reason: 'Rate Limit Exceeded' });
  24. }
  26. requestTimestamps.push(timestamp);
  27. });
  29. // Add anomaly flags to the original collection
  30. const flaggedCollection = collection.map(item => {
  31. if (anomalyFlags.some(flag => flag.item === item)) {
  32. return { ...item, anomalyFlag: anomalyFlags.find(flag => flag.item === item) };
  33. }
  34. return item;
  35. });
  37. return flaggedCollection;
  38. }

Add your comment