Merge fd50422 into 01d73e2

Author: Tadayoshi123

src/controllers/conversation.controller.js

@@ -23,19 +23,16 @@ exports.getAllConversation = (req, res, next) => {
 
 exports.createConversation = (req, res, next) => {
   try {
-    console.log("createConversation")
-    //création de la nouvelle conversation
     const newConversation = new Conversation({
       messages: [],
     });
 
-    //ajout de la conversation dans la liste des conversations de l'utilisateur 1
+    //adding the conversation to the user's list of conversations
     User.findOneAndUpdate(
       { _id: req.body.user1 },
       { $push: { matches: [newConversation] } }
     ).then((User1) => {
 
-      //ajout de la conversation dans la liste des conversations de l'utilisateur 2
       User.findOneAndUpdate(
         {
           _id:
@@ -83,6 +80,72 @@ exports.createConversation = (req, res, next) => {
   }
 };
 
+exports.createInstantConversation = (req, res, next) => {
+  const newConversation = new Conversation({
+    messages: [],
+  });
+
+  User.findOne({ _id: req.userToken.id })
+    .then((user) => {
+      if (user.nbInstantConversationPossibilities > 0) {
+        user.nbInstantConversationPossibilities -= 1;
+        user.save();
+        User.findOneAndUpdate(
+          { _id: req.userToken.id },
+          { $push: { matches: [newConversation] } }
+        )
+          .then((User1) => {
+            User.findOneAndUpdate(
+              { _id: req.body.user2 },
+              { $push: { matches: [newConversation] } }
+            )
+              .then((User2) => {
+                // Check if the conversation with the given members already exists
+                Conversation.findOne({ members: { $all: [User1, User2] } })
+                  .then((existingConversation) => {
+                    if (existingConversation) {
+                      // Conversation already exists
+                      res.send({
+                        message: "Conversation already exists",
+                        conversation: existingConversation,
+                      });
+                    } else {
+                      // Conversation doesn't exist, so add new conversation
+                      newConversation.members.push(User1);
+                      newConversation.members.push(User2);
+                      newConversation.save().then((conversation) => {
+                        res.send({
+                          message:
+                            "conversation " + conversation._id + " successfully added", conversation: conversation,
+                        });
+                      })
+                        .catch((error) => {
+                          next(error);
+                        });
+                    }
+                  })
+                  .catch((error) => {
+                    next(error);
+                  });
+              })
+              .catch((error) => {
+                next(error);
+              });
+          })
+          .catch((error) => {
+            next(error);
+          });
+      } else {
+        res.status(400).send({
+          message: "This user has no more instant conversation possibilities available",
+        });
+      }
+    })
+    .catch((error) => {
+      next(error);
+    });
+};
+
 exports.deleteConversation = async (req, res, next) => {
   try {
     res.send("endpoint wip");

src/models/user.js

@@ -155,6 +155,7 @@ const userSchema = new mongoose.Schema({
       default: "questions",
     },
   },
+  nbInstantConversationPossibilities: { type: Number, default: 1 },
 });
 
 module.exports = mongoose.model("User", userSchema);

src/routes/conversation.route.js

@@ -9,6 +9,7 @@ const verifyAdmin = require('../middlewares/verifyAdmin');
 router.get('/', verifyToken, conversationController.getAllConversation);
 router.post('/', conversationController.createConversation);
 // router.delete('/:id', verifyAdmin, conversationController.deleteConversation);
+router.post('/instant', verifyToken, conversationController.createInstantConversation);
 router.post('/block', verifyToken, conversationController.BlockConversation);
 router.post('/unblock', verifyToken, conversationController.UnblockConversation);
 router.post('/report', verifyToken, conversationController.ReportConversation);