Develop -> Main

package.json

@@ -3,7 +3,7 @@
   "version": "1.0.0",
   "main": "index.js",
   "scripts": {
-    "dev": "ts-node-dev --respawn --transpile-only src/index.ts",
+    "dev": "dotenv -e .env.dev -- ts-node-dev --respawn --transpile-only src/index.ts",
     "test": "echo \"Error: no test specified\" && exit 1",
     "start": "node dist/index.js",
     "prebuild": "npm run generate:swagger",
@@ -68,6 +68,7 @@
     "@types/swagger-jsdoc": "^6.0.4",
     "@types/swagger-ui-express": "^4.1.8",
     "@types/uuid": "^10.0.0",
+    "dotenv-cli": "^11.0.0",
     "nodemon": "^3.1.10",
     "prisma": "^6.11.1",
     "ts-node": "^10.9.2",

prisma/migrations/20260121113801_add_unread_count_to_chat_participant/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE `ChatParticipant` ADD COLUMN `unreadCount` INTEGER NOT NULL DEFAULT 0;

prisma/migrations/20260121114120_change_camelcase_to_snake_case_at_chat_participant/migration.sql

@@ -0,0 +1,9 @@
+/*
+  Warnings:
+
+  - You are about to drop the column `unreadCount` on the `ChatParticipant` table. All the data in the column will be lost.
+
+*/
+-- AlterTable
+ALTER TABLE `ChatParticipant` DROP COLUMN `unreadCount`,
+    ADD COLUMN `unread_count` INTEGER NOT NULL DEFAULT 0;

prisma/schema.prisma

@@ -515,11 +515,12 @@ model ChatParticipant {
   room_id               Int
   user_id               Int
   last_read_message_id  Int?
+  unread_count           Int                 @default(0)
 
   chatRoom              ChatRoom            @relation("RoomParticipants", fields: [room_id], references: [room_id], onDelete: Cascade)
   user                  User                @relation(fields: [user_id], references: [user_id], onDelete: Cascade)
   lastReadMessage       ChatMessage?        @relation("LastReadMessage", fields: [last_read_message_id], references: [message_id], onDelete: SetNull)
-
+           
   @@unique([room_id, user_id])
 }
 

src/chat/controllers/chat.controller.ts

@@ -0,0 +1,107 @@
+import { Request, Response } from "express";
+import { chatService } from "../services/chat.service";
+import { 
+  CreateChatRoomRequestDto, 
+  GetChatRoomListRequestDto,
+  ChatFilterType
+} from "../dtos/chat.dto";
+
+export const createOrGetChatRoom = async (req: Request, res: Response): Promise<void> => {
+  if (!req.user) {
+    res.fail({
+      statusCode: 401,
+      error: "no user",
+      message: "로그인이 필요합니다.",
+    });
+    return;
+  }
+
+  try {
+    const userId = (req.user as { user_id: number }).user_id;
+    const { partner_id } = req.body as CreateChatRoomRequestDto;
+
+    const result = await chatService.createOrGetChatRoomService(userId, partner_id);
+
+    res.success(result, "채팅방을 성공적으로 생성/반환했습니다.");
+  } catch (err: any) {
+    console.error(err);
+    res.fail({
+      error: err.name || "InternalServerError",
+      message: err.message || "채팅방 생성/반환 중 오류가 발생했습니다.",
+      statusCode: err.statusCode || 500,
+    });
+  }
+};
+
+export const getChatRoomDetail = async (req: Request, res: Response): Promise<void> => {
+    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);
+    const cursor = req.query.cursor ? Number(req.query.cursor) : undefined;
+    const limit = req.query.limit ? Number(req.query.limit) : 20;
+
+    if (isNaN(roomId)) {
+      res.fail({ statusCode: 400, error: "BadRequest", message: "올바른 roomId 필요합니다." });
+      return;
+    }
+
+    const result = await chatService.getChatRoomDetailService(roomId, userId, cursor, limit);
+
+    res.success(result, "채팅방 상세를 성공적으로 조회했습니다.");
+  } catch (err: any) {  
+    console.error(err);
+    res.fail({
+      error: err.name || "InternalServerError",
+      message: err.message || "채팅방 상세 조회 중 오류가 발생했습니다.",
+      statusCode: err.statusCode || 500,
+    });
+  }
+}
+
+// == 채팅방 목록
+export const getChatRoomList = 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 { cursor, limit, filter, search } = req.query as unknown as GetChatRoomListRequestDto;
+
+    if (filter && filter !== "all" && filter !== "unread" && filter !== "pinned") {
+      res.fail({ statusCode: 400, error: "BadRequest", message: "올바른 filter값이 필요합니다." });
+      return;
+    }
+
+    const result = await chatService.getChatRoomListService(
+          userId, 
+          cursor ? Number(cursor) : undefined, 
+          limit ? Number(limit) : undefined,     
+          filter,
+          search as string                     
+        );      
+      res.success(result, "채팅방 목록을 성공적으로 조회했습니다.");
+  } catch (err: any) {  
+    console.error(err);
+    res.fail({
+      error: err.name || "InternalServerError",
+      message: err.message || "채팅방 목록 조회 중 오류가 발생했습니다.",
+      statusCode: err.statusCode || 500,
+    });
+  }
+}