1. /**
  2. * Monitors scheduled queues for errors and provides basic input validation.
  3. *
  4. * @param {Array<Object>} queues An array of queue objects. Each queue object should have:
  5. * - name: (string) The name of the queue.
  6. * - tasks: (Array<Object>) An array of task objects. Each task object should have:
  7. * - name: (string) The name of the task.
  8. * - input: (Object) The input data for the task.
  9. * - execute: (function) The function to execute for the task.
  10. * @returns {Array<string>} An array of error messages. Empty if no errors found.
  11. */
  12. function checkQueuesForErrors(queues) {
  13. const errors = [];
  15. if (!Array.isArray(queues)) {
  16. errors.push("Input must be an array of queues.");
  17. return errors;
  18. }
  20. for (const queue of queues) {
  21. if (typeof queue !== 'object' || queue === null) {
  22. errors.push(`Invalid queue object: ${String(queue)}`);
  23. continue;
  24. }
  26. if (!queue.name || typeof queue.name !== 'string') {
  27. errors.push(`Queue name is missing or invalid: ${String(queue)}`);
  28. continue;
  29. }
  31. if (!Array.isArray(queue.tasks)) {
  32. errors.push(`Queue tasks must be an array: ${String(queue)}`);
  33. continue;
  34. }
  36. for (const task of queue.tasks) {
  37. if (typeof task !== 'object' || task === null) {
  38. errors.push(`Invalid task object: ${String(task)}`);
  39. continue;
  40. }
  42. if (!task.name || typeof task.name !== 'string') {
  43. errors.push(`Task name is missing or invalid: ${String(task)}`);
  44. continue;
  45. }
  47. if (typeof task.input !== 'object' || task.input === null) {
  48. errors.push(`Task input is missing or invalid: ${String(task)}`);
  49. continue;
  50. }
  52. if (typeof task.execute !== 'function') {
  53. errors.push(`Task execute function is missing or invalid: ${String(task)}`);
  54. continue;
  55. }
  57. try {
  58. //Attempt to execute the task to catch runtime errors
  59. task.execute(task.input);
  60. } catch (e) {
  61. errors.push(`Error executing task ${task.name} in queue ${queue.name}: ${String(e)}`);
  62. }
  63. }
  64. }
  66. return errors;
  67. }

Add your comment