[Components] openphone #14493

Sources
 - New Call Recording Completed (Instant)
 - New Outgoing Call Completed (Instant)
 - New Incoming Call Completed (Instant)

Actions
 - Send Message
 - Create Contact
 - Update Contact

Author: luancazarine

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

@@ -1,5 +1,5 @@
+import { parseObject } from "../../common/utils.mjs";
 import openphone from "../../openphone.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "openphone-create-contact",
@@ -10,61 +10,71 @@ export default {
   props: {
     openphone,
     firstName: {
-      type: "string",
-      label: "First Name",
-      description: "The contact's first name.",
+      propDefinition: [
+        openphone,
+        "firstName",
+      ],
     },
     lastName: {
-      type: "string",
-      label: "Last Name",
-      description: "The contact's last name.",
+      propDefinition: [
+        openphone,
+        "lastName",
+      ],
       optional: true,
     },
     company: {
-      type: "string",
-      label: "Company",
-      description: "The contact's company name.",
+      propDefinition: [
+        openphone,
+        "company",
+      ],
       optional: true,
     },
     role: {
-      type: "string",
-      label: "Role",
-      description: "The contact's role.",
+      propDefinition: [
+        openphone,
+        "role",
+      ],
       optional: true,
     },
     emails: {
-      type: "string[]",
-      label: "Emails",
-      description: "Array of contact's emails.",
+      propDefinition: [
+        openphone,
+        "emails",
+      ],
       optional: true,
     },
     phoneNumbers: {
-      type: "string[]",
-      label: "Phone Numbers",
-      description: "Array of contact's phone numbers.",
+      propDefinition: [
+        openphone,
+        "phoneNumbers",
+      ],
       optional: true,
     },
     customFields: {
-      type: "string[]",
-      label: "Custom Fields",
-      description: "Array of custom fields for the contact.",
+      propDefinition: [
+        openphone,
+        "customFields",
+      ],
       optional: true,
     },
   },
   async run({ $ }) {
-    const data = {
-      firstName: this.firstName,
-      lastName: this.lastName,
-      company: this.company,
-      role: this.role,
-      emails: this.emails,
-      phoneNumbers: this.phoneNumbers,
-      customFields: this.customFields,
-    };
+    const response = await this.openphone.createContact({
+      $,
+      data: {
+        defaultFields: {
+          firstName: this.firstName,
+          lastName: this.lastName,
+          company: this.company,
+          role: this.role,
+          emails: parseObject(this.emails),
+          phoneNumbers: parseObject(this.phoneNumbers),
+        },
+        customFields: parseObject(this.customFields),
+      },
+    });
 
-    const response = await this.openphone.createContact(data);
-
-    $.export("$summary", `Successfully created contact with ID: ${response.id}`);
+    $.export("$summary", `Successfully created contact with ID: ${response.data.id}`);
     return response;
   },
 };

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

@@ -1,11 +1,11 @@
+import { ConfigurationError } from "@pipedream/platform";
 import openphone from "../../openphone.app.mjs";
-import { axios } from "@pipedream/platform";
 
 export default {
   key: "openphone-send-message",
   name: "Send a Text Message via OpenPhone",
   description: "Send a text message from your OpenPhone number to a recipient. [See the documentation](https://www.openphone.com/docs/api-reference/messages/send-a-text-message)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     openphone,
@@ -16,41 +16,42 @@ export default {
       ],
     },
     to: {
-      propDefinition: [
-        openphone,
-        "to",
-      ],
+      type: "string",
+      label: "To",
+      description: "Recipient phone number in E.164 format.",
     },
     content: {
-      propDefinition: [
-        openphone,
-        "content",
-      ],
-    },
-    userId: {
-      propDefinition: [
-        openphone,
-        "userId",
-      ],
-      optional: true,
-    },
-    setInboxStatus: {
-      propDefinition: [
-        openphone,
-        "setInboxStatus",
-      ],
-      optional: true,
+      type: "string",
+      label: "Content",
+      description: "The text content of the message to be sent.",
     },
   },
   async run({ $ }) {
-    const response = await this.openphone.sendTextMessage({
-      from: this.from,
-      to: this.to,
-      content: this.content,
-      userId: this.userId,
-      setInboxStatus: this.setInboxStatus,
-    });
-    $.export("$summary", `Successfully sent message to ${this.to}`);
-    return response;
+    try {
+      const response = await this.openphone.sendTextMessage({
+        $,
+        data: {
+          content: this.content,
+          from: this.from,
+          to: [
+            this.to,
+          ],
+          setInboxStatus: "done",
+        },
+      });
+      $.export("$summary", `Successfully sent message to ${this.to}`);
+      return response;
+
+    } catch ({ response }) {
+      let errorMessage = "";
+
+      if (response.data.errors) {
+        errorMessage = `Prop: ${response.data.errors[0].path} - ${response.data.errors[0].message}`;
+      } else {
+        errorMessage = response.data.message;
+      }
+
+      throw new ConfigurationError(errorMessage);
+    }
   },
 };

components/openphone/actions/create-update-contact/create-update-contact.mjs renamed to components/openphone/actions/update-contact/update-contact.mjs

@@ -1,18 +1,18 @@
+import { parseObject } from "../../common/utils.mjs";
 import openphone from "../../openphone.app.mjs";
 
 export default {
   key: "openphone-update-contact",
   name: "Update Contact",
   description: "Update an existing contact on OpenPhone. [See the documentation](https://www.openphone.com/docs/api-reference/contacts/update-a-contact-by-id)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     openphone,
     contactId: {
-      propDefinition: [
-        openphone,
-        "contactId",
-      ],
+      type: "string",
+      label: "Contact ID",
+      description: "The unique identifier of the contact.",
     },
     firstName: {
       propDefinition: [
@@ -65,17 +65,21 @@ export default {
     },
   },
   async run({ $ }) {
-    const data = {
-      firstName: this.firstName,
-      lastName: this.lastName,
-      company: this.company,
-      role: this.role,
-      emails: this.emails,
-      phoneNumbers: this.phoneNumbers,
-      customFields: this.customFields,
-    };
-
-    const response = await this.openphone.updateContact(this.contactId, data);
+    const response = await this.openphone.updateContact({
+      $,
+      contactId: this.contactId,
+      data: {
+        defaultFields: {
+          firstName: this.firstName,
+          lastName: this.lastName,
+          company: this.company,
+          role: this.role,
+          emails: parseObject(this.emails),
+          phoneNumbers: parseObject(this.phoneNumbers),
+        },
+        customFields: parseObject(this.customFields),
+      },
+    });
 
     $.export("$summary", `Successfully updated contact with ID ${this.contactId}`);
     return response;

components/openphone/common/utils.mjs

@@ -0,0 +1,26 @@
+export const parseObject = (obj) => {
+  if (!obj) return undefined;
+
+  let parsedObj = obj;
+  if (typeof obj === "string") {
+    try {
+      parsedObj = JSON.parse(obj);
+    } catch (e) {
+      return obj;
+    }
+  }
+
+  if (Array.isArray(parsedObj)) {
+    return parsedObj.map((item) => parseObject(item));
+  }
+  if (typeof parsedObj === "object") {
+    for (const [
+      key,
+      value,
+    ] of Object.entries(parsedObj)) {
+      parsedObj[key] = parseObject(value);
+    }
+  }
+
+  return parsedObj;
+};