Merge pull request #115 from codeit-moving/release

Release -> main 20250102 17:08

Author: WooHyunTak

src/controllers/authController.ts

@@ -47,19 +47,11 @@ router.post(
         email,
         password,
       });
-      if (user) {
-        const accessToken = createToken(user, "access");
-        const refreshToken = createToken(user, "refresh");
-        res.cookie("accessToken", accessToken, cookieConfig.accessTokenOption);
-        res.cookie(
-          "refreshToken",
-          refreshToken,
-          cookieConfig.refreshTokenOption
-        );
-        res.status(204).send();
-      } else {
-        return res.status(400).send({ message: "로그인에 실패하였습니다." });
-      }
+      const accessToken = createToken(user, "access");
+      const refreshToken = createToken(user, "refresh");
+      res.cookie("accessToken", accessToken, cookieConfig.accessTokenOption);
+      res.cookie("refreshToken", refreshToken, cookieConfig.refreshTokenOption);
+      res.status(204).send();
     } catch (error) {
       next(error);
     }
@@ -142,9 +134,6 @@ router.post(
     try {
       const user = req.user as Payload;
       const userData = await userService.getUserById(user.id);
-      if (!userData) {
-        return res.status(400).send({ message: "유효하지 않은 사용자입니다." });
-      }
       const accessToken = createToken(
         {
           id: userData.id,

src/controllers/oauthController.ts

@@ -9,7 +9,7 @@ import {
   NAVER_CLIENT_ID,
   NAVER_REDIRECT_URI,
 } from "../env";
-import CustomError from "../utils/interfaces/customError";
+import { throwRedirectError } from "../utils/constructors/redirectError";
 
 const router = Router();
 
@@ -113,14 +113,10 @@ const handleOAuthCallback: RequestHandler = (req, res, next) => {
       mover: "/mover/profile",
     };
 
-    const error: CustomError = new Error("Forbidden");
-    error.status = 403;
-    error.data = {
-      message: messages[userType] || "프로필을 등록해주세요.",
-      redirectUrl: FRONTEND_URL + redirectUrls[userType],
-      redirect: true,
-    };
-    next(error);
+    return throwRedirectError(
+      messages[userType] || "프로필을 등록해주세요.",
+      redirectUrls[userType]
+    );
   }
 };
 

src/middlewares/authMiddleware.ts

@@ -5,6 +5,8 @@ import passport from "passport";
 import CustomError from "../utils/interfaces/customError";
 import userRepository from "../repositorys/userRepository";
 import { FRONTEND_URL } from "../env";
+import { throwRedirectError } from "../utils/constructors/redirectError";
+import { throwHttpError } from "../utils/constructors/httpError";
 
 interface authUser {
   id: number;
@@ -68,23 +70,10 @@ export const isCustomer = async (
   };
   const findUser = await userRepository.findById(user.id);
   if (!findUser) {
-    const error: CustomError = new Error("Unauthorized");
-    error.status = 403;
-    error.data = {
-      message: "유효하지 않은 사용자입니다.",
-    };
-    return next(error);
+    return throwHttpError(403, "유효하지 않은 사용자입니다.");
   }
-
   if (!user?.customerId) {
-    const error: CustomError = new Error("Unauthorized");
-    error.status = 403;
-    error.data = {
-      message: "고객 프로필을 먼저 등록해주세요",
-      redirectUrl: FRONTEND_URL + "/me/profile",
-      redirect: true,
-    };
-    return next(error);
+    return throwRedirectError("고객 프로필을 먼저 등록해주세요", "/me/profile");
   }
 
   next();
@@ -102,23 +91,13 @@ export const isMover = async (
   };
   const findUser = await userRepository.findById(user.id);
   if (!findUser) {
-    const error: CustomError = new Error("Unauthorized");
-    error.status = 403;
-    error.data = {
-      message: "유효하지 않은 사용자입니다.",
-    };
-    return next(error);
+    return throwHttpError(403, "유효하지 않은 사용자입니다.");
   }
   if (!user?.moverId) {
-    const error: CustomError = new Error("Unauthorized");
-    error.status = 403;
-    error.data = {
-      message: "기사 프로필을 먼저 등록해 주세요.",
-      redirectUrl: FRONTEND_URL + "/mover/profile",
-      redirect: true,
-    };
-    return next(error);
+    return throwRedirectError(
+      "기사 프로필을 먼저 등록해 주세요.",
+      "/mover/profile"
+    );
   }
-
   next();
 };

src/middlewares/passport.ts

@@ -16,34 +16,24 @@ import {
 } from "../env";
 import { JWT_SECRET } from "../env";
 import oauthService from "../services/oauthService";
-import CustomError from "../utils/interfaces/customError";
 import { Strategy } from "passport-custom";
 import jwt from "jsonwebtoken";
+import { HttpError } from "../utils/constructors/httpError";
 
 passport.use(
   "jwt",
   new Strategy(async (req, done) => {
     const token = req.cookies["accessToken"];
 
     if (!token) {
-      const error: CustomError = new Error("Token missing");
-      error.status = 403;
-      error.data = {
-        message: "토큰이 존재하지 않습니다.",
-      };
-      return done(error, false); // 토큰이 없을 때 에러 반환
+      return done(new HttpError(403, "토큰이 존재하지 않습니다."), false); // 토큰이 없을 때 에러 반환
     }
 
     try {
       const decoded = jwt.verify(token, JWT_SECRET);
       return done(null, decoded); // 토큰이 있고 유효하면 유저 정보 반환
     } catch (err) {
-      const error: CustomError = new Error("Invalid token");
-      error.status = 403;
-      error.data = {
-        message: "유효하지 않은 토큰입니다.",
-      };
-      return done(error, false); // 토큰이 있지만 유효하지 않으면 false 반환
+      return done(new HttpError(403, "유효하지 않은 토큰입니다."), false); // 토큰이 있지만 유효하지 않으면 false 반환
     }
   })
 );
@@ -71,24 +61,20 @@ passport.use(
     const refreshToken = req.cookies["refreshToken"];
 
     if (!refreshToken) {
-      const error: CustomError = new Error("Token missing");
-      error.status = 403;
-      error.data = {
-        message: "리프레시 토큰이 존재하지 않습니다.",
-      };
-      return done(error, false);
+      return done(
+        new HttpError(403, "리프레시 토큰이 존재하지 않습니다."),
+        false
+      );
     }
 
     try {
       const decoded = jwt.verify(refreshToken, REFRESH_SECRET);
       return done(null, decoded);
     } catch (err) {
-      const error: CustomError = new Error("Invalid token");
-      error.status = 403;
-      error.data = {
-        message: "유효하지 않은 리프레시 토큰입니다.",
-      };
-      return done(error, false);
+      return done(
+        new HttpError(403, "유효하지 않은 리프레시 토큰입니다."),
+        false
+      );
     }
   })
 );

src/middlewares/validations/movingRequest.ts

@@ -1,59 +1,35 @@
 import { RequestHandler } from "express";
 import customError from "../../utils/interfaces/customError";
+import { throwHttpError } from "../../utils/constructors/httpError";
 
 const createMovingRequestValidation: RequestHandler = (req, res, next) => {
   const { service, movingDate, pickupAddress, dropOffAddress, region } =
     req.body;
 
   if (!service || typeof service !== "number" || service < 1 || service > 3) {
-    const error: customError = new Error("Bad Request");
-    error.status = 400;
-    error.message = "Bad Request";
-    error.data = {
-      message: "이사 서비스 타입이 올바르지 않습니다.",
-    };
-    return next(error);
+    return throwHttpError(400, "이사 서비스 타입이 올바르지 않습니다.");
   }
-
   const date = new Date(movingDate);
-  if (!movingDate || !(date instanceof Date)) {
-    const error: customError = new Error("Bad Request");
-    error.status = 400;
-    error.message = "Bad Request";
-    error.data = {
-      message: "이사 날짜가 올바르지 않습니다.",
-    };
-    return next(error);
+
+  //이사 날짜 검증
+  if (!movingDate || isNaN(date.getTime())) {
+    return throwHttpError(400, "이사 날짜가 올바르지 않습니다.");
+  }
+
+  if (date <= new Date()) {
+    return throwHttpError(400, "이사 날짜는 오늘 이후여야 합니다.");
   }
 
   if (!pickupAddress || typeof pickupAddress !== "string") {
-    const error: customError = new Error("Bad Request");
-    error.status = 400;
-    error.message = "Bad Request";
-    error.data = {
-      message: "이사 출발지가 올바르지 않습니다.",
-    };
-    return next(error);
+    return throwHttpError(400, "이사 출발지가 올바르지 않습니다.");
   }
 
   if (!dropOffAddress || typeof dropOffAddress !== "string") {
-    const error: customError = new Error("Bad Request");
-    error.status = 400;
-    error.message = "Bad Request";
-    error.data = {
-      message: "이사 도착지가 올바르지 않습니다.",
-    };
-    return next(error);
+    return throwHttpError(400, "이사 도착지가 올바르지 않습니다.");
   }
 
   if (!region || typeof region !== "number") {
-    const error: customError = new Error("Bad Request");
-    error.status = 400;
-    error.message = "Bad Request";
-    error.data = {
-      message: "지역코드가 올바르지 않습니다.",
-    };
-    return next(error);
+    return throwHttpError(400, "지역코드가 올바르지 않습니다.");
   }
 
   next();

src/repositorys/moverRepository.ts

@@ -7,15 +7,6 @@ interface whereConditions {
   OR?: object[];
 }
 
-interface UpdateProfile {
-  nickname?: string;
-  career?: number;
-  introduction?: string;
-  description?: string;
-  services?: number[];
-  regions?: number[];
-}
-
 interface Profile {
   userId: number;
   nickname: string;
@@ -52,14 +43,14 @@ const getMoverCount = async (where: whereConditions) => {
 const getMoverList = (
   orderBy: { [key: string]: object | string },
   where: whereConditions,
-  cursor: number,
+  cursor: number | null,
   limit: number
 ) => {
   return prismaClient.mover.findMany({
-    orderBy,
+    orderBy: [orderBy, { id: "asc" }],
     where,
-    take: limit + 1, //커서 페이지 넘버 계산을 위해 1개 더 조회
-    skip: cursor ? 1 : 0, //커서 자신을 스킵하기 위함
+    take: limit + 1,
+    skip: cursor ? 1 : 0,
     cursor: cursor ? { id: cursor } : undefined,
     select: {
       ...defaultSelect,

src/repositorys/movingRequestRepository.ts

@@ -339,6 +339,7 @@ const getDesignatedMovers = (movingRequestId: number, moverId: number) => {
       mover: {
         select: {
           id: true,
+          nickname: true,
         },
       },
     },

src/schedules/images.ts

@@ -1,12 +1,11 @@
 import cron from "node-cron";
 import { deleteImages } from "../utils/s3.utils";
 import imageRepository from "../repositorys/imageRepository";
-import CustomError from "../utils/interfaces/customError";
+import { throwHttpError } from "../utils/constructors/httpError";
 
 // 매일 자정에 실행되는 크론 작업
 export const imageCleanup = () => {
   cron.schedule("0 0 * * *", async () => {
-    console.log("이미지 삭제 크론 작업 실행");
     try {
       const inActiveImages = await imageRepository.findInActiveImage(); //비활성화 이미지 조회
       // 각 이미지 삭제 처리
@@ -16,14 +15,12 @@ export const imageCleanup = () => {
             await deleteImages(image.imageUrl); // S3에서 이미지 삭제
             await imageRepository.deleteImage(image.imageUrl); // DB에서 이미지 URL 제거
           } catch (e) {
-            const error: CustomError = new Error();
-            error.message = "이미지 삭제 실패";
-            throw error;
+            return throwHttpError(500, "이미지 삭제 실패");
           }
         }
       }
     } catch (error) {
-      console.error("Error in cleanup job:", error);
+      return throwHttpError(500, "이미지 삭제 크론 작업 실행 실패");
     }
   });
 };

src/schedules/notifications.ts

@@ -47,12 +47,12 @@ const setMessage = async (confirmedQuote: ConfirmedQuote) => {
   );
   return [
     {
-      content: `내일은 ,${pickupLocation} -> ${dropOffLocation} 이사 예정일,이에요.`,
+      content: `내일은 ,${pickupLocation} → ${dropOffLocation} 이사 예정일,이에요.`,
       isRead: false,
       userId: confirmedQuote.mover.user.id,
     },
     {
-      content: `내일은 ,${pickupLocation} -> ${dropOffLocation} 이사 예정일,이에요.`,
+      content: `내일은 ,${pickupLocation} → ${dropOffLocation} 이사 예정일,이에요.`,
       isRead: false,
       userId: confirmedQuote.customer.user.id,
     },