@kiina/botmaster-kommunicate - npm Package Compare versions

Comparing version 1.3.1 to 1.4.0

package.json

 {
   "name": "@kiina/botmaster-kommunicate",
-  "version": "1.3.1",
+  "version": "1.4.0",
   "description": "",
@@ -5,0 +5,0 @@ "main": "src/index.js",

src/api.js

@@ -0,1 +1,3 @@
+const BASE_URL = 'https://services.kommunicate.io';
+
 class Api {
@@ -19,3 +21,3 @@
       headers: this.__headers,
-      baseURL,
+      baseURL: BASE_URL,
       url,
@@ -22,0 +24,0 @@ method,

src/kommunicate-bot.js

@@ -73,4 +73,2 @@ const express = require('express');
         const message = this.__formatUpdate(update);
-        this.__responseEvents[message.sender.id] = new EventEmitter();
-        this.__responseEvents[message.sender.id].once("event", (data) => res.status(200).jsonp(data) );
         this.__emitUpdate(message);
@@ -86,3 +84,3 @@ }
       sender: {
-        id: message.from,
+        id: message.groupId,
       },
@@ -101,4 +99,17 @@ recipient: {
 
-  __sendMessage(message) {
-    return this.__responseEvents[message[0].recipient.id].emit("event", message);
+  async __sendMessage(messages) {
+    for (let message of messages) {
+      try {
+        const body = {
+          ...message,
+          groupId: message.sender.id,
+          fromUserName: message.recipient.id
+        };
+        if (body.metadata) body.metadata.payload = JSON.stringify(body.metadata.payload);
+        return await this.__api.request('/rest/ws/message/v2/send', 'POST', body);
+      } catch (e) {
+        console.error(e.stack);
+        return {};
+      }
+    }
   }
@@ -109,2 +120,3 @@
       .values(outgoingMessages)
+      .filter(message => message.message)
       .map(message => {
@@ -217,3 +229,3 @@ let response = { ...message };
   __createStandardBodyResponseComponents(sentOutgoingMessage, sentRawMessage, rawBody) {
-    return Promise.resolve(rawBody);
+    return Promise.resolve({ recipient_id: sentRawMessage[0].recipient.id, message_id: Date.now() });
   }
@@ -220,0 +232,0 @@

No alert changes

Improved metrics

Total package byte prevSize

7645

increased by5.06%

Lines of code

230

increased by5.99%

No dependency changes