Merge branch 'master' into issue-13445

Author: lcaresia

components/aircall/actions/create-contact/create-contact.mjs

@@ -3,36 +3,64 @@ import common from "../common/common-create-update.mjs";
 export default {
   ...common,
   name: "Create Contact",
-  description: "Create a contact in Aircall. [See the documentation](https://developer.aircall.io/api-references/#create-a-contact)",
+  description:
+    "Create a contact in Aircall. [See the documentation](https://developer.aircall.io/api-references/#create-a-contact)",
   key: "aircall-create-contact",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     ...common.props,
     emails: {
       type: "string[]",
       label: "Emails",
-      description: "Array of email address objects (max 20). Each should contain `label` and `value`. If a string is provided, it will be used as both the label and value.",
+      description:
+        "Array of email address objects (max 20). Each should contain `label` and `value`. If a string is provided, it will be used as both the label and value. For example, `{{ [{\"label\": \"Work\", \"value\": \"[email protected]\"}] }}`, or `{{ [\"[email protected]\"] }}`",
       optional: true,
     },
     phoneNumbers: {
       type: "string[]",
       label: "Phone Numbers",
-      description: "Array of phone number objects (max 20). Each should contain `label` and `value`. If a string is provided, it will be used as both the label and value.",
+      description:
+        "Array of phone number objects (max 20). Each should contain `label` and `value`. If a string is provided, it will be used as both the label and value. For example, `{{ [{\"label\": \"Work\", \"value\": \"+1 812-641-5139\"}] }}`, or `{{ [\"+1 812-641-5139\"] }}`",
     },
   },
   async run({ $ }) {
+    const refinedPhoneNumbers = (this.phoneNumbers || []).map((item) => {
+      if (typeof item === "object" && item !== null) {
+        return item;
+      }
+
+      return {
+        label: item,
+        value: item,
+      };
+    });
+    const refinedEmails = (this.emails || []).map((item) => {
+      if (typeof item === "object" && item !== null) {
+        return item;
+      }
+
+      return {
+        label: item,
+        value: item,
+      };
+    });
+
     const data = {
       ...this.getCommonData(),
-      emails: this.emails,
-      phone_numbers: this.phoneNumbers,
+      emails: refinedEmails,
+      phone_numbers: refinedPhoneNumbers,
     };
+
     const response = await this.aircall.createContact({
       $,
       data,
     });
 
-    $.export("$summary", `Successfully created contact (ID: ${response?.contact?.id})`);
+    $.export(
+      "$summary",
+      `Successfully created contact (ID: ${response?.contact?.id})`,
+    );
 
     return response;
   },

components/aircall/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/aircall",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream Aircall Components",
   "main": "aircall.app.mjs",
   "keywords": [

components/airtable_oauth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/airtable_oauth",
-  "version": "0.4.1",
+  "version": "0.4.2",
   "description": "Pipedream Airtable (OAuth) Components",
   "main": "airtable_oauth.app.mjs",
   "keywords": [

components/airtable_oauth/sources/common/common.mjs

@@ -42,5 +42,12 @@ export default {
       const formattedTimestamp = new Date(timestampMillis).toISOString();
       this._setLastTimestamp(formattedTimestamp);
     },
+    getListRecordsParams(params) {
+      return {
+        filterByFormula: `LAST_MODIFIED_TIME() > "${this._getLastTimestamp()}"`,
+        returnFieldsByFieldId: this.returnFieldsByFieldId || false,
+        ...params,
+      };
+    },
   },
 };

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

@@ -6,7 +6,7 @@ export default {
   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",
+  version: "0.0.9",
   type: "source",
   dedupe: "unique",
   props: {
@@ -53,38 +53,46 @@ export default {
     const prevAllRecordIds = this._getPrevAllRecordIds();
 
     const lastTimestamp = this._getLastTimestamp();
-    const params = {
-      filterByFormula: `LAST_MODIFIED_TIME() > "${lastTimestamp}"`,
-      returnFieldsByFieldId: this.returnFieldsByFieldId || false,
-    };
+    const params = this.getListRecordsParams();
 
     const records = await this.airtable.listRecords({
       baseId,
       tableId,
       params,
     });
 
-    let allRecordIds = [],
-      newRecordsCount = 0,
+    let newRecordsCount = 0,
       modifiedRecordsCount = 0,
       deletedRecordsCount = 0;
 
     if (records) {
       for (const record of records) {
-        if (!lastTimestamp || moment(record.createdTime) > moment(lastTimestamp)) {
-          record.type = "new_record";
+        if (!lastTimestamp || moment(record.createdTime) > moment(lastTimestamp)) {;
+          this.$emit({
+            ...record,
+            type: "new_record",
+            metadata,
+          }, {
+            id: record.id,
+            summary: `New record: ${record.id}`,
+            ts: moment(record.createdTime).valueOf(),
+          });
           newRecordsCount++;
+
         } else {
-          record.type = "record_modified";
+          const ts = Date.now();
+          const id = `${record.id}-${ts}`;
+          this.$emit({
+            ...record,
+            type: "record_modified",
+            metadata,
+          }, {
+            id,
+            summary: `Record modified: ${record.id}`,
+            ts,
+          });
           modifiedRecordsCount++;
         }
-
-        record.metadata = metadata;
-
-        this.$emit(record, {
-          summary: `${record.type}: ${JSON.stringify(record.fields)}`,
-          id: record.id,
-        });
       }
     }
 
@@ -95,26 +103,27 @@ export default {
       tableId,
       params,
     });
-    if (!data.length || data.length === 0) return;
-    allRecordIds = [
-      ...data.map((record) => record.id),
-    ];
+
+    const allRecordIds = data.map((record) => record.id);
 
     if (prevAllRecordIds) {
-      const deletedRecordIds = prevAllRecordIds.filter(
-        (prevRecord) => !allRecordIds.includes(prevRecord),
-      );
+      const currentRecordIdSet = new Set(allRecordIds);
+      const deletedRecordIds =
+        prevAllRecordIds.filter((prevRecord) => !currentRecordIdSet.has(prevRecord));
+
       for (const recordID of deletedRecordIds) {
-        deletedRecordsCount++;
-        const deletedRecordObj = {
+        const ts = Date.now();
+        const id = `${recordID}-${ts}`;
+        this.$emit({
+          id: recordID,
           metadata,
           type: "record_deleted",
-          id: recordID,
-        };
-        this.$emit(deletedRecordObj, {
+        }, {
+          id,
           summary: `Record deleted: ${recordID}`,
-          id: recordID,
+          ts,
         });
+        deletedRecordsCount++;
       }
     }
 

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

@@ -6,7 +6,7 @@ export default {
   name: "New or Modified Records in View",
   description: "Emit new event for each new or modified record in a view",
   key: "airtable_oauth-new-or-modified-records-in-view",
-  version: "0.0.9",
+  version: "0.0.10",
   type: "source",
   props: {
     ...base.props,
@@ -48,11 +48,9 @@ export default {
     } = this;
 
     const lastTimestamp = this._getLastTimestamp();
-    const params = {
+    const params = this.getListRecordsParams({
       view: viewId,
-      filterByFormula: `LAST_MODIFIED_TIME() > "${lastTimestamp}"`,
-      returnFieldsByFieldId: this.returnFieldsByFieldId || false,
-    };
+    });
 
     const records = await this.airtable.listRecords({
       baseId,
@@ -74,19 +72,31 @@ export default {
     let newRecords = 0, modifiedRecords = 0;
     for (const record of records) {
       if (!lastTimestamp || moment(record.createdTime) > moment(lastTimestamp)) {
-        record.type = "new_record";
+        this.$emit({
+          ...record,
+          type: "new_record",
+          metadata,
+        }, {
+          id: record.id,
+          summary: `New record: ${record.id}`,
+          ts: moment(record.createdTime).valueOf(),
+        });
         newRecords++;
+
       } else {
-        record.type = "record_modified";
+        const ts = Date.now();
+        const id = `${record.id}-${ts}`;
+        this.$emit({
+          ...record,
+          type: "record_modified",
+          metadata,
+        }, {
+          id,
+          summary: `Record modified: ${record.id}`,
+          ts,
+        });
         modifiedRecords++;
       }
-
-      record.metadata = metadata;
-
-      this.$emit(record, {
-        summary: `${record.type}: ${JSON.stringify(record.fields)}`,
-        id: record.id,
-      });
     }
     console.log(`Emitted ${newRecords} new records(s) and ${modifiedRecords} modified record(s).`);
 

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

@@ -6,7 +6,7 @@ export default {
   name: "New Records in View",
   description: "Emit new event for each new record in a view",
   key: "airtable_oauth-new-records-in-view",
-  version: "0.0.8",
+  version: "0.0.9",
   type: "source",
   dedupe: "unique",
   props: {
@@ -49,11 +49,10 @@ export default {
     } = this;
 
     const lastTimestamp = this._getLastTimestamp();
-    const params = {
+    const params = this.getListRecordsParams({
       view: viewId,
       filterByFormula: `CREATED_TIME() > "${lastTimestamp}"`,
-      returnFieldsByFieldId: this.returnFieldsByFieldId || false,
-    };
+    });
 
     const records = await this.airtable.listRecords({
       baseId,

components/asana/actions/add-task-to-section/add-task-to-section.mjs

@@ -5,7 +5,7 @@ export default {
   name: "Add Task To Section",
   description: "Add a task to a specific, existing section. This will remove the task from other sections of the project. [See the documentation](https://developers.asana.com/docs/add-task-to-section)",
   key: "asana-add-task-to-section",
-  version: "0.2.7",
+  version: "0.2.8",
   type: "action",
   props: {
     ...common.props,

components/asana/actions/create-project/create-project.mjs

@@ -5,7 +5,7 @@ export default {
   key: "asana-create-project",
   name: "Create Project",
   description: "Create a new project in a workspace or team. [See the documentation](https://developers.asana.com/docs/create-a-project)",
-  version: "0.10.0",
+  version: "0.10.1",
   type: "action",
   props: {
     asana,

components/asana/actions/create-subtask/create-subtask.mjs

@@ -5,7 +5,7 @@ export default {
   key: "asana-create-subtask",
   name: "Create Subtask",
   description: "Creates a new subtask and adds it to the parent task. [See the documentation](https://developers.asana.com/docs/create-a-subtask)",
-  version: "0.4.0",
+  version: "0.4.1",
   type: "action",
   props: {
     ...common.props,
@@ -105,6 +105,9 @@ export default {
       propDefinition: [
         asana,
         "tags",
+        ({ workspace }) => ({
+          workspace,
+        }),
       ],
       optional: true,
     },