Merge branch 'master' into 14077-tricentis-new-components

Author: GTFalcao

components/hullo/actions/add-update-member/add-update-member.mjs

@@ -0,0 +1,102 @@
+import hullo from "../../hullo.app.mjs";
+
+export default {
+  key: "hullo-add-update-member",
+  name: "Add or Update Member",
+  description: "Adds a new member or updates an existing member's data in Hullo. [See the documentation](https://app.hullo.me/docs/index.html#?route=post-/endpoints/members)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    hullo,
+    phoneNumber: {
+      propDefinition: [
+        hullo,
+        "phoneNumber",
+      ],
+    },
+    fullName: {
+      type: "string",
+      label: "Full Name",
+      description: "The full name of the member. REQUIRED if creating a new member.",
+      optional: true,
+    },
+    registrationDate: {
+      type: "string",
+      label: "Registration Date",
+      description: "The date the member was registered in ISO-8601 format. Example: `2000-01-23T04:56:07.000+00:00`",
+      optional: true,
+    },
+    groups: {
+      type: "string[]",
+      label: "Groups",
+      description: "An array containing the names of groups this member belongs to",
+      optional: true,
+    },
+    attributes: {
+      propDefinition: [
+        hullo,
+        "attributes",
+      ],
+      reloadProps: true,
+    },
+  },
+  async additionalProps() {
+    const props = {};
+    if (!this.attributes?.length) {
+      return props;
+    }
+    for (const attribute of this.attributes) {
+      props[attribute] = {
+        type: "string",
+        label: attribute,
+        description: `Value for ${attribute}`,
+      };
+    }
+    return props;
+  },
+  methods: {
+    async formatAttributes(attributeKeys, attributeValues) {
+      const attributes = await this.hullo.listAttributes();
+      const formattedAttributes = {};
+      for (const key of attributeKeys) {
+        const { type } = attributes.find(({ name }) => name === key);
+        const value = type === "NUMBER"
+          ? +attributeValues[key]
+          : type === "LIST"
+            ? JSON.parse(attributeValues[key])
+            : attributeValues[key];
+        formattedAttributes[key] = [
+          value,
+        ];
+      }
+      return formattedAttributes;
+    },
+  },
+  async run({ $ }) {
+    const {
+      hullo,
+      formatAttributes,
+      phoneNumber,
+      fullName,
+      registrationDate,
+      groups,
+      attributes,
+      ...attributeValues
+    } = this;
+
+    const response = await hullo.addOrUpdateMember({
+      $,
+      data: {
+        phoneNumber,
+        fullName,
+        registrationDate,
+        groups,
+        attributes: attributes?.length
+          ? await formatAttributes(attributes, attributeValues)
+          : undefined,
+      },
+    });
+    $.export("$summary", `Successfully added or updated member with phone number ${this.phoneNumber}`);
+    return response;
+  },
+};

components/hullo/actions/send-message/send-message.mjs

@@ -0,0 +1,34 @@
+import hullo from "../../hullo.app.mjs";
+
+export default {
+  key: "hullo-send-message",
+  name: "Send Message",
+  description: "Sends a personalized message to a Hullo member. [See the documentation](https://app.hullo.me/docs/index.html#?route=post-/endpoints/messages)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    hullo,
+    phoneNumber: {
+      propDefinition: [
+        hullo,
+        "phoneNumber",
+      ],
+    },
+    messageText: {
+      type: "string",
+      label: "Message Text",
+      description: "The message text to send. Min length: 1, Max length: 640",
+    },
+  },
+  async run({ $ }) {
+    const response = await this.hullo.sendMessage({
+      $,
+      data: {
+        phoneNumber: this.phoneNumber,
+        messageText: this.messageText,
+      },
+    });
+    $.export("$summary", `Successfully sent message to member with phone number: ${this.phoneNumber}`);
+    return response;
+  },
+};

components/hullo/hullo.app.mjs

@@ -1,11 +1,62 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "hullo",
-  propDefinitions: {},
+  propDefinitions: {
+    attributes: {
+      type: "string[]",
+      label: "Attributes",
+      description: "The attributes that describe the member",
+      optional: true,
+      async options() {
+        const attributes = await this.listAttributes();
+        return attributes?.map(({ name }) => name ) || [];
+      },
+    },
+    phoneNumber: {
+      type: "string",
+      label: "Phone Number",
+      description: "The phone number of the member",
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return "https://app.hullo.me/api/endpoints";
+    },
+    _makeRequest(opts = {}) {
+      const {
+        $ = this,
+        path,
+        ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        url: `${this._baseUrl()}${path}`,
+        headers: {
+          "X-API-KEY": `${this.$auth.api_key}`,
+        },
+      });
+    },
+    listAttributes(opts = {}) {
+      return this._makeRequest({
+        path: "/attributes",
+        ...opts,
+      });
+    },
+    sendMessage(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/messages",
+        ...opts,
+      });
+    },
+    addOrUpdateMember(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/members",
+        ...opts,
+      });
     },
   },
 };

components/hullo/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/hullo",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Hullo Components",
   "main": "hullo.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
   }
-}
+}

components/smartsuite/.gitignore

@@ -0,0 +1,66 @@
+import smartsuite from "../../smartsuite.app.mjs";
+
+export default {
+  key: "smartsuite-create-record",
+  name: "Create Record",
+  description: "Creates a new record. [See the documentation](https://developers.smartsuite.com/docs/solution-data/records/create-record)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    smartsuite,
+    tableId: {
+      propDefinition: [
+        smartsuite,
+        "tableId",
+      ],
+      reloadProps: true,
+    },
+  },
+  async additionalProps() {
+    const props = {};
+    if (!this.tableId) {
+      return props;
+    }
+    const { structure: fields } = await this.smartsuite.listFields({
+      tableId: this.tableId,
+    });
+    for (const field of fields) {
+      if (!field.params.is_auto_generated
+        && !field.params.system
+        && field.field_type !== "linkedrecordfield"
+        && field.field_type !== "filefield"
+        && field.field_type !== "userfield"
+      ) {
+        props[field.slug] = {
+          type: "string",
+          label: field.label,
+          optional: !field.params.required,
+          options: field.params.choices
+            ? field.params.choices.map(({
+              value, label,
+            }) => ({
+              value,
+              label,
+            }))
+            : undefined,
+        };
+      }
+    }
+    return props;
+  },
+  async run({ $ }) {
+    const {
+      smartsuite,
+      tableId,
+      ...data
+    } = this;
+
+    const response = await smartsuite.createRecord({
+      $,
+      tableId,
+      data,
+    });
+    $.export("$summary", `Successfully created record with ID: ${response.id}`);
+    return response;
+  },
+};

components/smartsuite/actions/create-record/create-record.mjs

@@ -0,0 +1,70 @@
+import smartsuite from "../../smartsuite.app.mjs";
+
+export default {
+  key: "smartsuite-find-records",
+  name: "Find Records",
+  description: "Search for records based on matching field(s). [See the documentation](https://developers.smartsuite.com/docs/solution-data/records/list-records)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    smartsuite,
+    tableId: {
+      propDefinition: [
+        smartsuite,
+        "tableId",
+      ],
+    },
+    fieldIds: {
+      propDefinition: [
+        smartsuite,
+        "fieldIds",
+        (c) => ({
+          tableId: c.tableId,
+        }),
+      ],
+      reloadProps: true,
+    },
+  },
+  async additionalProps() {
+    const props = {};
+    if (!this.tableId || !this.fieldIds?.length) {
+      return props;
+    }
+    const { structure: fields } = await this.smartsuite.listFields({
+      tableId: this.tableId,
+    });
+    for (const fieldId of this.fieldIds) {
+      const field = fields.find(({ slug }) => slug === fieldId);
+      props[fieldId] = {
+        type: "string",
+        label: field.label,
+      };
+    }
+    return props;
+  },
+  async run({ $ }) {
+    const fields = this.fieldIds?.length
+      ? this.fieldIds.map((field) => ({
+        comparison: "is",
+        field,
+        value: this[field],
+      }))
+      : undefined;
+    const { items } = await this.smartsuite.listRecords({
+      $,
+      tableId: this.tableId,
+      data: {
+        filter: {
+          operator: "and",
+          fields,
+        },
+      },
+    });
+    if (items?.length) {
+      $.export("$summary", `Successfully found ${items.length} record${items.length === 1
+        ? ""
+        : "s"}`);
+    }
+    return items;
+  },
+};