handle singleCollaborator field type

Author: michelle0927

components/airtable_oauth/actions/create-or-update-record/create-or-update-record.mjs

@@ -6,7 +6,7 @@ export default {
   key: "airtable_oauth-create-or-update-record",
   name: "Create or Update Record",
   description: "Create a new record or update an existing one. [See the documentation](https://airtable.com/developers/web/api/create-records)",
-  version: "0.1.1",
+  version: "0.1.2",
   type: "action",
   props: {
     ...common.props,

components/airtable_oauth/actions/create-single-record/create-single-record.mjs

@@ -6,7 +6,7 @@ export default {
   key: "airtable_oauth-create-single-record",
   name: "Create Single Record",
   description: "Adds a record to a table.",
-  version: "0.0.10",
+  version: "0.0.11",
   type: "action",
   props: {
     ...common.props,

components/airtable_oauth/actions/get-record-or-create/get-record-or-create.mjs

@@ -6,7 +6,7 @@ export default {
   key: "airtable_oauth-get-record-or-create",
   name: "Get Record Or Create",
   description: "Get a specific record, or create one if it doesn't exist. [See the documentation](https://airtable.com/developers/web/api/create-records)",
-  version: "0.0.10",
+  version: "0.0.12",
   type: "action",
   props: {
     ...common.props,

components/airtable_oauth/actions/get-record/get-record.mjs

@@ -6,7 +6,7 @@ export default {
   key: "airtable_oauth-get-record",
   name: "Get Record",
   description: "Get data of a selected record from a table. [See the documentation](https://airtable.com/developers/web/api/get-record)",
-  version: "0.0.10",
+  version: "0.0.11",
   type: "action",
   props: {
     ...common.props,

components/airtable_oauth/actions/search-records/search-records.mjs

@@ -5,7 +5,7 @@ export default {
   key: "airtable_oauth-search-records",
   name: "Search Records",
   description: "Search for a record by formula or by field value. [See the documentation](https://airtable.com/developers/web/api/list-records)",
-  version: "0.0.11",
+  version: "0.0.12",
   type: "action",
   props: {
     ...common.props,

components/airtable_oauth/actions/update-record/update-record.mjs

@@ -6,7 +6,7 @@ export default {
   key: "airtable_oauth-update-record",
   name: "Update Record",
   description: "Update a single record in a table by Record ID. [See the documentation](https://airtable.com/developers/web/api/update-record)",
-  version: "0.0.10",
+  version: "0.0.11",
   type: "action",
   props: {
     ...common.props,

components/airtable_oauth/common/actions.mjs

@@ -33,7 +33,7 @@ export default {
     const baseId = ctx.baseId?.value ?? ctx.baseId;
     const tableId = ctx.tableId?.value ?? ctx.tableId;
 
-    const record = ctx.record ?? makeRecord(ctx);
+    const record = ctx.record ?? await makeRecord(ctx);
 
     ctx.airtable.validateRecord(record);
 
@@ -61,7 +61,7 @@ export default {
     const recordId = ctx.recordId;
 
     ctx.airtable.validateRecordID(recordId);
-    const record = ctx.record ?? makeRecord(ctx);
+    const record = ctx.record ?? await makeRecord(ctx);
 
     let response;
     try {

components/airtable_oauth/common/utils.mjs

@@ -121,17 +121,48 @@ function makeFieldProps(tableSchema) {
  * @param {object} props - A component's props
  * @returns {object} a record
  */
-function makeRecord(props) {
+async function makeRecord(ctx) {
   let record = {};
-  for (const key of Object.keys(props)) {
+  const fieldTypes = await mapFieldTypes(ctx);
+  for (const key of Object.keys(ctx)) {
     if (key.startsWith(FIELD_PREFIX)) {
       const fieldName = key.slice(FIELD_PREFIX.length);
-      record[fieldName] = props[key];
+      if (fieldTypes[fieldName] === FieldType.SINGLE_COLLABORATOR) {
+        record[fieldName] = buildSingleCollaboratorField(ctx[key]);
+        continue;
+      }
+      record[fieldName] = ctx[key];
     }
   }
   return record;
 }
 
+async function mapFieldTypes(ctx) {
+  const baseId = ctx.baseId?.value ?? ctx.baseId;
+  const tableId = ctx.tableId?.value ?? ctx.tableId;
+  const { tables } = await ctx.airtable.listTables({
+    baseId,
+  });
+  const tableSchema = tables.find(({ id }) => id === tableId);
+  const fieldTypes = {};
+  for (const field of tableSchema?.fields ?? []) {
+    fieldTypes[field.name] = field.type;
+  }
+  return fieldTypes;
+}
+
+const isEmail = (str) => /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(str);
+
+function buildSingleCollaboratorField(value) {
+  return isEmail(value)
+    ? {
+      email: value,
+    }
+    : {
+      id: value,
+    };
+}
+
 export {
   fieldTypeToPropType,
   fieldToProp,

components/airtable_oauth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/airtable_oauth",
-  "version": "0.4.3",
+  "version": "0.4.4",
   "description": "Pipedream Airtable (OAuth) Components",
   "main": "airtable_oauth.app.mjs",
   "keywords": [
@@ -13,7 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.6.0",
+    "@pipedream/platform": "^3.0.3",
     "airtable": "^0.11.1",
     "bottleneck": "^2.19.5",
     "lodash.chunk": "^4.2.0",