1. /**
  2. * Validates queue data for diagnostics with fixed retry intervals.
  3. * @param {Array<Object>} queues An array of queue objects.
  4. * @param {Object} config Configuration object containing retry interval.
  5. * @returns {Array<Object>} Validated queue objects. Returns an empty array if invalid input.
  6. */
  7. function validateQueues(queues, config) {
  8. if (!Array.isArray(queues)) {
  9. console.error("Invalid input: queues must be an array.");
  10. return [];
  11. }
  12. if (!config || typeof config.retryInterval !== 'number' || config.retryInterval <= 0) {
  13. console.error("Invalid input: config must contain a valid retryInterval (positive number).");
  14. return [];
  15. }
  17. const validatedQueues = [];
  19. for (const queue of queues) {
  20. if (typeof queue !== 'object' || queue === null) {
  21. console.warn("Invalid queue object encountered. Skipping.");
  22. continue;
  23. }
  25. if (typeof queue.name !== 'string' || queue.name.trim() === '') {
  26. console.error("Invalid queue: name must be a non-empty string.");
  27. continue;
  28. }
  30. if (typeof queue.url !== 'string' || queue.url.trim() === '') {
  31. console.error("Invalid queue: url must be a non-empty string.");
  32. continue;
  33. }
  35. if (typeof queue.retryInterval !== 'number' || queue.retryInterval <= 0) {
  36. console.error("Invalid queue: retryInterval must be a positive number.");
  37. continue;
  38. }
  40. validatedQueues.push(queue);
  41. }
  43. return validatedQueues;
  44. }

Add your comment