#270 안 읽은 메세지 확인

src/modules/auths/login.js

@@ -27,7 +27,7 @@ const login = (req, sid, id, oid, name) => {
 const logout = (req) => {
   // 로그아웃 전 socket.io 소켓들 연결부터 끊기
   const io = req.app.get("io");
-  if (io) io.in(req.session.id).disconnectSockets(true);
+  if (io) io.in(`session-${req.session.id}`).disconnectSockets(true);
 
   req.session.destroy((err) => {
     if (err) logger.error(err);

src/modules/populates/rooms.js

@@ -7,7 +7,7 @@ const roomPopulateOption = [
   { path: "to", select: "_id koName enName" },
   {
     path: "part",
-    select: "-_id user settlementStatus",
+    select: "-_id user settlementStatus readAt",
     populate: { path: "user", select: "_id id name nickname profileImageUrl" },
   },
 ];

src/modules/socket.js

@@ -187,6 +187,35 @@ const emitChatEvent = async (io, chat) => {
   }
 };
 
+const emitUpdateEvent = async (io, roomId) => {
+  try {
+    // 방의 모든 사용자에게 socket 메세지 업데이트 이벤트를 발생시킵니다.
+    if (!io || !roomId) {
+      throw new IllegalArgumentsException();
+    }
+
+    const { name, part } = await roomModel.findById(roomId, "name part");
+
+    if (!name || !part) {
+      throw new IllegalArgumentsException();
+    }
+
+    const userIds = part.map((participant) => participant.user);
+    await Promise.all(
+      userIds.map(async (userId) =>
+        io.in(`user-${userId}`).emit("chat_update", {
+          roomId,
+        })
+      )
+    );
+
+    return true;
+  } catch (err) {
+    logger.error(err);
+    return false;
+  }
+};
+
 // https://socket.io/how-to/use-with-express-session 참고
 const startSocketServer = (server) => {
   const io = new Server(server, {
@@ -198,7 +227,7 @@ const startSocketServer = (server) => {
         setHeader(key, values) {
           req.cookieHolder = values[0];
         },
-        writeHead() {},
+        writeHead() { },
       };
       sessionMiddleware(req, fakeRes, () => {
         if (req.session) {
@@ -235,7 +264,7 @@ const startSocketServer = (server) => {
         socket.join(`user-${userOid}`);
       });
 
-      socket.on("disconnect", () => {});
+      socket.on("disconnect", () => { });
     } catch (err) {
       logger.error(err);
     }
@@ -247,5 +276,6 @@ const startSocketServer = (server) => {
 module.exports = {
   transformChatsForRoom,
   emitChatEvent,
+  emitUpdateEvent,
   startSocketServer,
 };

src/modules/stores/mongo.js

@@ -34,6 +34,7 @@ const participantSchema = Schema({
     enum: ["not-departed", "paid", "send-required", "sent"],
     default: "not-departed",
   },
+  readAt: { type: Date, required: true, default: () => Date.now() },
 });
 
 const deviceTokenSchema = Schema({
@@ -117,6 +118,7 @@ const locationSchema = Schema({
   latitude: { type: Number }, // 이후 required: true 로 수정 필요
   longitude: { type: Number }, // 이후 required: true 로 수정 필요
 });
+
 const chatSchema = Schema({
   roomId: { type: Schema.Types.ObjectId, ref: "Room", required: true },
   type: {

src/routes/chats.js

@@ -54,6 +54,18 @@ router.post(
   chatsHandlers.sendChatHandler
 );
 
+/**
+ * 채팅 읽은 시각 업데이트 요청을 처리합니다.
+ * 같은 방에 있는 user들에게 업데이트를 요청합니다.
+ */
+router.post(
+  "/read",
+  body("roomId").isMongoId(),
+  body("lastMsgDate").isISO8601(),
+  validator,
+  chatsHandlers.readChatHandler
+);
+
 // 채팅 이미지를 업로드할 수 있는 Presigned-url을 발급합니다.
 router.post(
   "/uploadChatImg/getPUrl",

src/services/chats.js

@@ -1,7 +1,14 @@
 const { chatModel, userModel, roomModel } = require("../modules/stores/mongo");
 const { chatPopulateOption } = require("../modules/populates/chats");
 const aws = require("../modules/stores/aws");
-const { transformChatsForRoom, emitChatEvent } = require("../modules/socket");
+const {
+  transformChatsForRoom,
+  emitChatEvent,
+  emitUpdateEvent,
+} = require("../modules/socket");
+const {
+  roomPopulateOption,
+} = require("../modules/populates/rooms");
 
 const chatCount = 60;
 
@@ -165,6 +172,58 @@ const sendChatHandler = async (req, res) => {
   }
 };
 
+const readChatHandler = async (req, res) => {
+  try {
+    const io = req.app.get("io");
+    const { userId } = req;
+    const { roomId, lastMsgDate } = req.body;
+    const user = await userModel.findOne({ id: userId });
+
+    if (!userId || !user) {
+      return res.status(500).send("Chat/read : internal server error");
+    }
+    if (!io) {
+      return res.status(403).send("Chat/read : socket did not connected");
+    }
+    const isPart = await isUserInRoom(userId, roomId);
+    if (!isPart) {
+      return res
+        .status(403)
+        .send("Chat/read : user did not participated in the room");
+    }
+
+    const roomObject = await roomModel
+      .findOneAndUpdate(
+        {
+          _id: roomId,
+          part: {
+            $elemMatch: {
+              user: user._id,
+            },
+          },
+        },
+        {
+          $set: { "part.$[updater].readAt": lastMsgDate },
+        },
+        {
+          new: true,
+          arrayFilters: [{ "updater.user": { $eq: user._id } }],
+        }
+      )
+      .lean()
+      .populate(roomPopulateOption);
+
+    if (!roomObject) {
+      return res.status(404).send("Chat/read : cannot find room info");
+    }
+
+    if (await emitUpdateEvent(io, roomId)) res.json({ result: true });
+    else res.status(500).send("Chat/read : failed to emit socket events");
+  } catch (e) {
+    res.status(500).send("Chat/read : internal server error");
+  }
+};
+
 const uploadChatImgGetPUrlHandler = async (req, res) => {
   try {
     const { type, roomId } = req.body;
@@ -277,4 +336,5 @@ module.exports = {
   sendChatHandler,
   uploadChatImgGetPUrlHandler,
   uploadChatImgDoneHandler,
+  readChatHandler,
 };