Save just in case2

Author: SokolovskyiK

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

@@ -1,11 +1,11 @@
 import drift from "../../drift.app.mjs";
 import { removeNullEntries } from "../../common/utils.mjs";
 
-export default  {
+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.4",
+  version: "0.0.10",
   type: "action",
   props: {
     drift,
@@ -64,21 +64,16 @@ export default  {
       throw new Error (`Contact ${email} already exists`);
     };
 
-    let response;
+    const response = await drift.createContact({
+      $,
+      data: {
+        attributes,
+      },
+    });
 
-    try {
-      response = await drift.createContact({
-        $,
-        data: {
-          attributes,
-        },
-      });
-    } catch (error) {
-      drift.throwCustomError("Unable to create new contact", error, warnings);
-    }
+    console.log(response.data.id);
 
-    $.export("$summary", `Contact "${email}" created with ID "${response.data.id}".`
-        + "\n- "  + warnings.join("\n- "));
+    $.export("$summary", `Contact ${email} created.` + "\n- "  + warnings.join("\n- "));
     return response;
   },
 };

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

@@ -4,7 +4,7 @@ export default {
   key: "drift-delete-contact-test",
   name: "Delete Contact",
   description: "Deletes a contact in Drift by ID or email. [See the docs](https://devdocs.drift.com/docs/removing-a-contact).",
-  version: "0.0.10",
+  version: "0.0.12",
   type: "action",
   props: {
     drift,
@@ -25,54 +25,18 @@ export default {
 
     warnings.push(...drift.checkEmailOrId(emailOrId));
 
-    let contactId;
-    let email;
+    let contact = await drift.getContactByEmailOrId($, emailOrId);
+    contact = contact.data[0] || contact.data;
 
-    if (drift.isIdNumber(Number(emailOrId))) {
-
-      contactId = Number(emailOrId);
-      // Drift's response always returns 204 (No Content) on both successful and failed deletions.
-      // So fetch the contact first and throw early if it is not found.
-      try {
-        await drift.getContactById({
-          $,
-          contactId,
-        });
-      } catch (error) {
-        if (error.status === 404) {
-          throw new Error(`No contact found with ID: ${contactId}`);
-        } else {
-          throw error;
-        };
-      }
-
-    } else {
-      email = emailOrId;
-      // returns { data: [] } if not found.
-      const response = await drift.getContactByEmail({
-        $,
-        params: {
-          email,
-        },
-      });
-      if (!response?.data?.length) {
-        throw new Error(`No contact found with email: ${email}` +
-              "\n- "  + warnings.join("\n- "));
-      };
-
-      contactId = response.data[0].id;
-    };
+    const contactId = contact.id;
+    const contactEmail = contact.email;
 
     const response = await drift.deleteContactById({
       $,
       contactId,
     });
 
-    email = (email)
-      ? "\"" + email + "\""
-      : "";
-
-    $.export("$summary", `Contact ${email} ID "${contactId}" deleted successfully.`);
+    $.export("$summary", `Contact ${contactEmail} ID "${contactId}" deleted successfully.`);
 
     return response;
   },

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

@@ -1,10 +1,10 @@
 import drift from "../../drift.app.mjs";
 
-export default  {
-  key: "drift-get-contact-test",
-  name: "Delete Contact",
-  description: "Deletes a contact in Drift by ID or email. [See the docs](https://devdocs.drift.com/docs/retrieving-contact).",
-  version: "0.0.3",
+export default {
+  key: "drift-delete-contact-test",
+  name: "Get Contact",
+  description: "Retrieves a contact in Drift by ID or email. [See the docs](https://devdocs.drift.com/docs/retrieving-contact)",
+  version: "0.0.14",
   type: "action",
   props: {
     drift,
@@ -25,43 +25,9 @@ export default  {
 
     warnings.push(...drift.checkEmailOrId(emailOrId));
 
-    let contact;
+    const response = await drift.getContactByEmailOrId($, emailOrId);
 
-    if (drift.isIdNumber(Number(emailOrId))) {
-
-      const contactId = Number(emailOrId);
-
-      let response;
-      try {
-        response = await drift.getContactById({
-          $,
-          contactId,
-        });
-      } catch (error) {
-        if (error.status === 404) {
-          throw new Error(`No contact found with ID: ${contactId}`);
-        } else {
-          throw error;
-        };
-      }
-
-      contact = response.data;
-
-    } else {
-      const email = emailOrId;
-      const response = await drift.getContactByEmail({
-        $,
-        params: {
-          email,
-        },
-      });
-      if (!response?.data?.length) {
-        throw new Error(`No contact found with email: ${email}` +
-              "\n- "  + warnings.join("\n- "));
-      };
-
-      contact = response.data[0];
-    };
+    const contact = response.data[0] || response.data;
 
     console.log(contact);
 
@@ -71,4 +37,3 @@ export default  {
     return contact;
   },
 };
-

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

@@ -1,10 +1,11 @@
 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 docs](https://devdocs.drift.com/docs/updating-a-contact)",
-  version: "0.0.2",
+  version: "0.0.5",
   type: "action",
   props: {
     drift,
@@ -15,8 +16,8 @@ export default {
     },
     email: {
       type: "string",
-      label: "New Email",
-      description: "The new email address to assign to this contact.",
+      label: "Email",
+      description: "The contact’s email address",
       optional: true,
     },
     name: {
@@ -41,77 +42,42 @@ export default {
 
   async run({ $ }) {
     const warnings = [];
-    const { drift } = this;
-    const emailOrId = drift.trimIfString(this.emailOrId);
-    warnings.push(...drift.checkEmailOrId(emailOrId));
+    const {
+      drift, name, email, phone,
+    } = this;
 
-    let contactId;
+    const customAttributes = drift.parseIfJSONString(this.customAttributes);
 
-    // Resolve contact by ID or email
-    if (drift.isIdNumber(Number(emailOrId))) {
-      contactId = Number(emailOrId);
-      try {
-        await drift.getContactById({
-          $,
-          contactId,
-        }); // validate
-      } catch (error) {
-        if (error.status === 404) {
-          throw new Error(`No contact found with ID: ${contactId}`);
-        } else {
-          throw error;
-        }
-      }
-    } else {
-      const response = await drift.getContactByEmail({
-        $,
-        params: {
-          email: emailOrId,
-        },
-      });
-      if (!response?.data?.length) {
-        throw new Error(`No contact found with email: ${emailOrId}` +
-          "\n- " + warnings.join("\n- "));
-      }
-      contactId = response.data[0].id;
-    }
-
-    // Safely merge attributes
-    const attributes = {
-      ...(this.email && {
-        email: this.email,
-      }),
-      ...(this.name && {
-        name: this.name,
-      }),
-      ...(this.phone && {
-        phone: this.phone,
-      }),
-      ...this.customAttributes,
-    };
-
-    // Remove conflicts where top-level fields exist in customAttributes
-    [
-      "email",
-      "name",
-      "phone",
-    ].forEach((key) => {
-      if (this.customAttributes?.[key]) {
-        warnings.push(`Warning: Custom attribute "${key}" is ignored because it’s already handled as a top-level prop.`);
-        delete attributes[key];
-      }
+    const attributes = removeNullEntries({
+      name,
+      phone,
+      email,
+      ...customAttributes,
     });
 
     if (!Object.keys(attributes).length) {
       throw new Error("No attributes provided to update.");
-    }
+    };
 
-    const response = await drift.updateContactById(contactId, {
+    const emailOrId = drift.trimIfString(this.emailOrId);
+
+    warnings.push(...drift.checkEmailOrId(emailOrId));
+    warnings.push(...drift.checkIfEmailValid(emailOrId));
+
+    let contact = await drift.getContactByEmailOrId($, emailOrId);
+
+    const contactId = contact.data[0]?.id || contact.data.id;
+
+    const response = await drift.updateContact({
       $,
-      attributes,
+      contactId,
+      data: {
+        attributes,
+      },
     });
 
     $.export("$summary", `Contact ID ${contactId} updated successfully.`);
     return response;
   },
 };
+

components/drift/package.json

@@ -13,6 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^3.0.0"
+    "@pipedream/platform": "^3.0.0",
+    "node-persist": "^4.0.4"
   }
 }

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

@@ -0,0 +1,56 @@
+import drift from "../../drift.app.mjs";
+
+export default {
+  key: "drift-new-conversation-instant",
+  name: "New Conversation",
+  description: "Emits an event every time a new conversation is started in Drift.",
+  version: "0.0.2",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    drift,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      label: "Polling Interval",
+      description: "How often to poll Drift for new conversations.",
+    },
+    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,
+    },
+  },
+
+  async run({ $ }) {
+    const lastTimestamp = this.db.get("lastCreatedAt") || 0;
+
+    const res = await this.drift._makeRequest({
+      $,
+      path: `/conversations?limit=${this.limit}&sort=createdAt`,
+    });
+
+    const conversations = res?.data || [];
+
+    for (const conversation of conversations) {
+      const createdAt = conversation.createdAt || 0;
+
+      if (createdAt > lastTimestamp) {
+        this.$emit(conversation, {
+          id: conversation.id,
+          summary: `New conversation with ID ${conversation.id}`,
+          ts: createdAt,
+        });
+      }
+    }
+
+    const newest = conversations.reduce((max, c) =>
+      Math.max(max, c.createdAt || 0), lastTimestamp);
+
+    this.db.set("lastCreatedAt", newest);
+  },
+};

components/drift/tests/dev-db/2c26b46b68ffc68ff99b453c1d30413413422d706483bfa0f98a5e886266e7ae

@@ -0,0 +1 @@
+{"key":"lastCreatedAt","value":1746293843698}