1. /**
  2. * Handles record processing with graceful failure.
  3. * @param {object} record The record to process.
  4. * @param {function} processRecord Function to process the record. Should return a Promise.
  5. * @param {function} onError Function to handle errors. Takes the record and error as arguments.
  6. * @returns {Promise<object>} A promise that resolves with the processed record or rejects with the last error.
  7. */
  8. async function processRecordGracefully(record, processRecord, onError) {
  9. try {
  10. // Attempt to process the record
  11. const result = await processRecord(record);
  13. // If processing is successful, return the result
  14. return result;
  15. } catch (error) {
  16. // Handle errors gracefully
  17. console.error("Error processing record:", record, error);
  18. onError(record, error); // Call the onError callback
  19. // Optionally, you can log the error to a monitoring system here.
  21. // Re-throw the error to propagate it to the caller (if desired).
  22. // throw error;
  24. //Return a rejected promise if the error is not handled by onError
  25. throw error;
  26. }
  27. }
  30. /**
  31. * Example usage (for testing/demonstration)
  32. */
  33. //Simulated processRecord function
  34. async function simulateProcessRecord(record) {
  35. return new Promise((resolve, reject) => {
  36. setTimeout(() => {
  37. if (record.id % 3 === 0) {
  38. resolve({ ...record, processed: true });
  39. } else if (record.id % 5 === 0) {
  40. reject(new Error("Simulated processing error for id: " + record.id));
  41. } else{
  42. resolve({ ...record, processed: true });
  43. }
  44. }, 50); // Simulate some asynchronous operation
  45. });
  46. }
  48. /**
  49. * Example onError function
  50. */
  51. function exampleOnError(record, error) {
  52. console.warn("Record failed to process:", record, error.message);
  53. // Optionally, you can add logic to retry the record later.
  54. }
  58. //Example usage:
  59. async function runExample() {
  60. const record1 = { id: 1, data: "data1" };
  61. const record2 = { id: 2, data: "data2" };
  62. const record3 = { id: 3, data: "data3" };
  63. const record4 = { id: 5, data: "data5" };
  65. try {
  66. const result1 = await processRecordGracefully(record1, simulateProcessRecord, exampleOnError);
  67. console.log("Record 1 processed:", result1);
  69. const result2 = await processRecordGracefully(record2, simulateProcessRecord, exampleOnError);
  70. console.log("Record 2 processed:", result2);
  72. const result3 = await processRecordGracefully(record3, simulateProcessRecord, exampleOnError);
  73. console.log("Record 3 processed:", result3);
  75. const result4 = await processRecordGracefully(record4, simulateProcessRecord, exampleOnError);
  76. console.log("Record 4 processed:", result4);
  80. } catch (error) {
  81. console.error("Unhandled error:", error);
  82. }
  83. }
  85. runExample();

Add your comment