[Notion] emit original page, not modified

components/notion/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/notion",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "description": "Pipedream Notion Components",
   "main": "notion.app.mjs",
   "keywords": [

components/notion/sources/updated-page/updated-page.mjs

@@ -9,7 +9,7 @@ export default {
   key: "notion-updated-page",
   name: "Updated Page in Database", /* eslint-disable-line pipedream/source-name */
   description: "Emit new event when a page in a database is updated. To select a specific page, use `Updated Page ID` instead",
-  version: "0.1.1",
+  version: "0.1.2",
   type: "source",
   dedupe: "unique",
   props: {
@@ -91,11 +91,13 @@ export default {
       // Files & Media type:
       // `url` and `expiry_time` are constantly updated by Notion, so ignore these fields
       if (property.type === "files") {
-        for (const file of property.files) {
+        const modified = structuredClone(property);
+        for (const file of modified.files) {
           if (file.type === "file") {
             delete file.file;
           }
         }
+        return modified;
       }
       return property;
     },
@@ -153,34 +155,38 @@ export default {
 
       for (const propertyName of propertiesToCheck) {
         const previousValue = structuredClone(propertyValues[page.id]?.[propertyName]);
-        const currentValue = this.maybeRemoveFileSubItems(page.properties[propertyName]);
+        // value used to compare and to save to this.db
+        const currentValueToSave = this.maybeRemoveFileSubItems(page.properties[propertyName]);
+        // (unmodified) value that should be emitted
+        const currentValueToEmit = page.properties[propertyName];
 
         const pageExistsInDB = propertyValues[page.id] != null;
-        const propertyChanged = JSON.stringify(previousValue) !== JSON.stringify(currentValue);
+        const propertyChanged =
+          JSON.stringify(previousValue) !== JSON.stringify(currentValueToSave);
 
         if (pageExistsInDB && propertyChanged) {
           propertyHasChanged = true;
           propertyValues[page.id] = {
             ...propertyValues[page.id],
-            [propertyName]: currentValue,
+            [propertyName]: currentValueToSave,
           };
           changes.push({
             property: propertyName,
             previousValue,
-            currentValue,
+            currentValue: currentValueToEmit,
           });
         }
 
         if (!pageExistsInDB) {
           isNewPage = true;
           propertyHasChanged = true;
           propertyValues[page.id] = {
-            [propertyName]: currentValue,
+            [propertyName]: currentValueToSave,
           };
           changes.push({
             property: propertyName,
             previousValue,
-            currentValue,
+            currentValue: currentValueToEmit,
           });
         }
       }