feat: delete message reaction socket 구현 (#206)

* fix:  lastReplyAt 동작 버그 수정

* feat: message reaction delete socket 구현

* feat: limit을 10개에서 20개로 수정
magic number 수정

Author: ypd01018

server/src/service/message-reaction-service.ts

@@ -59,8 +59,8 @@ class MessageReactionService {
 
     const createdMessageReaction = await this.messageReactionRepository.save(newMessageReaction);
     const customMessageReaction = this.customMessageReaction(createdMessageReaction);
-    const displayNames = await this.addAuthorMessageReaction(customMessageReaction);
-    return { ...customMessageReaction, displayNames };
+    const authors = await this.addAuthorMessageReaction(customMessageReaction);
+    return { ...customMessageReaction, authors };
   }
 
   customMessageReaction(messageReaction) {
@@ -78,11 +78,12 @@ class MessageReactionService {
       .addSelect('user')
       .where('messageReaction.reactionId = :reactionId', { reactionId })
       .getMany();
-    const displayNames = AuthorMessageReaction.map((MessageReaction) => {
-      const { displayName } = MessageReaction.user;
-      return displayName;
+    const author = AuthorMessageReaction.map((MessageReaction) => {
+      const { displayName, userId } = MessageReaction.user;
+      return { displayName, userId };
     });
-    return displayNames;
+
+    return author;
   }
 
   async deleteMessageReaction(userId: number, messageId: number, reactionId: number) {
@@ -99,6 +100,23 @@ class MessageReactionService {
 
     await this.messageReactionRepository.softDelete(messageReaction.messageReactionId);
   }
+
+  async getMessageReaction(messageId: number, reactionId: number) {
+    const messageReactions = await this.messageReactionRepository
+      .createQueryBuilder('messageReaction')
+      .leftJoin('messageReaction.user', 'user')
+      .select('messageReaction')
+      .addSelect('user')
+      .where('messageReaction.messageId = :messageId', { messageId })
+      .andWhere('messageReaction.reactionId = :reactionId', { reactionId })
+      .getMany();
+    const authors = messageReactions.map((messageReaction) => {
+      const { userId, displayName } = messageReaction.user;
+      return { userId, displayName };
+    });
+    const { title, emoji } = await this.reactionRepository.findOne({ reactionId });
+    return { reactionId, title, emoji, messageId, authors };
+  }
 }
 
 export default MessageReactionService;

server/src/service/reply-service.ts

@@ -77,6 +77,7 @@ class ReplyService {
   }
 
   async getReplies(messageId: number, offsetId: number) {
+    const limit = 20;
     let where = 'reply.messageId = :messageId';
     where += offsetId ? ' AND reply.replyId < :offsetId' : '';
     const replies = await this.replyRepository
@@ -90,7 +91,7 @@ class ReplyService {
       .addSelect(['replyReactions', 'user', 'reaction'])
       .where(where, { messageId, offsetId })
       .orderBy('reply.replyId', 'DESC')
-      .take(10)
+      .take(limit)
       .getMany();
     const formattedReplies = replies.map((reply) => {
       const { replyReactions } = { ...reply };

server/src/socket/event/message-reaction-event.ts

@@ -3,6 +3,7 @@ import eventName from '@constants/event-name';
 
 const messageReactionEvent = (io, socket) => {
   socket.on(eventName.CREATE_REACTION, (messageReaction) => messageReactionHandler.createMessageReaction(io, socket, messageReaction));
+  socket.on(eventName.DELETE_REACTION, (messageReaction) => messageReactionHandler.deleteMessageReaction(io, socket, messageReaction));
 };
 
 export default messageReactionEvent;

server/src/socket/handler/message-reaction-handler.ts

@@ -10,6 +10,16 @@ const messageHandler = {
     const newMessageReaction = await MessageReactionService.getInstance().createMessageReaction(Number(userId), Number(messageId), title, emoji);
     const { chatroomId } = (await MessageServie.getInstance().getMessage(messageId)).chatroom;
     io.to(String(chatroomId)).emit(eventName.CREATE_REACTION, { ...newMessageReaction, chatroomId });
+  },
+
+  async deleteMessageReaction(io, socket, messageReaction) {
+    const req = socket.request;
+    const { userId } = req.user;
+    const { messageId, reactionId } = messageReaction;
+    await MessageReactionService.getInstance().deleteMessageReaction(Number(userId), Number(messageId), Number(reactionId));
+    const newMessageReaction = await MessageReactionService.getInstance().getMessageReaction(Number(messageId), Number(reactionId));
+    const { chatroomId } = (await MessageServie.getInstance().getMessage(messageId)).chatroom;
+    io.to(String(chatroomId)).emit(eventName.DELETE_REACTION, { ...newMessageReaction, chatroomId });
   }
 };