1. /**
  2. * Flags anomalies in queues and logs errors.
  3. *
  4. * @param {Array} queue - The queue to analyze.
  5. * @param {object} config - Configuration object with anomaly thresholds.
  6. */
  7. function flagQueueAnomalies(queue, config) {
  8. if (!Array.isArray(queue)) {
  9. console.error("Invalid input: queue must be an array.");
  10. return;
  11. }
  13. if (!config || typeof config !== 'object') {
  14. console.error("Invalid input: config must be an object.");
  15. return;
  16. }
  18. const anomalyThreshold = config.anomalyThreshold || 0.1; // Default threshold
  19. const minQueueLength = config.minQueueLength || 5; // Default min length
  20. const maxQueueLength = config.maxQueueLength || 100; // Default max length
  21. const maxItemSize = config.maxItemSize || 100; // Default max item size
  23. // Check queue length
  24. if (queue.length < minQueueLength) {
  25. console.warn(`Queue length (${queue.length}) below minimum (${minQueueLength}).`);
  26. }
  27. if (queue.length > maxQueueLength) {
  28. console.warn(`Queue length (${queue.length}) above maximum (${maxQueueLength}).`);
  29. }
  31. // Check item size (assuming items are objects)
  32. for (const item of queue) {
  33. if (typeof item !== 'object' || item === null) {
  34. console.warn("Queue contains non-object item. Skipping size check.");
  35. continue;
  36. }
  37. if (Object.keys(item).length > maxItemSize) {
  38. console.warn(`Item size (${Object.keys(item).length}) exceeds maximum (${maxItemSize}).`);
  39. }
  40. }
  42. //Example: Check for duplicate items (simple example)
  43. const itemCounts = {};
  44. for (const item of queue) {
  45. const itemStr = JSON.stringify(item); //Convert object to string for comparison
  46. if (itemCounts[itemStr]) {
  47. itemCounts[itemStr]++;
  48. if (itemCounts[itemStr] > 2) { //Flag if item appears more than twice
  49. console.warn(`Duplicate item found: ${itemStr}`);
  50. }
  51. } else {
  52. itemCounts[itemStr] = 1;
  53. }
  54. }
  55. }

Add your comment