From 5c40faa456ecdb83502ffcfe40e594a0a6796e07 Mon Sep 17 00:00:00 2001
From: chlehdwon <cookie000215@gmail.com>
Date: Tue, 30 May 2023 14:28:37 +0000
Subject: [PATCH] Add: emitUpdateEvent

---
 src/modules/socket.js | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)

diff --git a/src/modules/socket.js b/src/modules/socket.js
index c16e7856..1cf3ef7a 100644
--- a/src/modules/socket.js
+++ b/src/modules/socket.js
@@ -177,6 +177,35 @@ const emitChatEvent = async (io, chat) => {
   }
 };
 
+const emitUpdateEvent = async (io, roomId, userId) => {
+  try {
+    // 방의 모든 사용자에게 socket 메세지 업데이트 이벤트를 발생시킵니다.
+    if (!io || !roomId || !userId) {
+      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, {
@@ -237,5 +266,6 @@ const startSocketServer = (server) => {
 module.exports = {
   transformChatsForRoom,
   emitChatEvent,
+  emitUpdateEvent,
   startSocketServer,
 };