removed check on attributes.updateconversation == false. Now conversa…

…tions are always updated
chat21 · Nov 6, 2022 · 91b0b20 · 91b0b20
1 parent 43e314b
commit 91b0b20
Show file tree

Hide file tree

Showing 5 changed files with 16 additions and 10 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,6 +4,9 @@
 available on:
  ▶️ https://www.npmjs.com/package/@chat21/chat21-server
 
+## v0.2.26 - online
+- removed if (savedMessage.attributes && savedMessage.attributes.updateconversation == false) {update_conversation = false}. Now conversations are always updated. Same modification also on chat21client.js
+
 ## v0.2.25 - online
 - all negative acks removed. All callback(false) => callback(true) to avoid queue blocks
 - minor fixes

diff --git a/mqttclient/CHANGELOG.md b/mqttclient/CHANGELOG.md
@@ -1,5 +1,8 @@
 Chat21Client.js CHANGELOG
 
+### v0.1.12.2
+- - removed if (savedMessage.attributes && savedMessage.attributes.updateconversation == false) {update_conversation = false}. Now conversations are always updated. Same modification also on observer.js
+
 ### v0.1.12.1
 - some console.log() hidden
 

diff --git a/mqttclient/chat21client.js b/mqttclient/chat21client.js
@@ -1,7 +1,7 @@
 /*
     Chat21Client
 
-    v0.1.12.1
+    v0.1.12.2
 
     @Author Andrea Sponziello
     (c) Tiledesk 2020
@@ -630,12 +630,11 @@ class Chat21Client {
                         // Observing conversations added from messages
                         // console.log("Observing conversations added from messages", message_json);
                         // if (this.onConversationAddedCallbacks) {
-                        // console.log("callbacks ok........");
                         let update_conversation = true;
-                        if (message_json.attributes && message_json.attributes.updateconversation == false) {
-                            update_conversation = false
-                        }
-                        // console.log("update_conversation........", update_conversation);
+                        // temporarily ignoring the updateconversation = false option
+                        // if (message_json.attributes && message_json.attributes.updateconversation == false) {
+                        //     update_conversation = false
+                        // }
                         if (update_conversation && this.onConversationAddedCallbacks) {
                             this.onConversationAddedCallbacks.forEach((callback, handler, map) => {
                                 message_json.is_new = true;

diff --git a/observer.js b/observer.js
@@ -663,9 +663,10 @@ function process_persist(topic, message_string, callback) {
   savedMessage.conversWith = convers_with
 
   let update_conversation = true
-  if (savedMessage.attributes && savedMessage.attributes.updateconversation == false) {
-    update_conversation = false
-  }
+  // temporarily ignoring the updateconversation = false option
+  // if (savedMessage.attributes && savedMessage.attributes.updateconversation == false) {
+  //   update_conversation = false
+  // }
   // logger.debug("updateconversation = " + update_conversation)
   chatdb.saveOrUpdateMessage(savedMessage, function(err, msg) {
     // logger.debug("Message saved", savedMessage)

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@chat21/chat21-server",
-  "version": "0.2.25",
+  "version": "0.2.26",
   "description": "Chat21 AMQP/MQTT messages dispatcher",
   "dependencies": {
     "aedes": "^0.40.1",