0.2.9 - added /:appid/:userid/archived_conversations/:conversWith endpoint

Author: sponzillo

CHANGELOG.md

@@ -1,4 +1,7 @@
 
+## v0.2.9
+- added /:appid/:userid/archived_conversations/:conversWith endpoint
+
 ## v0.2.8
 - chat21Api.joinGroupMessages(): forced message.status = 150 in history messages after a join
 

chatdb/index.js

@@ -146,9 +146,9 @@ class ChatDB {
     });
   }
 
-  conversationDetail(appid, userid, conversWith, callback) {
+  conversationDetail(appid, userid, conversWith, archived, callback) {
     winston.info("DB. app: "+ appid+ " user: " + userid + " conversWith: "+ conversWith);
-    this.db.collection(this.conversations_collection).find( { timelineOf: userid, app_id: appid, conversWith: conversWith } ).limit(1).toArray(function(err, docs) {
+    this.db.collection(this.conversations_collection).find( { timelineOf: userid, app_id: appid, conversWith: conversWith, archived: archived } ).limit(1).toArray(function(err, docs) {
       if (err) {
         if (callback) {
           callback(err, null)

index.js

@@ -172,7 +172,7 @@ app.get(BASEURL + "/:appid/:userid/conversations/:conversWith", (req, res) => {
   if (!authorize(req, res)) {
     return
   }
-  conversationDetail(req, function(err, docs) {
+  conversationDetail(req, false, function(err, docs) {
     if (err) {
       const reply = {
           success: false,
@@ -190,12 +190,35 @@ app.get(BASEURL + "/:appid/:userid/conversations/:conversWith", (req, res) => {
   })
 })
 
-function conversationDetail(req, callback) {
+app.get(BASEURL + "/:appid/:userid/archived_conversations/:conversWith", (req, res) => {
+  logger.debug("HTTP: GET /:appid/:userid/conversations/:conversWith");
+  if (!authorize(req, res)) {
+    return
+  }
+  conversationDetail(req, true, function(err, docs) {
+    if (err) {
+      const reply = {
+          success: false,
+          err: err.message()
+      }
+      res.status(501).send(reply)
+    }
+    else {
+      const reply = {
+        success: true,
+        result: docs
+      }
+      res.status(200).json(reply)
+    }
+  })
+})
+
+function conversationDetail(req, archived, callback) {
   // logger.debug("getting /:appid/:userid/archived_conversations")
   const appid = req.params.appid
   const userid = req.params.userid
   const conversWith = req.params.conversWith
-  chatdb.conversationDetail(appid, userid, conversWith, function(err, docs) {
+  chatdb.conversationDetail(appid, userid, conversWith, archived, function(err, docs) {
     callback(err, docs);
   });
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@chat21/chat21-http-server",
-  "version": "0.2.8",
+  "version": "0.2.9",
   "description": "Chat21 HTTP APIs",
   "main": "index.js",
   "dependencies": {