[25.08.25 / TASK-247] Fix - Leaderboard 쿼리 결과값 버그 수정 (#44)

* fix: 리더보드 비정상적인 집계값 수정
* refactor: 중복된 날짜 계산 개선
* test: 통합 테스트에 버그 픽스한 부분 추가 및 skip 삭제
* fix: 전체 데이터 수집 전(00시~01시)의 요청에 대한 방어로직 추가
* fix: linting
* refactor: 비정상 데이터 필터링 구문 개선

Author: ooheunda

src/controllers/user.controller.ts

@@ -8,7 +8,6 @@ import { fetchVelogApi } from '@/modules/velog/velog.api';
 
 type Token10 = string & { __lengthBrand: 10 };
 
-// eslint-disable-next-line @typescript-eslint/naming-convention
 const THREE_WEEKS_IN_MS = 21 * 24 * 60 * 60 * 1000;
 
 export class UserController {

src/repositories/__test__/integration/leaderboard.repo.integration.test.ts

@@ -1,4 +1,3 @@
-/* eslint-disable jest/no-disabled-tests */
 /**
  * 주의: 이 통합 테스트는 현재 시간에 의존적입니다.
  * getCurrentKSTDateString과 getKSTDateStringWithOffset 함수는 실제 시간을 기준으로
@@ -10,22 +9,21 @@ import dotenv from 'dotenv';
 import pg, { Pool } from 'pg';
 import { LeaderboardRepository } from '@/repositories/leaderboard.repository';
 import { PostLeaderboardSortType, UserLeaderboardSortType } from '@/types';
+import { getKSTDateStringWithOffset } from '@/utils/date.util';
 
 dotenv.config();
-
-jest.setTimeout(60000); // 각 케이스당 60초 타임아웃 설정
+jest.setTimeout(30000); // 각 케이스당 30초 타임아웃 설정
 
 /**
  * LeaderboardRepository 통합 테스트
  *
  * 이 테스트 파일은 실제 데이터베이스와 연결하여 LeaderboardRepository의 모든 메서드를
  * 실제 환경과 동일한 조건에서 테스트합니다.
  */
-describe.skip('LeaderboardRepository 통합 테스트', () => {
+describe('LeaderboardRepository 통합 테스트', () => {
   let testPool: Pool;
   let repo: LeaderboardRepository;
 
-  // eslint-disable-next-line @typescript-eslint/naming-convention
   const DEFAULT_PARAMS = {
     USER_SORT: 'viewCount' as UserLeaderboardSortType,
     POST_SORT: 'viewCount' as PostLeaderboardSortType,
@@ -45,7 +43,7 @@ describe.skip('LeaderboardRepository 통합 테스트', () => {
         idleTimeoutMillis: 30000, // 연결 유휴 시간 (30초)
         connectionTimeoutMillis: 5000, // 연결 시간 초과 (5초)
         allowExitOnIdle: false, // 유휴 상태에서 종료 허용
-        statement_timeout: 60000, // 쿼리 타임아웃 증가 (60초)
+        statement_timeout: 30000, // 쿼리 타임아웃 증가 (30초)
       };
 
       // localhost 가 아니면 ssl 필수
@@ -80,10 +78,17 @@ describe.skip('LeaderboardRepository 통합 테스트', () => {
 
   afterAll(async () => {
     try {
-      jest.clearAllMocks();
-
-      // 풀 완전 종료
-      await testPool.end();
+        // 모든 쿼리 완료 대기
+        await new Promise(resolve => setTimeout(resolve, 1000));
+  
+        // 풀 완전 종료
+        if (testPool) {
+          // 강제 종료: 모든 활성 쿼리와 연결 중지
+          await testPool.end();
+        }
+  
+        // 추가 정리 시간
+        await new Promise(resolve => setTimeout(resolve, 1000));
 
       logger.info('LeaderboardRepository 통합 테스트 DB 연결 종료');
     } catch (error) {
@@ -225,6 +230,16 @@ describe.skip('LeaderboardRepository 통합 테스트', () => {
         expect(user.username).not.toBeNull();
       });
     });
+
+    it('데이터 수집이 비정상적인 유저는 리더보드에 포함되지 않아야 한다', async () => {
+      const result = await repo.getUserLeaderboard(DEFAULT_PARAMS.USER_SORT, DEFAULT_PARAMS.DATE_RANGE, 30);
+
+      if (!isEnoughData(result, 1, '사용자 리더보드 비정상 유저 필터링')) return;
+
+      result.forEach((user) => {
+        expect(Number(user.total_views)).not.toBe(Number(user.view_diff));
+      });
+    });
   });
 
   describe('getPostLeaderboard', () => {
@@ -342,6 +357,20 @@ describe.skip('LeaderboardRepository 통합 테스트', () => {
         expect(areDifferent).toBe(true);
       }
     });
+
+    it('데이터 수집이 비정상적인 게시물은 리더보드에 포함되지 않아야 한다', async () => {
+      const result = await repo.getPostLeaderboard(DEFAULT_PARAMS.POST_SORT, DEFAULT_PARAMS.DATE_RANGE, 30);
+      const pastDateKST = getKSTDateStringWithOffset(-DEFAULT_PARAMS.DATE_RANGE * 24 * 60);
+
+      if (!isEnoughData(result, 1, '게시물 리더보드 비정상 게시물 필터링')) return;
+
+      result.forEach((post) => {
+        if (post.released_at < pastDateKST) {
+          // eslint-disable-next-line jest/no-conditional-expect
+          expect(Number(post.total_views)).not.toBe(Number(post.view_diff));
+        }
+      });
+    });
   });
 });
 

src/repositories/__test__/integration/post.repo.integration.test.ts

@@ -19,7 +19,6 @@ describe('PostRepository 통합 테스트', () => {
   let repo: PostRepository;
 
   // 테스트에 사용할 기본 데이터 ID
-  // eslint-disable-next-line @typescript-eslint/naming-convention
   const TEST_DATA = {
     USER_ID: 1,
     POST_ID: 2445,

src/repositories/__test__/leaderboard.repo.test.ts

@@ -79,11 +79,20 @@ describe('LeaderboardRepository', () => {
       await repo.getUserLeaderboard('viewCount', mockDateRange, 10);
 
       expect(mockPool.query).toHaveBeenCalledWith(
-        expect.stringContaining('WHERE date >='), // pastDateKST를 사용하는 부분 확인
+        expect.stringContaining('WHERE date ='), // pastDateKST를 사용하는 부분 확인
         [expect.any(Number)], // limit
       );
     });
 
+    it('데이터 수집이 비정상적인 유저는 리더보드에 포함되지 않아야 한다', async () => {
+      await repo.getUserLeaderboard('viewCount', 30, 10);
+
+      expect(mockPool.query).toHaveBeenCalledWith(
+        expect.stringContaining('HAVING SUM(COALESCE(ss.start_view, 0)) != 0'),
+        expect.anything(),
+      );
+    });
+
     it('에러 발생 시 DBError를 던져야 한다', async () => {
       mockPool.query.mockRejectedValue(new Error('DB connection failed'));
       await expect(repo.getUserLeaderboard('viewCount', 30, 10)).rejects.toThrow(DBError);
@@ -156,11 +165,20 @@ describe('LeaderboardRepository', () => {
       await repo.getPostLeaderboard('viewCount', mockDateRange, 10);
 
       expect(mockPool.query).toHaveBeenCalledWith(
-        expect.stringContaining('WHERE date >='), // pastDateKST를 사용하는 부분 확인
+        expect.stringContaining('WHERE date ='), // pastDateKST를 사용하는 부분 확인
         [expect.any(Number)], // limit
       );
     });
 
+    it('데이터 수집이 비정상적인 게시물은 리더보드에 포함되지 않아야 한다', async () => {
+      await repo.getPostLeaderboard('viewCount', 30, 10);
+
+      expect(mockPool.query).toHaveBeenCalledWith(
+        expect.stringContaining('ss.post_id IS NOT NULL'),
+        expect.anything()
+      );
+    });
+
     it('에러 발생 시 DBError를 던져야 한다', async () => {
       mockPool.query.mockRejectedValue(new Error('DB connection failed'));
       await expect(repo.getPostLeaderboard('viewCount', 30, 10)).rejects.toThrow(DBError);

src/repositories/leaderboard.repository.ts

@@ -10,7 +10,7 @@ export class LeaderboardRepository {
   async getUserLeaderboard(sort: UserLeaderboardSortType, dateRange: number, limit: number) {
     try {
       const pastDateKST = getKSTDateStringWithOffset(-dateRange * 24 * 60);
-      const cteQuery = this.buildLeaderboardCteQuery(dateRange);
+      const cteQuery = this.buildLeaderboardCteQuery(dateRange, pastDateKST);
 
       const query = `
         ${cteQuery}
@@ -21,15 +21,16 @@ export class LeaderboardRepository {
           COALESCE(SUM(ts.today_view), 0) AS total_views,
           COALESCE(SUM(ts.today_like), 0) AS total_likes, 
           COUNT(DISTINCT CASE WHEN p.is_active = true THEN p.id END) AS total_posts,
-          SUM(COALESCE(ts.today_view, 0) - COALESCE(ss.start_view, COALESCE(ts.today_view, 0))) AS view_diff,
-          SUM(COALESCE(ts.today_like, 0) - COALESCE(ss.start_like, COALESCE(ts.today_like, 0))) AS like_diff,
+          SUM(COALESCE(ts.today_view, 0) - COALESCE(ss.start_view, 0)) AS view_diff,
+          SUM(COALESCE(ts.today_like, 0) - COALESCE(ss.start_like, 0)) AS like_diff,
           COUNT(DISTINCT CASE WHEN p.released_at >= '${pastDateKST}' AND p.is_active = true THEN p.id END) AS post_diff
         FROM users_user u
         LEFT JOIN posts_post p ON p.user_id = u.id
         LEFT JOIN today_stats ts ON ts.post_id = p.id
         LEFT JOIN start_stats ss ON ss.post_id = p.id
         WHERE u.username IS NOT NULL
         GROUP BY u.id, u.email, u.username
+        HAVING SUM(COALESCE(ss.start_view, 0)) != 0
         ORDER BY ${this.SORT_COL_MAPPING[sort]} DESC, u.id
         LIMIT $1;
       `;
@@ -44,7 +45,8 @@ export class LeaderboardRepository {
 
   async getPostLeaderboard(sort: PostLeaderboardSortType, dateRange: number, limit: number) {
     try {
-      const cteQuery = this.buildLeaderboardCteQuery(dateRange);
+      const pastDateKST = getKSTDateStringWithOffset(-dateRange * 24 * 60);
+      const cteQuery = this.buildLeaderboardCteQuery(dateRange, pastDateKST);
 
       const query = `
         ${cteQuery}
@@ -56,13 +58,18 @@ export class LeaderboardRepository {
           u.username AS username,
           COALESCE(ts.today_view, 0) AS total_views,
           COALESCE(ts.today_like, 0) AS total_likes,
-          COALESCE(ts.today_view, 0) - COALESCE(ss.start_view, COALESCE(ts.today_view, 0)) AS view_diff,
-          COALESCE(ts.today_like, 0) - COALESCE(ss.start_like, COALESCE(ts.today_like, 0)) AS like_diff
+          COALESCE(ts.today_view, 0) - COALESCE(ss.start_view, 0) AS view_diff,
+          COALESCE(ts.today_like, 0) - COALESCE(ss.start_like, 0) AS like_diff
         FROM posts_post p
         LEFT JOIN users_user u ON u.id = p.user_id
         LEFT JOIN today_stats ts ON ts.post_id = p.id
         LEFT JOIN start_stats ss ON ss.post_id = p.id
         WHERE p.is_active = true
+          AND (
+            p.released_at >= '${pastDateKST}'
+            OR 
+            ss.post_id IS NOT NULL
+          )
         ORDER BY ${this.SORT_COL_MAPPING[sort]} DESC, p.id
         LIMIT $1;
       `;
@@ -76,10 +83,16 @@ export class LeaderboardRepository {
   }
 
   // 오늘 날짜와 기준 날짜의 통계를 가져오는 CTE(임시 결과 집합) 쿼리 빌드
-  private buildLeaderboardCteQuery(dateRange: number) {
-    const nowDateKST = getCurrentKSTDateString();
-    // 과거 날짜 계산 (dateRange일 전)
-    const pastDateKST = getKSTDateStringWithOffset(-dateRange * 24 * 60);
+  private buildLeaderboardCteQuery(dateRange: number, pastDateKST?: string) {
+    // KST 기준 00시~01시 (UTC 15:00~16:00) 사이라면 전날 데이터를 사용
+    const nowDateKST =
+      new Date().getUTCHours() === 15
+        ? getKSTDateStringWithOffset(-24 * 60) // 전날 데이터
+        : getCurrentKSTDateString();
+
+    if (!pastDateKST) {
+      pastDateKST = getKSTDateStringWithOffset(-dateRange * 24 * 60);
+    }
 
     return `
       WITH 
@@ -89,17 +102,15 @@ export class LeaderboardRepository {
           daily_view_count AS today_view,
           daily_like_count AS today_like
         FROM posts_postdailystatistics
-        WHERE date <= '${nowDateKST}'
-        ORDER BY post_id, date DESC
+        WHERE date = '${nowDateKST}'
       ),
       start_stats AS (
         SELECT DISTINCT ON (post_id)
           post_id,
           daily_view_count AS start_view,
           daily_like_count AS start_like
         FROM posts_postdailystatistics
-        WHERE date >= '${pastDateKST}'
-        ORDER BY post_id, date ASC
+        WHERE date = '${pastDateKST}'
       )
     `;
   }