- Additional support for chats

Author: paschmann

server/routes/rasa_router.js

@@ -251,14 +251,20 @@ function conversationParseRequest(req, res, next) {
               server_response: body,
               query: req.body.q
             });
-          //Update conversation table with updated conversation response from rasa ...
-          db.run('update conversations set conversation = ? where conversation_id = ?', [body, req.body.conversation_id], function(err) {
-            if (err) {
-              logger.winston.error("Error updating the record");
-            } else {
-              sendOutput(200, res, body);
-            }
-          });
+            //Maybe we should run this before the DB update and save both to the DB at the same time and then return both responses to the client
+            request({ method: 'POST', uri: global.rasa_endpoint + "/conversations/" + req.body.conversation_id + "/predict", body: JSON.stringify(req.body) },
+            function (err, response, predict_body) {
+              //console.log(body);
+              //Update conversation table with updated conversation response from rasa ...
+              db.run('update conversations set conversation = ? where conversation_id = ?', [predict_body, req.body.conversation_id], function(err) {
+                if (err) {
+                  logger.winston.error("Error updating the record");
+                } else {
+                  
+                  sendOutput(200, res, predict_body);
+                }
+              });
+            });
         } catch (err) {
           logger.winston.error(err);
           sendOutput(500, res, '{"error" : ' + err + "}");
@@ -290,6 +296,7 @@ function restartRasaCoreConversation(req, res, next) {
         if (err) {
           logger.winston.error("Error updating the record");
         } else {
+          //Predict the next action?
           sendOutput(200, res, body);
         }
       });

web/src/app/components/chat/chat.js

@@ -50,8 +50,8 @@ function ChatController($scope, $rootScope, $interval, $http, Rasa_Version, Sett
       $scope.selected_conversation = selected_conversation;
       if (selected_conversation.conversation) {
         var conversation = JSON.parse(selected_conversation.conversation);
-        if (conversation && conversation.events) {
-          $scope.transactions = conversation.events;
+        if (conversation && conversation.tracker.events) {
+          $scope.transactions = conversation.tracker.events;
         }
         $scope.loadConversationStory(selected_conversation.conversation_id);
       }
@@ -85,9 +85,9 @@ function ChatController($scope, $rootScope, $interval, $http, Rasa_Version, Sett
       $scope.test_text = "";
       $('.write_msg').focus();
       $http.post(appConfig.api_endpoint_v2 + '/rasa/conversations/messages', JSON.stringify(reqMessage)).then(function (response) {
-        if (response.data && response.data.events) {
+        if (response.data && response.data.tracker) {
           $scope.selected_conversation.conversation = JSON.stringify(response.data);
-          $scope.transactions = response.data.events;
+          $scope.transactions = response.data.tracker.events;
           $scope.loadConversationStory($scope.selected_conversation.conversation_id);
           scrollToMessage();
         }