[Components] ortto #13209

Sources
 - New Contact Created

Actions
 - Create Custom Activity
 - Opt Out SMS

Author: luancazarine

common/constants.mjs

@@ -0,0 +1 @@
+export const LIMIT = 100;

components/ortto/.gitignore

@@ -1,55 +1,51 @@
+import { parseObject } from "../../common/utils.mjs";
 import ortto from "../../ortto.app.mjs";
 
 export default {
   key: "ortto-create-custom-activity",
   name: "Create Custom Activity",
-  description: "Creates a unique activity for a user. Can optionally initialize a new record beforehand. [See the documentation](https://help.ortto.com/developer/latest/api-reference/activity/index.html)",
-  version: "0.0.{{ts}}",
+  description: "Creates a unique activity for a person. Can optionally initialize a new record beforehand. [See the documentation](https://help.ortto.com/developer/latest/api-reference/activity/index.html)",
+  version: "0.0.1",
   type: "action",
   props: {
     ortto,
-    activityName: {
+    activityId: {
       propDefinition: [
         ortto,
-        "activityName",
+        "activityId",
       ],
     },
-    recordId: {
+    attributes: {
       propDefinition: [
         ortto,
-        "recordId",
+        "attributes",
       ],
-      optional: true,
     },
-    recordType: {
+    fields: {
       propDefinition: [
         ortto,
-        "recordType",
+        "fields",
       ],
-      optional: true,
-    },
-    data: {
-      propDefinition: [
-        ortto,
-        "data",
-      ],
-      optional: true,
     },
   },
   async run({ $ }) {
-    if (this.recordType && this.data) {
-      await this.ortto.initializeOrUpdateRecord({
-        recordType: this.recordType,
-        data: this.data,
-      });
-    }
-
-    const response = await this.ortto.createUniqueActivity({
-      activityName: this.activityName,
-      recordId: this.recordId,
+    const response = await this.ortto.createCustomActivity({
+      $,
+      data: {
+        "activities": [
+          {
+            activity_id: this.activityId,
+            attributes: parseObject(this.attributes),
+            fields: parseObject(this.fields),
+          },
+        ],
+        "merge_by": [
+          "str::email",
+        ],
+      },
     });
 
-    $.export("$summary", `Successfully created activity ${response.id}`);
+    $.export("$summary", "Successfully created activity");
     return response;
   },
 };

components/ortto/actions/create-custom-activity/create-custom-activity.mjs

@@ -0,0 +1,109 @@
+import { clearObj } from "../../common/utils.mjs";
+import ortto from "../../ortto.app.mjs";
+
+export default {
+  key: "ortto-create-person",
+  name: "Create or Update a Person",
+  description: "Create or update a preexisting person in the Ortto account. [See the documentation](https://help.ortto.com/a-250-api-reference)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    ortto,
+    firstName: {
+      type: "string",
+      label: "First Name",
+      description: "The person's first name.",
+      optional: true,
+    },
+    lastName: {
+      type: "string",
+      label: "Last Name",
+      description: "The person's last name.",
+      optional: true,
+    },
+    phone: {
+      type: "string",
+      label: "Phone",
+      description: "The person's phone number.",
+    },
+    email: {
+      type: "string",
+      label: "Email",
+      description: "The person's email address.",
+    },
+    city: {
+      type: "string",
+      label: "City",
+      description: "The person's address city.",
+      optional: true,
+    },
+    country: {
+      type: "string",
+      label: "Country",
+      description: "The person's address country.",
+      optional: true,
+    },
+    region: {
+      type: "string",
+      label: "Region",
+      description: "The person's address region.",
+      optional: true,
+    },
+    birthday: {
+      type: "string",
+      label: "Birthday",
+      description: "The person's birth date.",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const {
+      ortto,
+      ...props
+    } = this;
+
+    const birthday = {};
+    if (props.birthday) {
+      const date = new Date(props.birthday);
+      birthday.day = date.getDate();
+      birthday.month = date.getMonth() + 1;
+      birthday.year = date.getFullYear();
+    }
+
+    const response = await ortto.createPerson({
+      data: {
+        people: [
+          {
+            fields: clearObj({
+              "str::first": props.firstName,
+              "str::last": props.lastName,
+              "phn::phone": {
+                "phone": props.phone,
+                "parse_with_country_code": true,
+              },
+              "str::email": props.email,
+              "geo::city": {
+                name: props.city,
+              },
+              "geo::country": {
+                name: props.country,
+              },
+              "geo::region": {
+                name: props.region,
+              },
+              "dtz::b": birthday,
+            }),
+          },
+        ],
+        async: false,
+        merge_by: [
+          "str::email",
+        ],
+        merge_strategy: 3,
+        find_strategy: 0,
+      },
+    });
+    $.export("$summary", "Person successfully initialized or updated!");
+    return response;
+  },
+};

components/ortto/actions/create-person/create-person.mjs

@@ -1,5 +1,4 @@
 import ortto from "../../ortto.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "ortto-opt-out-sms",
@@ -9,21 +8,32 @@ export default {
   type: "action",
   props: {
     ortto,
-    userId: {
+    userEmail: {
       propDefinition: [
         ortto,
-        "userId",
+        "userEmail",
       ],
     },
   },
   async run({ $ }) {
-    const response = await this.ortto.optOutSMS({
-      pathParams: {
-        userId: this.userId,
+    const response = await this.ortto.updatePerson({
+      data: {
+        people: [
+          {
+            fields: {
+              "str::email": this.userEmail,
+              "bol::sp": false,
+            },
+          },
+        ],
+        async: false,
+        merge_by: [
+          "str::email",
+        ],
       },
     });
 
-    $.export("$summary", `Successfully opted out SMS for User ID: ${this.userId}`);
+    $.export("$summary", `Successfully opted out SMS for User ID: ${this.userEmail}`);
     return response;
   },
 };

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

@@ -0,0 +1,41 @@
+export const clearObj = (obj) => {
+  return Object.entries(obj)
+    .filter(([
+      ,
+      v,
+    ]) => (v != null && v != "" && JSON.stringify(v) != "{}"))
+    .reduce((acc, [
+      k,
+      v,
+    ]) => ({
+      ...acc,
+      [k]: (!Array.isArray(v) && v === Object(v))
+        ? clearObj(v)
+        : v,
+    }), {});
+};
+
+export const parseObject = (obj) => {
+  if (!obj) return undefined;
+
+  if (Array.isArray(obj)) {
+    return obj.map((item) => {
+      if (typeof item === "string") {
+        try {
+          return JSON.parse(item);
+        } catch (e) {
+          return item;
+        }
+      }
+      return item;
+    });
+  }
+  if (typeof obj === "string") {
+    try {
+      return JSON.parse(obj);
+    } catch (e) {
+      return obj;
+    }
+  }
+  return obj;
+};