Applying comon behavior to 'new field'

Author: GTFalcao

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

@@ -10,22 +10,46 @@ export default {
         "tableFields",
       ];
     },
-  },
-  props: {
-    ...common.props,
-    watchSchemasOfFieldIds: {
-      propDefinition: [
-        airtable,
-        "sortFieldId",
-        (c) => ({
-          baseId: c.baseId,
-          tableId: c.tableId,
-        }),
-      ],
-      type: "string[]",
-      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",
+    async saveAdditionalData() {
+      const tableData = await this.airtable.listTables({ baseId: this.baseId });
+      const filteredData = tableData?.tables?.map(({ id, name, fields}) => ({
+        id,
+        name,
+        fields,
+      }));
+      if (filteredData?.length) {
+        this.db.set("tableSchemas", filteredData);
+      }
+    },
+    async emitEvent(payload) {
+      const [tableId, tableData] = Object.entries(payload.changedTablesById)[0];
+      const [operation, fieldObj] = Object.entries(tableData)[0];
+      const [fieldId, fieldUpdateInfo] = Object.entries(fieldObj)[0];
+
+      const updateType = operation === "createdFieldsById" ? "created" : "updated";
+
+      let table = {
+        id: tableId,
+      }
+      let field = {
+        id: fieldId,
+      }
+
+      const tableSchemas = this.db.get("tableSchemas");
+      if (tableSchemas) {
+        table = tableSchemas.find(({ id }) => id === tableId)
+        field = table?.fields.find(({ id }) => id === fieldId);
+        delete table.fields;
+      }
+
+      const summary = `Field ${updateType}: ${field.name ?? fieldUpdateInfo?.name ?? field.id}`
+
+      this.$emit({
+        originalPayload: payload,
+        table,
+        field,
+        fieldUpdateInfo,
+      }, this.generateMeta(payload, summary));
     },
   },
 };

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

@@ -114,8 +114,13 @@ export default {
       const meta = this.generateMeta(payload);
       this.$emit(payload, meta);
     },
+    emitEvent(payload) {
+      // sources may call this to customize event emission, but it is
+      // a separate method so that the source may fall back to default
+      this.emitDefaultEvent(payload);
+    },
     async saveAdditionalData() {
-      // some sources may call this to fetch additional data (e.g. field schemas)
+      // sources may call this to fetch additional data (e.g. field schemas)
       // and it can be silently ignored when not required
       return true;
     }

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

@@ -16,46 +16,22 @@ export default {
         "update",
       ];
     },
-    async saveAdditionalData() {
-      const tableData = await this.airtable.listTables({ baseId: this.baseId });
-      const filteredData = tableData?.tables?.map(({ id, name, fields}) => ({
-        id,
-        name,
-        fields,
-      }));
-      if (filteredData?.length) {
-        this.db.set("tableSchemas", filteredData);
-      }
-    },
-    async emitEvent(payload) {
-      const [tableId, tableData] = Object.entries(payload.changedTablesById)[0];
-      const [operation, fieldObj] = Object.entries(tableData)[0];
-      const [fieldId, fieldUpdateInfo] = Object.entries(fieldObj)[0];
-
-      const updateType = operation === "createdFieldsById" ? "created" : "updated";
-
-      let table = {
-        id: tableId,
-      }
-      let field = {
-        id: fieldId,
-      }
-
-      const tableSchemas = this.db.get("tableSchemas");
-      if (tableSchemas) {
-        table = tableSchemas.find(({ id }) => id === tableId)
-        field = table?.fields.find(({ id }) => id === fieldId);
-        delete table.fields;
-      }
-
-      const summary = `Field ${updateType}: ${field.name ?? fieldUpdateInfo?.name ?? field.id}`
-
-      this.$emit({
-        originalPayload: payload,
-        table,
-        field,
-        fieldUpdateInfo,
-      }, this.generateMeta(payload, summary));
-    }
   },
+  props: {
+    ...common.props,
+    watchSchemasOfFieldIds: {
+      propDefinition: [
+        airtable,
+        "sortFieldId",
+        (c) => ({
+          baseId: c.baseId,
+          tableId: c.tableId,
+        }),
+      ],
+      type: "string[]",
+      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",
+    },
+  }
 };