hotfix: 날짜 조회 SQL 쿼리의 치명적인 이슈 핸들링

Author: Nuung

src/controllers/post.controller.ts

@@ -13,7 +13,7 @@ import {
 export class PostController {
   constructor(private postService: PostService) {}
 
-  getAllPost: RequestHandler = async (
+  getAllPosts: RequestHandler = async (
     req: Request<object, object, object, GetAllPostsQuery>,
     res: Response<PostsResponseDto>,
     next: NextFunction,
@@ -38,15 +38,15 @@ export class PostController {
     }
   };
 
-  getAllPostStatistics: RequestHandler = async (
+  getAllPostsStatistics: RequestHandler = async (
     req: Request,
     res: Response<PostStatisticsResponseDto>,
     next: NextFunction,
   ) => {
     try {
       const { id } = req.user;
 
-      const stats = await this.postService.getAllPostStatistics(id);
+      const stats = await this.postService.getAllPostsStatistics(id);
       const totalPostCount = await this.postService.getTotalPostCounts(id);
 
       const response = new PostStatisticsResponseDto(

src/repositories/post.repository.ts

@@ -3,7 +3,7 @@ import logger from '@/configs/logger.config';
 import { DBError } from '@/exception';
 
 export class PostRepository {
-  constructor(private pool: Pool) {}
+  constructor(private pool: Pool) { }
 
   async findPostsByUserId(userId: number, cursor?: string, sort?: string, isAsc?: boolean, limit: number = 15) {
     try {
@@ -162,28 +162,39 @@ export class PostRepository {
 
   async findPostByPostId(postId: number, start?: string, end?: string) {
     try {
-      let query = `
-      SELECT
-        (pds.date AT TIME ZONE 'Asia/Seoul') AT TIME ZONE 'UTC' AS date,
-        pds.daily_view_count,
-        pds.daily_like_count
-      FROM posts_postdailystatistics pds
-      WHERE pds.post_id = $1
-      ORDER BY pds.date ASC
+      // 기본 쿼리 부분
+      const baseQuery = `
+        SELECT
+          (pds.date AT TIME ZONE 'Asia/Seoul') AT TIME ZONE 'UTC' AS date,
+          pds.daily_view_count,
+          pds.daily_like_count
+        FROM posts_postdailystatistics pds
+        WHERE pds.post_id = $1
       `;
 
-      const values: (number | string)[] = [postId];
+      // 날짜 필터링 조건 구성
+      const dateFilterQuery = (start && end)
+        ? `
+          AND (pds.date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date >= ($2 AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date
+          AND (pds.date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date <= ($3 AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date
+        `
+        : '';
 
-      if (start && end) {
-        query += ` AND (pds.date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date >= ($2 AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date
-                   AND (pds.date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date <= ($3 AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date`;
-        values.push(start, end);
-      }
+      // 정렬 조건 추가
+      const orderByQuery = `ORDER BY pds.date ASC`;
 
-      const result = await this.pool.query(query, values);
+      // 최종 쿼리 조합
+      const fullQuery = [baseQuery, dateFilterQuery, orderByQuery].join(' ');
+
+      // 파라미터 배열 구성
+      const queryParams: Array<number | string> = [postId];
+      if (start && end) queryParams.push(start, end);
+
+      // 쿼리 실행
+      const result = await this.pool.query(fullQuery, queryParams);
       return result.rows;
     } catch (error) {
-      logger.error('Post Repo findPostByPostId error : ', error);
+      logger.error('Post Repo findPostByPostId error:', error);
       throw new DBError('단건 post 조회 중 문제가 발생했습니다.');
     }
   }

src/routes/post.router.ts

@@ -49,7 +49,7 @@ router.get(
   '/posts',
   authMiddleware.verify,
   validateRequestDto(GetAllPostsQueryDto, 'query'),
-  postController.getAllPost,
+  postController.getAllPosts,
 );
 
 /**
@@ -69,7 +69,7 @@ router.get(
  *       '500':
  *         description: 서버 오류 / 데이터 베이스 조회 오류
  */
-router.get('/posts-stats', authMiddleware.verify, postController.getAllPostStatistics);
+router.get('/posts-stats', authMiddleware.verify, postController.getAllPostsStatistics);
 
 /**
  * @swagger

src/services/post.service.ts

@@ -26,12 +26,12 @@ export class PostService {
         nextCursor: result.nextCursor,
       };
     } catch (error) {
-      logger.error('PostService getAllpost error : ', error);
+      logger.error('PostService getAllposts error : ', error);
       throw error;
     }
   }
 
-  async getAllPostStatistics(userId: number) {
+  async getAllPostsStatistics(userId: number) {
     try {
       const postsStatistics = await this.postRepo.getYesterdayAndTodayViewLikeStats(userId);
 
@@ -45,7 +45,7 @@ export class PostService {
 
       return transformedStatistics;
     } catch (error) {
-      logger.error('PostService getAllPostStatistics error : ', error);
+      logger.error('PostService getAllPostsStatistics error : ', error);
       throw error;
     }
   }