updates

Author: michelle0927

components/esendex/actions/send-sms-message/send-sms-message.mjs

@@ -5,7 +5,7 @@ export default {
   key: "esendex-send-sms-message",
   name: "Send SMS Message",
   description: "Send an SMS message to a recipient. [See the documentation[(https://developers.esendex.com/api-reference/#messagedispatcher)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     esendex,
@@ -70,7 +70,7 @@ export default {
         ],
       },
     });
-    $.export("$summary", `Successfully sent SMSmessage to ${this.to}`);
+    $.export("$summary", `Successfully sent SMS message to ${this.to}`);
     return response;
   },
 };

components/esendex/actions/send-voice-message/send-voice-message.mjs

@@ -5,7 +5,7 @@ export default {
   key: "esendex-send-voice-message",
   name: "Send Voice Message",
   description: "Send a voice message to a recipient. [See the documentation[(https://developers.esendex.com/api-reference/#messagedispatcher)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "action",
   props: {
     esendex,

components/esendex/package.json

@@ -13,6 +13,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^3.0.3"
+    "@pipedream/platform": "^3.0.3",
+    "simple-xml2json": "^1.2.3"
   }
 }

components/esendex/sources/new-message-received/new-message-received.mjs

@@ -1,12 +1,14 @@
 import esendex from "../../esendex.app.mjs";
 import constants from "../../common/constants.mjs";
 import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+import xml2json from "simple-xml2json";
+import sampleEmit from "./test-event.mjs";
 
 export default {
   key: "esendex-new-message-received",
   name: "New Message Received",
   description: "Emit new event when a new message is received. [See the documentation[(https://developers.esendex.com/api-reference/#messageheader)",
-  version: "0.0.{{ts}}",
+  version: "0.0.1",
   type: "source",
   dedupe: "unique",
   props: {
@@ -21,7 +23,7 @@ export default {
     type: {
       type: "string",
       label: "Type",
-      description: "The type of the messages to watch for: either SMS or Voice. If no type is specified, the default is SMS.",
+      description: "The type of the messages to watch for: either SMS or Voice. If no type is specified, all types are returned.",
       options: constants.MESSAGE_TYPES,
       optional: true,
     },
@@ -35,35 +37,47 @@ export default {
   },
   methods: {
     _getLastTs() {
-      return this.$db.get("lastTs");
+      return this.db.get("lastTs");
     },
     _setLastTs(ts) {
-      this.$db.set("lastTs", ts);
+      this.db.set("lastTs", ts);
     },
     generateMeta(message) {
       return {
-        id: message.reference,
-        summary: `New Message Received: ${message.reference}`,
+        id: message.id,
+        summary: `New Message Received: ${message.id}`,
         ts: Date.parse(message.laststatusat),
       };
     },
     async processEvent(max) {
       const lastTs = this._getLastTs();
       let maxTs = lastTs;
 
-      const { messageheaders } = await this.esendex.listMessages({
+      const xmlResponse = await this.esendex.listMessages({
         params: {
           start: lastTs,
           finish: new Date().toISOString()
             .split(".")[0] + "Z", // current time
-          type: this.type,
           status: this.status,
         },
       });
 
+      const { messageheaders } = xml2json.parser(xmlResponse);
+      let messages = messageheaders?.messageheader || [];
+      if (!Array.isArray(messages)) {
+        messages = [
+          messages,
+        ];
+      }
+
+      if (!messages.length) {
+        return;
+      }
+
       let count = 0;
-      for (const message of messageheaders) {
-        if (!lastTs || Date.parse(message.laststatusat) > Date.parse(lastTs)) {
+      for (const message of messages) {
+        if ((!lastTs || Date.parse(message.laststatusat) > Date.parse(lastTs))
+          && (!this.type || message.type === this.type)) {
           const meta = this.generateMeta(message);
           this.$emit(message, meta);
           if (!maxTs || Date.parse(message.laststatusat) > Date.parse(maxTs)) {
@@ -86,4 +100,5 @@ export default {
   async run() {
     await this.processEvent();
   },
+  sampleEmit,
 };

components/esendex/sources/new-message-received/test-event.mjs

@@ -0,0 +1,29 @@
+export default {
+    "id": "7645199a-01e6-4a9f-8ce1-ae3a4ea30227",
+    "uri": "https://api.esendex.com/v1.0/messageheaders/7645199a-01e6-4a9f-8ce1-ae3a4ea30227",
+    "reference": "EX0349711",
+    "status": "Delivered",
+    "deliveredat": "2025-06-04T15:21:39.783Z",
+    "sentat": "2025-06-04T15:21:34.19Z",
+    "laststatusat": "2025-06-04T15:21:39.783Z",
+    "submittedat": "2025-06-04T15:21:33.843Z",
+    "type": "SMS",
+    "to": {
+      "phonenumber": 5555555555,
+    },
+    "from": {
+      "phonenumber": 5555555555,
+    },
+    "summary": "hello world",
+    "body": {
+      "id": "7645199a-01e6-4a9f-8ce1-ae3a4ea30227",
+      "uri": "https://api.esendex.com/v1.0/messageheaders/7645199a-01e6-4a9f-8ce1-ae3a4ea30227/body"
+    },
+    "direction": "Outbound",
+    "parts": 1,
+    "username": "",
+    "batch": {
+      "id": "3428f958-c19d-49c6-9c59-3c2f9e884713",
+      "uri": "https://api.esendex.com/v1.0/messagebatches/3428f958-c19d-49c6-9c59-3c2f9e884713"
+    }
+  }