feature: 배치, soft delete 기능과 is active false 의 추가로 이에 모든 조건에 해당 조건 추가

Author: Nuung

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

@@ -56,6 +56,28 @@ describe('PostRepository', () => {
       expect(result.posts).toEqual(mockPosts);
       expect(result.posts[0].id).toBeGreaterThan(result.posts[1].id);
     });
+
+    it('쿼리에 is_active = TRUE 조건이 포함되어야 한다', async () => {
+      const mockPosts = [
+        { id: 1, post_released_at: '2025-03-01T00:00:00Z', daily_view_count: 10, daily_like_count: 5 },
+      ];
+
+      mockPool.query.mockResolvedValue({
+        rows: mockPosts,
+        rowCount: mockPosts.length,
+        command: '',
+        oid: 0,
+        fields: [],
+      } as QueryResult);
+
+      await repo.findPostsByUserId(1);
+
+      // 쿼리 호출 확인
+      expect(mockPool.query).toHaveBeenCalledWith(
+        expect.stringContaining("p.is_active = TRUE"),
+        expect.anything()
+      );
+    });
   });
 
   describe('findPostsByUserIdWithGrowthMetrics', () => {
@@ -157,6 +179,28 @@ describe('PostRepository', () => {
       mockPool.query.mockRejectedValue(new Error('DB connection failed'));
       await expect(repo.findPostsByUserIdWithGrowthMetrics(1)).rejects.toThrow(DBError);
     });
+
+    it('쿼리에 is_active = TRUE 조건이 포함되어야 한다', async () => {
+      const mockPosts = [
+        { id: 1, view_growth: 20, like_growth: 5 },
+      ];
+
+      mockPool.query.mockResolvedValue({
+        rows: mockPosts,
+        rowCount: mockPosts.length,
+        command: '',
+        oid: 0,
+        fields: [],
+      } as QueryResult);
+
+      await repo.findPostsByUserIdWithGrowthMetrics(1);
+
+      // 쿼리 호출 확인
+      expect(mockPool.query).toHaveBeenCalledWith(
+        expect.stringContaining("p.is_active = TRUE"),
+        expect.anything()
+      );
+    });
   });
 
   describe('getTotalPostCounts', () => {
@@ -172,6 +216,24 @@ describe('PostRepository', () => {
       const count = await repo.getTotalPostCounts(1);
       expect(count).toBe(10);
     });
+
+    it('is_active = TRUE인 게시물만 카운트해야 한다', async () => {
+      mockPool.query.mockResolvedValue({
+        rows: [{ count: '5' }],
+        rowCount: 1,
+        command: '',
+        oid: 0,
+        fields: [],
+      } as QueryResult);
+    
+      await repo.getTotalPostCounts(1);
+    
+      // 쿼리 호출 확인
+      expect(mockPool.query).toHaveBeenCalledWith(
+        expect.stringContaining("is_active = TRUE"),
+        expect.anything()
+      );
+    });
   });
 
   describe('에러 발생 시 처리', () => {
@@ -204,6 +266,24 @@ describe('PostRepository', () => {
       const result = await repo.getYesterdayAndTodayViewLikeStats(1);
       expect(result).toEqual(mockStats);
     });
+
+    it('is_active = TRUE인 게시물의 통계만 반환해야 한다', async () => {
+      mockPool.query.mockResolvedValue({
+        rows: [{ daily_view_count: 20, daily_like_count: 15 }],
+        rowCount: 1,
+        command: '',
+        oid: 0,
+        fields: [],
+      } as QueryResult);
+    
+      await repo.getYesterdayAndTodayViewLikeStats(1);
+    
+      // 쿼리 호출 확인
+      expect(mockPool.query).toHaveBeenCalledWith(
+        expect.stringContaining("p.is_active = TRUE"),
+        expect.anything()
+      );
+    });    
   });
 
   describe('findPostByPostId', () => {

src/repositories/post.repository.ts

@@ -78,6 +78,7 @@ export class PostRepository {
           WHERE (date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date = (NOW() AT TIME ZONE 'UTC' - INTERVAL '1 day')::date
         ) yesterday_stats ON p.id = yesterday_stats.post_id
         WHERE p.user_id = $1
+          AND p.is_active = TRUE
           AND (pds.post_id IS NOT NULL OR yesterday_stats.post_id IS NOT NULL)
           ${cursorCondition}
         ORDER BY ${orderBy}
@@ -182,6 +183,7 @@ export class PostRepository {
         WHERE (date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date = (NOW() AT TIME ZONE 'UTC' - INTERVAL '1 day')::date
       ) yesterday_stats ON p.id = yesterday_stats.post_id
       WHERE p.user_id = $1
+        AND p.is_active = TRUE
         AND (pds.post_id IS NOT NULL OR yesterday_stats.post_id IS NOT NULL)
         ${cursorCondition}
       ORDER BY ${orderByExpression}
@@ -213,7 +215,7 @@ export class PostRepository {
 
   async getTotalPostCounts(id: number) {
     try {
-      const query = 'SELECT COUNT(*) FROM "posts_post" WHERE user_id = $1';
+      const query = 'SELECT COUNT(*) FROM "posts_post" WHERE user_id = $1 AND is_active = TRUE';
       const result = await this.pool.query(query, [id]);
       return parseInt(result.rows[0].count, 10);
     } catch (error) {
@@ -244,6 +246,7 @@ export class PostRepository {
           WHERE (date AT TIME ZONE 'Asia/Seoul' AT TIME ZONE 'UTC')::date = (NOW() AT TIME ZONE 'UTC' - INTERVAL '1 day')::date
         ) yesterday_stats ON p.id = yesterday_stats.post_id
         WHERE p.user_id = $1
+        AND p.is_active = TRUE
       `;
       const values = [userId];
 
@@ -304,6 +307,7 @@ export class PostRepository {
       FROM posts_post p
       JOIN posts_postdailystatistics pds ON p.id = pds.post_id
       WHERE p.post_uuid = $1
+        AND p.is_active = TRUE
         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
       ORDER BY pds.date ASC