[Components] Drift. Actions + Sources (#16553)

* Initial

* Save just in case

* Save just in case2

* alpha

* Test actions

* [Components] Drift. Actions + Sources

* Fix CodeRabbit

* Fix folder name

* Fix minor

* minor fix

* Major fix

* add new message source

* Update components/drift/actions/create-contact/create-contact.mjs

---------

Co-authored-by: Luan Cazarine <[email protected]>

Author: SokolovskyiK

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

@@ -0,0 +1,81 @@
+import drift from "../../drift.app.mjs";
+import { removeNullEntries } from "../../common/utils.mjs";
+
+export default {
+  key: "drift-create-contact",
+  name: "Create Contact",
+  description: "Creates a contact in Drift. [See the documentation](https://devdocs.drift.com/docs/creating-a-contact).",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    drift,
+    email: {
+      type: "string",
+      label: "Email",
+      description: "The contact's email address",
+    },
+    name: {
+      type: "string",
+      label: "Name",
+      description: "The contact's full name",
+      optional: true,
+    },
+    phone: {
+      type: "string",
+      label: "Phone",
+      description: "The contact's phone number",
+      optional: true,
+    },
+    source: {
+      type: "string",
+      label: "Lead Source",
+      description: "The value of the 'lead_create_source' custom attribute to match (case-sensitive).",
+      optional: true,
+    },
+    customAttributes: {
+      type: "object",
+      label: "Custom Attributes",
+      description: "Additional custom attributes to store on the contact",
+      optional: true,
+    },
+  },
+
+  async run({ $ }) {
+
+    const {
+      drift, email, name, phone, source,
+    } = this;
+
+    const customAttributes = drift.parseIfJSONString(this.customAttributes);
+
+    const attributes = removeNullEntries({
+      email,
+      name,
+      phone,
+      source,
+      ...customAttributes,
+    });
+
+    const existingContact = await drift.getContactByEmail({
+      $,
+      params: {
+        email,
+      },
+    });
+
+    if (existingContact && existingContact.data.length > 0) {
+      throw new Error (`Contact ${email} already exists`);
+    };
+
+    const response = await drift.createContact({
+      $,
+      data: {
+        attributes,
+      },
+    });
+
+    $.export("$summary", `Contact "${email}" has been created successfully.`);
+    return response;
+  },
+};
+

components/drift/actions/delete-contact/delete-contact.mjs

@@ -0,0 +1,41 @@
+import drift from "../../drift.app.mjs";
+
+export default {
+  key: "drift-delete-contact",
+  name: "Delete Contact",
+  description: "Deletes a contact in Drift by ID or email. [See the documentation](https://devdocs.drift.com/docs/removing-a-contact).",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    drift,
+    emailOrId: {
+      type: "string",
+      label: "Email or Id",
+      description: "The contact's email address or ID",
+    },
+  },
+
+  async run({ $ }) {
+
+    const {
+      drift, emailOrId,
+    } = this;
+
+    let contact = await drift.getContactByEmailOrId($, emailOrId);
+    contact = contact.data[0] || contact.data;
+
+    const contactId = contact.id;
+    const contactEmail = contact.attributes.email;
+
+    const response = await drift.deleteContactById({
+      $,
+      contactId,
+    });
+
+    $.export("$summary", `Contact "${contactEmail}" ID "${contactId}" 
+      has been deleted successfully.`);
+
+    return response;
+  },
+};
+

components/drift/actions/get-contact/get-contact.mjs

@@ -0,0 +1,37 @@
+import drift from "../../drift.app.mjs";
+
+export default {
+  key: "drift-get-contact",
+  name: "Get Contact",
+  description: "Retrieves a contact in Drift by ID or email. [See the documentation](https://devdocs.drift.com/docs/retrieving-contact)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    drift,
+    emailOrId: {
+      type: "string",
+      label: "Email or Id",
+      description: "The contact's email address or ID",
+    },
+  },
+
+  async run({ $ }) {
+
+    const {
+      drift, emailOrId,
+    } = this;
+
+    const response = await drift.getContactByEmailOrId($, emailOrId);
+
+    const contact = response.data[0] || response.data;
+
+    if (!contact) {
+      throw new Error("Failed to get contact");
+    };
+
+    $.export("$summary", `Contact ${contact.attributes.email} ID "${contact.id}"`
+      + " has been fetched successfully.");
+
+    return contact;
+  },
+};

components/drift/actions/update-contact/update-contact.mjs

@@ -0,0 +1,85 @@
+import drift from "../../drift.app.mjs";
+import { removeNullEntries } from "../../common/utils.mjs";
+
+export default {
+  key: "drift-update-contact",
+  name: "Update Contact",
+  description: "Updates a contact in Drift using ID or email. Only changed attributes will be updated. [See Drift API documentation](https://devdocs.drift.com/docs/updating-a-contact)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    drift,
+    emailOrId: {
+      type: "string",
+      label: "Email or ID",
+      description: "The contact’s email address or numeric ID.",
+    },
+    email: {
+      type: "string",
+      label: "Email",
+      description: "The contact’s email address",
+      optional: true,
+    },
+    name: {
+      type: "string",
+      label: "Name",
+      description: "The contact’s name.",
+      optional: true,
+    },
+    phone: {
+      type: "string",
+      label: "Phone",
+      description: "The contact’s phone number.",
+      optional: true,
+    },
+    source: {
+      type: "string",
+      label: "Lead Source",
+      description: "The value of the 'lead_create_source' custom attribute to match (case-sensitive).",
+      optional: true,
+    },
+    customAttributes: {
+      type: "object",
+      label: "Custom Attributes",
+      description: "Any custom attributes to update (e.g. company, job title, etc).",
+      optional: true,
+    },
+  },
+
+  async run({ $ }) {
+    const {
+      drift, name, email, phone, source, emailOrId,
+    } = this;
+
+    const customAttributes = drift.parseIfJSONString(this.customAttributes);
+
+    const attributes = removeNullEntries({
+      name,
+      phone,
+      email,
+      source,
+      ...customAttributes,
+    });
+
+    if (!Object.keys(attributes).length) {
+      throw new Error("No attributes provided to update.");
+    };
+
+    let contact = await drift.getContactByEmailOrId($, emailOrId);
+
+    const contactId = contact.data[0]?.id || contact.data.id;
+
+    const response = await drift.updateContact({
+      $,
+      contactId,
+      data: {
+        attributes,
+      },
+    });
+
+    $.export("$summary", `Contact ID "${contactId}" has been updated successfully.`);
+
+    return response;
+  },
+};
+

components/drift/common/utils.mjs

@@ -0,0 +1,48 @@
+const removeNullEntries = (obj) =>
+  obj && Object.entries(obj).reduce((acc, [
+    key,
+    value,
+  ]) => {
+    const isNumber = typeof value === "number";
+    const isBoolean = typeof value === "boolean";
+    const isNotEmpyString = typeof value === "string" && value.trim() !== "";
+    const isNotEmptyArray = Array.isArray(value) && value.length;
+    const isNotEmptyObject =
+        typeof value === "object" &&
+        value !== null &&
+        !Array.isArray(value) &&
+        Object.keys(value).length !== 0;
+    isNotEmptyObject && (value = removeNullEntries(value));
+    return ((value || value === false) &&
+        (isNotEmpyString || isNotEmptyArray || isNotEmptyObject || isBoolean || isNumber))
+      ? {
+        ...acc,
+        [key]: value,
+      }
+      : acc;
+  }, {});
+
+function doesContextMatch(inputContext, fetchedContext) {
+
+  if (typeof inputContext !== "object" || inputContext === null || Array.isArray(inputContext)) {
+    throw new Error ("Message context is not an object");
+  };
+
+  for (const key of Object.keys(inputContext)) {
+    if (!(key in fetchedContext)) {
+      console.log(`Invalid context field "${key}", emission skipped` );
+      return false;
+    }
+    if (fetchedContext[key] !== inputContext[key]) {
+      console.log(`Context values of "${key}" do not match, emission skipped` );
+      return false;
+    }
+  }
+  return true;
+};
+
+export {
+  removeNullEntries,
+  doesContextMatch,
+};
+