Adding dedupe: unique and always including previous values

Author: GTFalcao

components/airtable_oauth/sources/common/common-webhook-field.mjs

@@ -23,16 +23,9 @@ export default {
         }),
       ],
       type: "string[]",
-      label: "Watch Schemas of Field Ids",
+      label: "Field Schemas to Watch",
       description:
         "Only emit events for updates that modify the schemas of these fields. If omitted, schemas of all fields within the table/view/base are watched",
     },
-    includePreviousFieldDefinitions: {
-      type: "boolean",
-      label: "Include Previous Field Definitions",
-      description:
-        "If true, include the previous field definition in the event payload",
-      optional: true,
-    },
   },
 };

components/airtable_oauth/sources/common/common-webhook.mjs

@@ -48,37 +48,29 @@ export default {
   },
   hooks: {
     async activate() {
-      const filters = {
-        recordChangeScope: this.viewId
-          ? this.viewId
-          : this.tableId
-            ? this.tableId
-            : undefined,
-        dataTypes: this.getDataTypes(),
-        changeTypes: this.getChangeTypes(),
-        fromSources: this.fromSources,
-        watchDataInFieldIds: this.watchDataInFieldIds,
-        watchSchemasOfFieldIds: this.watchSchemasOfFieldIds,
-      };
-
-      const includes = {
-        includeCellValuesInFieldIds: this.includeCellValuesInFieldIds,
-        includePreviousCellValues: this.includePreviousCellValues,
-        includePreviousFieldDefinitions: this.includePreviousFieldDefinitions,
-      };
-
       const { id } = await this.airtable.createWebhook({
         baseId: this.baseId,
         data: {
           notificationUrl: `${this.http.endpoint}/`,
           specification: {
             options: {
-              filters: Object.keys(filters).length
-                ? filters
-                : undefined,
-              includes: Object.keys(includes).length
-                ? includes
-                : undefined,
+              filters: {
+                recordChangeScope: this.viewId
+                  ? this.viewId
+                  : this.tableId
+                    ? this.tableId
+                    : undefined,
+                dataTypes: this.getDataTypes(),
+                changeTypes: this.getChangeTypes(),
+                fromSources: this.fromSources,
+                watchDataInFieldIds: this.watchDataInFieldIds,
+                watchSchemasOfFieldIds: this.watchSchemasOfFieldIds,
+              },
+              includes: {
+                includeCellValuesInFieldIds: this.includeCellValuesInFieldIds,
+                includePreviousCellValues: true,
+                includePreviousFieldDefinitions: true,
+              },
             },
           },
         },

components/airtable_oauth/sources/new-field/new-field.mjs

@@ -1,4 +1,4 @@
-import common from "../common/common-webhook-field.mjs";
+import common from "../common/common-webhook.mjs";
 
 export default {
   ...common,
@@ -7,12 +7,18 @@ export default {
   key: "airtable_oauth-new-field",
   version: "1.0.0",
   type: "source",
+  dedupe: "unique",
   methods: {
     ...common.methods,
     getChangeTypes() {
       return [
         "add",
       ];
     },
+    getDataTypes() {
+      return [
+        "tableFields",
+      ];
+    },
   },
 };

components/airtable_oauth/sources/new-modified-or-deleted-records/new-modified-or-deleted-records.mjs

@@ -4,10 +4,11 @@ import moment from "moment";
 export default {
   ...base,
   name: "New, Modified or Deleted Records",
+  description: "Emit new event each time a record is added, updated, or deleted in an Airtable table. Supports tables up to 10,000 records",
   key: "airtable_oauth-new-modified-or-deleted-records",
   version: "0.0.8",
   type: "source",
-  description: "Emit new event each time a record is added, updated, or deleted in an Airtable table. Supports tables up to 10,000 records",
+  dedupe: "unique",
   props: {
     ...base.props,
     tableId: {

components/airtable_oauth/sources/new-or-modified-field/new-or-modified-field.mjs

@@ -7,6 +7,7 @@ export default {
   key: "airtable_oauth-new-or-modified-field",
   version: "1.0.0",
   type: "source",
+  dedupe: "unique",
   methods: {
     ...common.methods,
     getChangeTypes() {

components/airtable_oauth/sources/new-or-modified-records-in-view/new-or-modified-records-in-view.mjs

@@ -8,6 +8,7 @@ export default {
   key: "airtable_oauth-new-or-modified-records-in-view",
   version: "0.0.8",
   type: "source",
+  dedupe: "unique",
   props: {
     ...base.props,
     tableId: {

components/airtable_oauth/sources/new-or-modified-records/new-or-modified-records.mjs

@@ -7,6 +7,7 @@ export default {
   description: "Emit new event for each new or modified record in a table or view",
   version: "1.0.0",
   type: "source",
+  dedupe: "unique",
   methods: {
     ...common.methods,
     getChangeTypes() {

components/airtable_oauth/sources/new-records-in-view/new-records-in-view.mjs

@@ -8,6 +8,7 @@ export default {
   key: "airtable_oauth-new-records-in-view",
   version: "0.0.8",
   type: "source",
+  dedupe: "unique",
   props: {
     ...base.props,
     tableId: {

components/airtable_oauth/sources/new-records/new-records.mjs

@@ -7,6 +7,7 @@ export default {
   key: "airtable_oauth-new-records",
   version: "1.0.0",
   type: "source",
+  dedupe: "unique",
   methods: {
     ...common.methods,
     getChangeTypes() {