Improvements on Field and Record sources

Author: GTFalcao

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

@@ -18,19 +18,27 @@ export default {
         operation = changedRecord[0];
         recordObj = changedRecord[1];
       }
+
+        // for deleted record(s) we'll emit only their ids (no other info is available)
+      if (operation === 'destroyedRecordIds' && Array.isArray(recordObj)) {
+        const { length } = recordObj;
+        const summary = length === 1 ? `Record deleted: ${recordObj[0]}` : `${length} records deleted`;
+        this.$emit({
+          originalPayload: payload,
+          tableId,
+          deletedRecordIds: recordObj,
+        }, this.generateMeta(payload, summary));
+        return;
+      }
+
       const [recordId, recordUpdateInfo] = Object.entries(recordObj)[0];
 
       const timestamp = Date.parse(payload.timestamp);
       if (this.isDuplicateEvent(recordId, timestamp)) return;
       this._setLastObjectId(recordId);
       this._setLastTimestamp(timestamp);
 
-      let updateType = 'updated';
-      if (operation === "createdRecordsById") {
-        updateType = "created";
-      } else if (operation === "deletedRecordsById") {
-        updateType = "deleted";
-      }
+      let updateType = operation === "createdRecordsById" ? 'created' : 'updated';
 
       const { fields } = await this.airtable.getRecord({
         baseId: this.baseId,

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

@@ -1,11 +1,11 @@
-import common from "../common/common-webhook.mjs";
+import common from "../common/common-webhook-field.mjs";
 
 export default {
   ...common,
   name: "New Field Created (Instant)",
   description: "Emit new event when a field is created in the selected table. [See the documentation](https://airtable.com/developers/web/api/get-base-schema)",
   key: "airtable_oauth-new-field",
-  version: "1.0.0",
+  version: "1.0.{{ts}}",
   type: "source",
   dedupe: "unique",
   methods: {
@@ -15,10 +15,5 @@ export default {
         "add",
       ];
     },
-    getDataTypes() {
-      return [
-        "tableFields",
-      ];
-    },
   },
 };

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

@@ -8,7 +8,7 @@ export default {
   name: "New Record Created, Updated or Deleted (Instant)",
   description: "Emit new event when a record is added, updated, or deleted in a table or selected view.",
   key: "airtable_oauth-new-modified-or-deleted-records-instant",
-  version: "0.1.0",
+  version: "0.1.{{ts}}",
   type: "source",
   dedupe: "unique",
   props: {
@@ -19,6 +19,7 @@ export default {
       description: "Select the types of record updates that should emit events. If not specified, all updates will emit events.",
       options: constants.CHANGE_TYPES,
       optional: true,
+      default: ["add", "remove", "update"],
     },
     watchDataInFieldIds: {
       propDefinition: [

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

@@ -1,4 +1,5 @@
 import common from "../common/common-webhook-field.mjs";
+import airtable from "../../airtable_oauth.app.mjs";
 
 export default {
   ...common,