Develop -> Main

src/chat/controllers/chat.controller.ts

@@ -26,7 +26,7 @@ export const createOrGetChatRoom = async (req: Request, res: Response): Promise<
   } catch (err: any) {
     console.error(err);
     res.fail({
-      error: err.name || "InternalServerError",
+      error: err.error || "InternalServerError",
       message: err.message || "채팅방 생성/반환 중 오류가 발생했습니다.",
       statusCode: err.statusCode || 500,
     });
@@ -61,7 +61,7 @@ export const getChatRoomDetail = async (req: Request, res: Response): Promise<vo
   } catch (err: any) {  
     console.error(err);
     res.fail({
-      error: err.name || "InternalServerError",
+      error: err.error || "InternalServerError",
       message: err.message || "채팅방 상세 조회 중 오류가 발생했습니다.",
       statusCode: err.statusCode || 500,
     });
@@ -99,9 +99,143 @@ export const getChatRoomList = async(req: Request, res: Response) => {
   } catch (err: any) {  
     console.error(err);
     res.fail({
-      error: err.name || "InternalServerError",
+      error: err.error || "InternalServerError",
       message: err.message || "채팅방 목록 조회 중 오류가 발생했습니다.",
       statusCode: err.statusCode || 500,
     });
   }
-} 
+} 
+
+// == 상대방 차단
+export const blockUser = async(req: Request, res: Response) => {
+  if (!req.user) {
+    res.fail({  
+      statusCode: 401,
+      error: "no user",
+      message: "로그인이 필요합니다.",
+    });
+    return;
+  } 
+  try {
+    const blockerId = (req.user as { user_id: number }).user_id;
+    const { blocked_user_id } = req.body as { blocked_user_id: number };
+
+    if (!blocked_user_id || isNaN(blocked_user_id)) {
+      res.fail({ statusCode: 400, error: "BadRequest", message: "올바른 blocked_user_id가 필요합니다." });
+      return;
+    }
+
+    if (blockerId === blocked_user_id) {
+      res.fail({ statusCode: 400, error: "BadRequest", message: "자기 자신을 차단할 수 없습니다." });
+      return;
+    }
+
+    await chatService.blockUserService(blockerId, blocked_user_id);
+
+    res.success(null, "상대방을 성공적으로 차단했습니다.");
+  } catch (err: any) {
+    console.error(err);
+    res.fail({
+      error: err.error || "InternalServerError",
+      message: err.message || "상대방 차단 중 오류가 발생했습니다.",
+      statusCode: err.statusCode || 500,
+    });
+  }
+};
+
+// == 채팅방 나가기
+export const leaveChatRoom = async(req: Request, res: Response) => {
+    if (!req.user) {
+      res.fail({  
+        statusCode: 401,
+        error: "no user",
+        message: "로그인이 필요합니다.",
+      });
+      return;
+    } 
+    try {
+      const userId = (req.user as { user_id: number }).user_id;
+      const roomId = Number(req.params.roomId);
+      console.log("🍀roomId:", roomId);
+
+      if (isNaN(roomId)) {
+        res.fail({ statusCode: 400, error: "BadRequest", message: "올바른 roomId가 필요합니다." });
+        return;
+      }
+      await chatService.leaveChatRoomService(roomId, userId);
+
+      res.success(null, "채팅방을 성공적으로 나갔습니다.");
+    } catch (err: any) {
+      console.error(err);
+      res.fail({
+        error: err.error || "InternalServerError",
+        message: err.message || "채팅방 나가기 중 오류가 발생했습니다.",
+        statusCode: err.statusCode || 500,
+      });
+    }
+};
+// == S3 presigned URL 발급
+export const getPresignedUrl = async(req: Request, res: Response) => {
+  if (!req.user) {
+    res.fail({  
+      statusCode: 401,
+      error: "no user",
+      message: "로그인이 필요합니다.",
+    });
+    return;
+  } 
+  try {
+    const rawFiles = req.body.files;
+
+    if (!rawFiles || !Array.isArray(rawFiles) || rawFiles.length === 0) {
+      res.fail({ statusCode: 400, error: "BadRequest", message: "업로드할 파일 정보가 필요합니다." });
+      return;
+    }
+
+    const files = rawFiles.map((file: any) => ({
+      fileName: file.name,
+      contentType: file.content_type
+    }));
+
+    const result = await chatService.getPresignedUrlService(files);
+
+    res.success(result, "presign을 성공적으로 발급했습니다.");
+  } catch (err: any) {
+    console.error(err);
+    res.fail({
+      error: err.error || "InternalServerError",
+      message: err.message || "presigned URL 생성 중 오류가 발생했습니다.",
+      statusCode: err.statusCode || 500,
+    });
+  }
+};
+
+// == 채팅방 고정 토글
+export const togglePinChatRoom = async(req: Request, res: Response) => {
+    if (!req.user) {
+      res.fail({  
+        statusCode: 401,
+        error: "no user",
+        message: "로그인이 필요합니다.",
+      });
+      return;
+    }
+    try {
+      const userId = (req.user as { user_id: number }).user_id;
+      const roomId = Number(req.params.roomId);
+      if (isNaN(roomId)) {
+        res.fail({ statusCode: 400, error: "BadRequest", message: "올바른 roomId가 필요합니다." });
+        return;
+      }
+      const isPinned = await chatService.togglePinChatRoomService(roomId, userId);
+      res.success(isPinned, "채팅방 고정을 성공적으로 토글했습니다.");
+    }
+    catch (err: any) {
+      console.error(err);
+      res.fail({
+        error: err.error || "InternalServerError",
+        message: err.message || "채팅방 고정 토글 중 오류가 발생했습니다.",
+        statusCode: err.statusCode || 500,
+      });
+    }
+  }

src/chat/dtos/chat.dto.ts

@@ -207,4 +207,9 @@ export class ChatRoomListResponseDto {
 
     return dto;
   }
+}
+
+// == 채팅방 고정 토글 
+export interface TogglePinResponseDto {
+  is_pinned: boolean;
 }

src/chat/repositories/chat.repository.ts

@@ -29,6 +29,7 @@ export class ChatRepository {
     });
   }
 
+  // == 채팅방 상세 조회 (참여자 정보 포함)
   async findRoomDetailWithParticipant(roomId: number) {
     return prisma.chatRoom.findUnique({
       where: { room_id: roomId },
@@ -40,6 +41,23 @@ export class ChatRepository {
     });
   }
 
+  // == 안읽은 메세지 초기화
+  async resetUnreadCount(roomId: number, userId: number, lastMessageId?: number | null) {
+    return prisma.chatParticipant.update({
+      where: {
+        room_id_user_id: {
+          room_id: roomId,
+          user_id: userId,
+        },
+      },
+      data: {
+        unread_count: 0,
+        last_read_message_id: lastMessageId,
+      },
+    });
+  }
+
+  // == 메시지 목록 조회
   async findMessagesByRoomId(roomId: number, cursor?: number, limit: number = 20, userId?: number) {
     const leftInfo = await prisma.chatParticipant.findFirst({
       where: {
@@ -194,6 +212,46 @@ export class ChatRepository {
     ]);
     return {rooms, totalRoom}
   };
-}
 
+  // == 상대방 차단
+  async blockUser(blockerId: number, blockedId: number) {
+    return prisma.userBlock.create({
+      data: {
+        blocker_id: blockerId,
+        blocked_id: blockedId,
+      },
+    });
+  }
+
+  // == 채팅방 나가기
+  async leaveChatRoom(roomId: number, userId: number) {
+    return prisma.chatParticipant.update({
+      where: {
+        room_id_user_id: {
+          room_id: roomId,
+          user_id: userId,  
+        },
+      },
+      data: {
+        left_at: new Date(),
+      },
+    }); 
+  };
+
+
+  // == 채팅방 고정 토글
+  async togglePinChatRoom(roomId: number, userId: number, isPinned: boolean) {
+    return prisma.chatParticipant.update({
+      where: {
+        room_id_user_id: {
+          room_id: roomId,
+          user_id: userId,
+        },
+      },
+      data: {
+        is_pinned: !isPinned, // 토글
+      },
+    });
+  }
+}