revert updated-page.mjs

Author: michelle0927

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

@@ -3,7 +3,6 @@ import sampleEmit from "./test-event.mjs";
 import base from "../common/base.mjs";
 import constants from "../common/constants.mjs";
 import zlib from "zlib";
-import { ConfigurationError } from "@pipedream/platform";
 
 export default {
   ...base,
@@ -39,32 +38,16 @@ export default {
       description: "Only emit events when one or more of the selected properties have changed",
       optional: true,
     },
-    includeChanges: {
-      type: "boolean",
-      label: "Include Changes",
-      description: "If `false`, the emitted event will not include information about the specific property changes. Must be `true` if `property types` is set. Default: `true`",
-      default: true,
-      optional: true,
-    },
     alert: {
       type: "alert",
       alertType: "warning",
-      content: "Source not saving? Your database might be too large. If deployment takes longer than one minute, an error will occur. Try removing `property types` and setting `includeChanges` to `false`.",
+      content: "Source not saving? Your database might be too large. If deployment takes longer than one minute, an error will occur.",
     },
   },
   hooks: {
     async activate() {
-      if (!this.includeChanges && this.properties?.length) {
-        throw new ConfigurationError("`includeChanges` must be `true` if `properties` are set");
-      }
-
-      this._setLastUpdatedTimestamp(Date.now());
-
-      if (!this.includeChanges) {
-        return;
-      }
-
       console.log("Activating: fetching pages and properties");
+      this._setLastUpdatedTimestamp(Date.now());
       const propertyValues = {};
       const propertiesToCheck = await this._getPropertiesToCheck();
       const params = this.lastUpdatedSortParam();
@@ -141,15 +124,14 @@ export default {
         : this._generateMeta(page, constants.summaries.PAGE_UPDATED);
       const event = {
         page,
+        changes,
       };
-      if (this.includeChanges) {
-        event.changes = changes;
-      }
       this.$emit(event, meta);
     },
   },
   async run() {
     const lastCheckedTimestamp = this._getLastUpdatedTimestamp();
+    const propertyValues = this._getPropertyValues();
 
     if (!lastCheckedTimestamp) {
       // recently updated (deactivated / activated), skip execution
@@ -167,23 +149,8 @@ export default {
       },
     };
     let newLastUpdatedTimestamp = lastCheckedTimestamp;
-    const pagesStream = this.notion.getPages(this.databaseId, params);
-
-    if (!this.includeChanges) {
-      for await (const page of pagesStream) {
-        newLastUpdatedTimestamp = Math.max(
-          newLastUpdatedTimestamp,
-          Date.parse(page.last_edited_time),
-        );
-        const isNewPage = page.last_edited_time === page.created_time;
-        this._emitEvent(page, [], isNewPage);
-      }
-      this._setLastUpdatedTimestamp(newLastUpdatedTimestamp);
-      return;
-    }
-
     const propertiesToCheck = await this._getPropertiesToCheck();
-    const propertyValues = this._getPropertyValues();
+    const pagesStream = this.notion.getPages(this.databaseId, params);
 
     for await (const page of pagesStream) {
       const changes = [];