1. /**
  2. * Extends task queue logic with debugging and graceful failure handling.
  3. *
  4. * @param {Array<Function>} queue - The task queue (array of functions).
  5. * @param {function} errorCallback - Callback function to handle task failures.
  6. * @returns {function} - A modified queue with debugging capabilities.
  7. */
  8. function enhanceTaskQueue(queue, errorCallback) {
  9. if (!Array.isArray(queue)) {
  10. console.error("Queue must be an array.");
  11. return function(task) {
  12. errorCallback("Invalid queue provided");
  13. };
  14. }
  16. if (typeof errorCallback !== 'function') {
  17. console.error("Error callback must be a function.");
  18. return function(task) {
  19. errorCallback("Invalid error callback");
  20. };
  21. }
  24. const enhancedQueue = [...queue]; // Create a copy to avoid modifying the original
  26. enhancedQueue.forEach((task, index) => {
  27. const originalTask = task; // Store the original task
  29. task = function (...args) {
  30. console.debug(`Executing task at index ${index} with arguments:`, args);
  31. try {
  32. const result = originalTask(...args); // Execute the original task
  33. console.debug(`Task at index ${index} completed successfully. Result:`, result);
  34. return result;
  35. } catch (error) {
  36. console.error(`Task at index ${index} failed:`, error);
  37. errorCallback(error); // Call the error callback
  38. return undefined; // Or handle the error appropriately (e.g., re-queue)
  39. }
  40. };
  42. enhancedQueue[index] = task; // Replace the original task with the enhanced version
  43. });
  46. return enhancedQueue;
  47. }
  50. /**
  51. * Example usage (for testing/demonstration)
  52. */
  53. // const myQueue = [
  54. // (x) => x * 2,
  55. // (x) => { throw new Error("Simulated error"); },
  56. // (x) => x + 1
  57. // ];
  58. //
  59. // const handleErrors = (error) => {
  60. // console.error("Error occurred:", error);
  61. // };
  62. //
  63. // const enhancedQueue = enhanceTaskQueue(myQueue, handleErrors);
  64. //
  65. // enhancedQueue.forEach(task => {
  66. // task(5);
  67. // });

Add your comment