feature/IO-3096-GlobalNotifications - Checkpoint, Builders

server/notifications/eventParser.js

@@ -10,8 +10,8 @@
  * @param {string} params.table - The name of the table where the event occurred.
  * @param {string} [params.jobIdField] - The field name or key path (e.g., "req.body.event.new.jobid") used to extract the job ID.
  * @returns {Promise<Object>} An object containing:
- *   - {@link changedFieldNames}: An array of field names that have changed.
- *   - {@link changedFields}: An object mapping changed field names to their new values (or `null` if the field was removed).
+ *   - {string[]} changedFieldNames - An array of field names that have changed.
+ *   - {Object} changedFields - An object mapping changed field names to an object with `old` and `new` values.
  *   - {boolean} isNew - Indicates if the event is for new data (i.e., no oldData exists).
  *   - {Object} data - The new data.
  *   - {string} trigger - The event trigger.
@@ -24,8 +24,10 @@ const eventParser = async ({ oldData, newData, trigger, table, jobIdField }) =>
   let changedFieldNames = [];
 
   if (isNew) {
-    // If there's no old data, every field in newData is considered changed (new)
-    changedFields = { ...newData };
+    // If there's no old data, every field in newData is considered new
+    changedFields = Object.fromEntries(
+      Object.entries(newData).map(([key, value]) => [key, { old: undefined, new: value }])
+    );
     changedFieldNames = Object.keys(newData);
   } else {
     // Compare oldData with newData for changes
@@ -36,7 +38,10 @@ const eventParser = async ({ oldData, newData, trigger, table, jobIdField }) =>
           !Object.prototype.hasOwnProperty.call(oldData, key) ||
           JSON.stringify(oldData[key]) !== JSON.stringify(newData[key])
         ) {
-          changedFields[key] = newData[key];
+          changedFields[key] = {
+            old: oldData[key], // Could be undefined if key didn’t exist in oldData
+            new: newData[key]
+          };
           changedFieldNames.push(key);
         }
       }
@@ -44,22 +49,23 @@ const eventParser = async ({ oldData, newData, trigger, table, jobIdField }) =>
     // Check for fields that were removed
     for (const key in oldData) {
       if (Object.prototype.hasOwnProperty.call(oldData, key) && !Object.prototype.hasOwnProperty.call(newData, key)) {
-        changedFields[key] = null; // Indicate field was removed
+        changedFields[key] = {
+          old: oldData[key],
+          new: null // Indicate field was removed
+        };
         changedFieldNames.push(key);
       }
     }
   }
+
   // Extract jobId based on jobIdField
   let jobId = null;
   if (jobIdField) {
-    // If the jobIdField is provided as a string like "req.body.event.new.jobid",
-    // strip the prefix if it exists so we can use the property name.
     let keyName = jobIdField;
     const prefix = "req.body.event.new.";
     if (keyName.startsWith(prefix)) {
       keyName = keyName.slice(prefix.length);
     }
-    // Attempt to retrieve the job id from newData first; if not available, try oldData.
     jobId = newData[keyName] || (oldData && oldData[keyName]) || null;
   }