1. /**
  2. * Transforms data records for non-production use with error logging.
  3. * @param {Array<object>} records - An array of data records to transform.
  4. * @param {function} transformFunction - A function to transform each record.
  5. * @returns {Promise<Array<object>>} A promise that resolves with the transformed records or rejects with an error.
  6. */
  7. async function transformRecords(records, transformFunction) {
  8. if (!Array.isArray(records)) {
  9. throw new Error("Records must be an array.");
  10. }
  12. if (typeof transformFunction !== 'function') {
  13. throw new Error("Transform function must be a function.");
  14. }
  16. const transformedRecords = [];
  18. for (let i = 0; i < records.length; i++) {
  19. try {
  20. const record = records[i];
  22. if (typeof record !== 'object' || record === null) {
  23. console.warn(`Skipping invalid record at index ${i}: Not an object.`);
  24. continue;
  25. }
  27. const transformed = await transformFunction(record); //Use await for async transform functions.
  29. if (transformed !== undefined) {
  30. transformedRecords.push(transformed);
  31. } else {
  32. console.warn(`Skipping record at index ${i}: Transform function returned undefined.`);
  33. }
  34. } catch (error) {
  35. console.error(`Error transforming record at index ${i}:`, error);
  36. // Optionally, re-throw the error or handle it differently.
  37. //throw error; // Re-throw to stop processing.
  38. }
  39. }
  41. return transformedRecords;
  42. }
  45. export default transformRecords;

Add your comment