speed depandant on length

Author: wbaccinelli

niceday-broker/index.js

@@ -14,7 +14,11 @@ require('dotenv').config();
 const { THERAPIST_PASSWORD, THERAPIST_EMAIL_ADDRESS, ENVIRONMENT } = process.env;
 let { RASA_AGENT_URL } = process.env;
 RASA_AGENT_URL = (RASA_AGENT_URL === undefined) ? 'http://rasa_server:5005/webhooks/rest/webhook' : RASA_AGENT_URL;
-const MESSAGE_DELAY = 3000; // Delay in between messages in ms
+// proportional factor between the number of words in a message and the time to wait before the 
+// newt message is delivered 
+WORDS_PER_SECOND = 5
+// maximum delay between a message and the next one
+MAX_DELAY = 10
 
 const chatSdk = new Chat();
 let selectedServer;
@@ -73,22 +77,31 @@ function sleep(ms) {
  * Handle the response from rasa, send each message to the Niceday user.
  * We insert a delay in between messages, so the user has some time to read each message.
  * */
-function onRasaResponse() {
+async function onRasaResponse() {
   if (this.readyState === 4 && this.status === 200) {
     const responseJson = JSON.parse(this.responseText);
-    responseJson.forEach(async (message, i) => {
-      if (ENVIRONMENT === 'prod') {
-        await sleep(i * MESSAGE_DELAY);
-      }
-      const attachment = {
+    for (message of responseJson){
+          const attachment = {
         replyOfId: null,
         attachmentIds: [],
       };
       if ('metadata' in message) {
         attachment.attachmentIds = message.metadata;
       }
-      sendMessage(message.text, parseInt(message.recipient_id, 10), attachment);
-    });
+      
+      sendMessage(message.text, parseInt(message.recipient_id, 10), attachment)
+
+      if (ENVIRONMENT === 'prod') {
+        const delay = (message.text.split(" ").length)/WORDS_PER_SECOND;
+        
+        if (delay > MAX_DELAY) {
+          delay = MAX_DELAY;
+        }
+
+        await sleep(delay*1000);
+      }
+    }
+
   } else if (this.readyState === 4) {
     console.log('Something went wrong, status:', this.status, this.responseText);
   }