1. /**
  2. * Detects errors in task queues for staging environments (synchronous).
  3. * Assumes a simple queue structure (e.g., an array).
  4. *
  5. * @param {Array} queue - The task queue (array of task objects).
  6. * @param {function} taskExecutor - A function to execute each task. Receives a task object as input.
  7. * @returns {Array} - An array of error objects. Empty array if no errors found.
  8. */
  9. function detectStagingQueueErrors(queue, taskExecutor) {
  10. const errors = [];
  12. if (!Array.isArray(queue)) {
  13. errors.push({ message: "Queue must be an array." });
  14. return errors;
  15. }
  17. for (let i = 0; i < queue.length; i++) {
  18. const task = queue[i];
  20. if (typeof task !== 'object' || task === null) {
  21. errors.push({ message: `Invalid task at index ${i}. Task must be an object.` });
  22. continue; // Skip to the next task
  23. }
  25. if (typeof taskExecutor !== 'function') {
  26. errors.push({ message: "taskExecutor must be a function." });
  27. return errors;
  28. }
  30. try {
  31. taskExecutor(task); // Execute the task
  32. } catch (error) {
  33. errors.push({ index: i, message: error.message, stack: error.stack }); // Capture error details
  34. }
  35. }
  37. return errors;
  38. }
  40. export default detectStagingQueueErrors;

Add your comment