1. /**
  2. * Diffs two datasets of queues for dry-run scenarios with error logging.
  3. * @param {Array<Object>} queue1 The first dataset of queues. Each object should have a 'queue' property.
  4. * @param {Array<Object>} queue2 The second dataset of queues. Each object should have a 'queue' property.
  5. * @param {string} queueName The name of the queue to compare. Used for logging.
  6. * @returns {Array<Object>} An array of differences between the queues. Each object in the array will have 'queue' and 'difference' properties.
  7. */
  8. function diffQueues(queue1, queue2, queueName) {
  9. const differences = [];
  11. if (!Array.isArray(queue1) || !Array.isArray(queue2)) {
  12. console.error("Error: Input must be arrays.");
  13. return differences; // Return empty array if invalid input
  14. }
  16. if (queue1.length !== queue2.length) {
  17. console.warn("Warning: Queue datasets have different lengths. Diffing may not be meaningful.");
  18. }
  20. for (let i = 0; i < queue1.length; i++) {
  21. const item1 = queue1[i];
  22. const item2 = queue2[i];
  24. if (typeof item1 !== 'object' || typeof item2 !== 'object' || !item1.hasOwnProperty('queue') || !item2.hasOwnProperty('queue')) {
  25. console.error(`Error: Invalid queue item at index ${i}. Expected object with 'queue' property.`);
  26. continue; // Skip to next iteration
  27. }
  29. const queue1Value = item1.queue;
  30. const queue2Value = item2.queue;
  33. if (queue1Value !== queue2Value) {
  34. differences.push({
  35. queue: queueName, // Queue name for logging
  36. difference: {
  37. index: i,
  38. value1: queue1Value,
  39. value2: queue2Value
  40. }
  41. });
  42. }
  43. }
  45. return differences;
  46. }

Add your comment