feature : 로그아웃

Author: Joonw00

srcs/aichat/aichat.controller.js

@@ -17,6 +17,7 @@ export const createAiChatSession = async (req, res) => {
 export const handleAiChat = async (req, res) => {
   try {
     const { thread_id, message } = req.body;
+    const userId = req.userId;
     if (!thread_id || !message) {
       return res.status(400).json(response(status.BAD_REQUEST, "thread_id와 메시지를 입력하세요"));
     }

srcs/aichat/aichat.route.js

@@ -1,8 +1,13 @@
 import express from "express";
 import { createAiChatSession, handleAiChat } from "./aichat.controller.js";
+import authenticateToken from "../../config/jwt.middleware.js";
 
 export const aichatRouter = express.Router();
 
+
+aichatRouter.use(authenticateToken);
+
+
 aichatRouter.post("/session", createAiChatSession); // 세션 생성
 aichatRouter.post("/chat", handleAiChat); // 채팅
 export default aichatRouter;

srcs/auth/auth.controller.js

@@ -38,6 +38,13 @@ const handleKakaoAuth = async (req, res) => {
     try {
         const code  = req.body.code || req.query.code;  
 
+        // 
+        if (!code) {
+            return res.json(response(
+                { isSuccess: status.BAD_REQUEST.isSuccess, code: 400, message: "인가 코드가 없습니다." },
+                authErrorResponseDTO("인가 코드가 필요합니다.")
+            ));
+        }
         const { accessToken, refreshToken, userInfo, isNewUser } = await kakaoLogin(code);
 
         return res.status(isNewUser ? 201 : 200).json(response(

srcs/auth/auth.route.js

@@ -6,8 +6,9 @@ import {
   handleGoogleAuth,
   handleTokenRefresh,
 } from "./auth.controller.js";
-import { signupUser, loginUser } from "../user/user.controller.js";
+import { signupUser, loginUser, logout } from "../user/user.controller.js";
 import { authMiddleware } from "./auth.middleware.js";
+import authenticateToken from "../../config/jwt.middleware.js";
 
 const authRouter = express.Router();
 authRouter.get("/verify", authMiddleware);
@@ -38,4 +39,8 @@ authRouter.post("/refresh", handleTokenRefresh);
 authRouter.post("/signUp", signupUser);
 authRouter.post("/login", loginUser);
 
+authRouter.use(authenticateToken);
+
+authRouter.post("/logout", authenticateToken, logout);
+
 export default authRouter;

srcs/user/user.controller.js

@@ -101,4 +101,31 @@ export const loginUser = async (req, res) => {
     console.log(error);
     res.send(response(status.BAD_REQUEST, "로그인 실패"));
   }
+};
+
+export const logout = async (req, res) => {
+  try {
+      const userId = req.userId;
+      console.log(userId);
+
+      if (!userId) {
+          return res.status(401).json(response(
+              { isSuccess: false, code: 401, message: "로그인이 필요합니다." },
+              {}
+          ));
+      }
+
+      await UserService.logoutUser(userId);
+
+      return res.status(200).json(response(
+          { isSuccess: true, code: 200, message: "로그아웃 성공" },
+          {}
+      ));
+  } catch (error) {
+      console.error("로그아웃 에러:", error);
+      return res.status(500).json(response(
+          { isSuccess: false, code: 500, message: "로그아웃 중 오류 발생" },
+          {}
+      ));
+  }
 };

srcs/user/user.model.js

@@ -142,4 +142,14 @@ export const UserModel = {
       throw new Error("프로필변경 실패");
     }
   },
+
+  userLogout: async (userId) => {
+    try {
+      await pool.query(sql.userLogoutSQL, [userId]);
+      console.log(`사용자 ${userId} 로그아웃 완료`);
+    } catch (error) {
+      console.error("로그아웃 서비스 오류:", error);
+      throw new Error("로그아웃 실패");
+    }
+  }
 };

srcs/user/user.service.js

@@ -103,4 +103,16 @@ export const UserService = {
       throw new BaseError(status.BAD_REQUEST, "프로필 변경 실패");
     }
   },
+
+  logoutUser: async (userId) => {
+    try {
+        await UserModel.userLogout(userId);
+        console.log(`사용자 ${userId} 로그아웃 완료`);
+    } catch (error) {
+        console.error("로그아웃 서비스 오류:", error);
+        throw new Error("로그아웃 실패");
+    }
+  }
+
+
 };

srcs/user/user.sql.js

@@ -10,4 +10,5 @@ export const sql = {
   postRefreshToken: `UPDATE user SET refresh_token = ? WHERE user_id = ?`,
   logoutUserSQL: `UPDATE user SET refresh_token = ? WHERE user_id = ?`,
   updateProfileSQL: `UPDATE user SET profile_image_url = ? WHERE user_id = ?`,
+  userLogoutSQL: `UPDATE user SET refresh_token = NULL WHERE user_id = ?`,
 };