1. /**
  2. * Wraps JSON object processing with error handling and fallback.
  3. *
  4. * @param {any[]} data An array of JSON objects to process.
  5. * @param {function} processObject A function to process each JSON object.
  6. * @param {function} fallback A function to call if processing fails.
  7. * @returns {Promise<any[]>} A promise that resolves with the processed data or rejects on a critical error.
  8. */
  9. async function processBatchJson(data, processObject, fallback) {
  10. if (!Array.isArray(data)) {
  11. return fallback("Input must be an array."); // Fallback for invalid input
  12. }
  14. const results = [];
  16. for (const item of data) {
  17. try {
  18. if (typeof item !== 'object' || item === null) {
  19. console.warn("Skipping non-object item:", item);
  20. results.push(null); //Or handle non-object items as needed, e.g. skip them
  21. continue;
  22. }
  24. const processedItem = await processObject(item);
  25. results.push(processedItem);
  26. } catch (error) {
  27. console.error("Error processing item:", item, error);
  28. results.push(null); // Or handle errors differently, e.g., skip the item
  29. if (fallback) {
  30. try {
  31. const fallbackResult = await fallback(item, error); // Pass the original item and error to fallback
  32. results.push(fallbackResult);
  33. } catch (fallbackError) {
  34. console.error("Fallback failed:", fallbackError);
  35. results.push(null); // or handle the fallback failure
  36. }
  37. }
  38. }
  39. }
  41. return results;
  42. }

Add your comment