alpha

Author: SokolovskyiK

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

@@ -5,7 +5,7 @@ export default {
   key: "drift-create-contact-test",
   name: "Create Contact",
   description: "Creates a contact in Drift. [See the docs](https://devdocs.drift.com/docs/creating-a-contact).",
-  version: "0.0.10",
+  version: "0.0.11",
   type: "action",
   props: {
     drift,
@@ -26,6 +26,12 @@ export default {
       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",
@@ -39,7 +45,7 @@ export default {
     const warnings = [];
 
     const {
-      drift, email, name, phone,
+      drift, email, name, phone, source,
     } = this;
 
     warnings.push(...drift.checkIfEmailValid(email));
@@ -50,6 +56,7 @@ export default {
       email,
       name,
       phone,
+      source,
       ...customAttributes,
     });
 

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

@@ -5,7 +5,7 @@ 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 docs](https://devdocs.drift.com/docs/updating-a-contact)",
-  version: "0.0.5",
+  version: "0.0.7",
   type: "action",
   props: {
     drift,
@@ -32,6 +32,12 @@ export default {
       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",
@@ -43,7 +49,7 @@ export default {
   async run({ $ }) {
     const warnings = [];
     const {
-      drift, name, email, phone,
+      drift, name, email, phone, source,
     } = this;
 
     const customAttributes = drift.parseIfJSONString(this.customAttributes);
@@ -52,6 +58,7 @@ export default {
       name,
       phone,
       email,
+      source,
       ...customAttributes,
     });
 

components/drift/common/utils.mjs

@@ -1,28 +1,27 @@
 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 =
+  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) &&
+    isNotEmptyObject && (value = removeNullEntries(value));
+    return ((value || value === false) &&
         (isNotEmpyString || isNotEmptyArray || isNotEmptyObject || isBoolean || isNumber))
-        ? {
-          ...acc,
-          [key]: value,
-        }
-        : acc;
-    }, {});
-  
-  export {
-    removeNullEntries,
-  };
-  
+      ? {
+        ...acc,
+        [key]: value,
+      }
+      : acc;
+  }, {});
+
+export {
+  removeNullEntries,
+};

components/drift/drift.app.mjs

@@ -7,6 +7,13 @@ export default {
   propDefinitions: {},
   methods: {
     ...methods,
+    _mock$() {
+      return new Proxy({}, {
+        get() {
+          return (...args) => console.log(...args);
+        },
+      });
+    },
     _baseUrl() {
       return "https://driftapi.com";
     },
@@ -30,6 +37,16 @@ export default {
       });
     },
 
+    getNextPage($, url) {
+      return axios($, {
+        method: "GET",
+        url,
+        headers: {
+          "Authorization": `Bearer ${this.$auth?.oauth_access_token || "iHlC8LmFQiTH0DcWds7ETMRMmo3BvUyP"}`,
+        },
+      });
+    },
+
     getContactByEmail(opts) {
       return this._makeRequest({
         path: "/contacts",
@@ -111,5 +128,13 @@ export default {
 
       return response;
     },
+
+    getNewestConversations(arr, lastKnown) {
+      const firtsNew = arr.indexOf(lastKnown);
+      if (firtsNew === -1) throw new Error("Id not found");
+      const newest = arr.slice(0, firtsNew);
+      return newest.reverse();
+    },
+
   },
 };

components/drift/sources/contact-updated/new-contact-update.mjs

@@ -0,0 +1,42 @@
+import drift from "../../drift.app.mjs";
+
+export default {
+  key: "drift-new-contact-update-test",
+  name: "New Contact Update",
+  description: "Emit new event when a contact is updated in Drift. [See the docs](https://devdocs.drift.com/docs/webhook-events-1).",
+  version: "0.0.1",
+  type: "source",
+  props: {
+    drift,
+    http: "$.interface.http",
+  },
+  async run(event) {
+
+    const { body } = event;
+
+    if (body?.type !== "contact_updated") {
+      console.log("Ignored non-contact_updated event:", body?.type);
+      return;
+    }
+
+    const contactId = body.data.endUserId;
+
+    const result = await this.drift.getContactById({
+      contactId,
+    });
+
+    const email = result.data.attributes.email;
+
+    body.data.attributes =  result.data.attributes;
+
+    console.log(body);
+
+    console.log("Contact updated webhook payload:", body);
+
+    this.$emit(body, {
+      summary: `Contact "${email}" ID "${contactId}" updated`,
+      id: body.data.endUserId,
+      ts: body.timeStamp,
+    });
+  },
+};

components/drift/sources/new-conversation-instant/new-conversation-instant.mjs

@@ -1,9 +1,9 @@
 import drift from "../../drift.app.mjs";
 
 export default {
-  key: "drift-new-conversation-instant",
+  key: "drift-new-conversation-instant-test",
   name: "New Conversation",
-  description: "Emits an event every time a new conversation is started in Drift.",
+  description: "Emit new when a new conversation is started in Drift.",
   version: "0.0.2",
   type: "source",
   dedupe: "unique",
@@ -13,44 +13,97 @@ export default {
     timer: {
       type: "$.interface.timer",
       label: "Polling Interval",
-      description: "How often to poll Drift for new conversations.",
+      description: "How often to poll Drift for new conversations. [See the docs](https://devdocs.drift.com/docs/retrieve-a-conversation)",
     },
-    limit: {
-      type: "integer",
-      label: "Maximum Conversations to Fetch",
-      description: "The number of most recent conversations to retrieve each time the source runs.",
-      default: 50,
-      optional: true,
-      min: 1,
-      max: 500,
+  },
+  hooks: {
+    async activate() {
+
+      const {
+        drift,
+        db,
+      } = this;
+
+      await db.set("lastConversation", null); //reset
+
+      const result = await drift._makeRequest({
+        path: "/conversations/list?limit=100&statusId=1",
+      });
+
+      if (!result.data.length) {
+        console.log("No conversations found.");
+        return;
+      };
+
+      await db.set("lastConversation", result.data[0].id);
+      console.log(`Initialized with ID ${result.data[0].id}.`);
+
+      console.log("here");
+
     },
   },
 
   async run({ $ }) {
-    const lastTimestamp = this.db.get("lastCreatedAt") || 0;
+    const {
+      db, drift,
+    } = this;
 
-    const res = await this.drift._makeRequest({
+    const conversations = [];
+
+    const result = await drift._makeRequest({
       $,
-      path: `/conversations?limit=${this.limit}&sort=createdAt`,
+      path: "/conversations/list?limit=100&statusId=1",
     });
 
-    const conversations = res?.data || [];
+    if (!result.data.length) {
+      console.log("No conversations found.");
+      return;
+    };
+
+    const lastConversation = await db.get("lastConversation");
+
+    if (!lastConversation) {
+      await db.set("lastConversation", result.data[0].id);
+      console.log(`Initialized with ID ${result.data[0].id}.`);
+      return;
+    };
+
+    let isEnough = result.data.some((obj) => obj.id === lastConversation);
+
+    conversations.push(...result.data);
+
+    let nextUrl = result.links?.next;
+
+    while (!isEnough && nextUrl) {
+      const next = await drift.getNextPage($, nextUrl);
+      isEnough = next.data.some((obj) => obj.id === lastConversation);
+      conversations.push(...next.data);
+      nextUrl = next.links?.next;
+    };
+
+    conversations.sort((a, b) => a.id - b.id);
+
+    const lastConvIndex = conversations.findIndex((obj) => obj.id === lastConversation);
+
+    if (lastConvIndex === -1) {
+      throw new Error ("lastConversation not found in fetched data. Skipping emit.");
+    };
+
+    if (lastConvIndex + 1 === conversations.length) {
+      console.log("No new conversations found");
+    };
 
-    for (const conversation of conversations) {
-      const createdAt = conversation.createdAt || 0;
+    for (let i = lastConvIndex + 1; i < conversations.length; i++) {
 
-      if (createdAt > lastTimestamp) {
-        this.$emit(conversation, {
-          id: conversation.id,
-          summary: `New conversation with ID ${conversation.id}`,
-          ts: createdAt,
-        });
-      }
-    }
+      this.$emit(conversations[i], {
+        id: conversations[i].id,
+        summary: `New conversation with ID ${conversations[i].contactId}`,
+        ts: conversations[i].createdAt,
+      });
 
-    const newest = conversations.reduce((max, c) =>
-      Math.max(max, c.createdAt || 0), lastTimestamp);
+    };
 
-    this.db.set("lastCreatedAt", newest);
+    const lastConvId = conversations[conversations.length - 1].id;
+    await db.set("lastConversation", lastConvId);
   },
 };

components/drift/sources/new-lead-instance.mjs/new-lead-instance.mjs

@@ -0,0 +1,38 @@
+import drift from "../../drift.app.mjs";
+
+export default {
+  key: "drift-new-lead-instance-test",
+  name: "New Lead",
+  description: "Emit new event when a contact adds their email in chat.  [See the docs](https://devdocs.drift.com/docs/webhook-events-1).",
+  version: "0.0.1",
+  type: "source",
+  props: {
+    drift,
+    http: "$.interface.http",
+  },
+  async run(event) {
+
+    const { body } = event;
+
+    if (body?.type !== "contact_identified") {
+      console.log("Ignored non-contact_identified event:", body?.type);
+      return;
+    }
+
+    const contactId = body.data.endUserId;
+
+    const result = await this.drift.getContactById({
+      contactId,
+    });
+
+    const email = result.data.attributes.email;
+
+    body.data.attributes =  result.data.attributes; //inject more data
+
+    this.$emit(body, {
+      summary: `Contact "${email}" ID "${contactId}" updated`,
+      id: body.data.endUserId,
+      ts: body.timeStamp,
+    });
+  },
+};