backend for view/create chat room

createchatroom.js

@@ -0,0 +1,29 @@
+const { MongoClient } = require("mongodb");
+
+module.exports = async function (roomId, roomname) {
+  const uri = process.env.DB_CREDENTIALS;
+
+  const client = new MongoClient(uri);
+  let successOrFail = false;
+  try {
+    await client.connect();
+
+    const database = client.db("4learn");
+    const collection = database.collection("Chatroom");
+
+    // create js obj received by /register
+
+    const doc = { roomId: roomId, chatroomName: roomname };
+    console.log(roomId);
+    const result = await collection.insertOne(doc);
+
+    console.log(`${result.insertedCount} documents were inserted into db`);
+    console.log(result.insertedCount > 0);
+    if (result.insertedCount > 0) {
+      successOrFail = true;
+      return true;
+    }
+  } finally {
+    await client.close();
+  }
+};

getchatroomlist.js

@@ -0,0 +1,24 @@
+const { MongoClient } = require("mongodb");
+
+module.exports = async function (roomListArray) {
+  const uri = process.env.DB_CREDENTIALS;
+
+  const client = new MongoClient(uri, { useUnifiedTopology: true });
+  let successOrFail = false;
+
+  try {
+    await client.connect();
+
+    const database = client.db("4learn");
+    const collection = database.collection("Chatroom");
+
+    // create js obj received by /login
+
+    const result = await collection.find();
+    console.log("getting list");
+    await result.forEach((result) => roomListArray.push(result));
+  } finally {
+    await client.close();
+    return roomListArray;
+  }
+};